Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

5.195s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 0.211s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 0.284s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 1.296s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 0.162s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 0.171s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.015s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.014s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 0.131s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 0.149s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.017s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 0.154s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 0.135s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 0.164s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.015s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.115s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.107s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.103s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 0.119s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 0.139s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 0.105s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 0.124s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.013s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 0.107s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.014s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 0.108s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 0.116s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 0.105s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 0.107s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.081s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.079s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.088s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 0.105s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 0.101s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 0.104s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 0.105s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 0.098s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop] 0.098s passed

Standard output

2015-08-14 00:37:07,198 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 00:37:07,245 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-14 00:37:07,246 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EveryEveryPipeAssemblyPlatformTest
2015-08-14 00:37:07,334 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,353 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,363 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,373 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,379 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,387 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,393 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,393 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,399 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,404 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,409 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,410 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,410 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,412 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,413 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,413 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,418 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,419 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,425 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,433 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,440 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,448 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,454 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,455 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,459 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,463 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,463 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,464 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,464 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,465 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,468 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,469 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,473 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,473 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,477 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,481 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,484 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,488 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,491 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,494 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-14 00:37:07,815 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-14 00:37:08,115 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 00:37:08,212 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:08,214 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:08,227 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 8AA3D0F4A9C444F8B5839CB4361B72D9
2015-08-14 00:37:08,438 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 00:37:08,439 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:08,440 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:08,440 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-14 00:37:08,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:08,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:08,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:08,443 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-14 00:37:08,493 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-14 00:37:08,567 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-14 00:37:08,802 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1346544514_0001
2015-08-14 00:37:08,804 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:08,913 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:08,933 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:08,934 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:09,005 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,006 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-14 00:37:09,051 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-14 00:37:09,108 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-08-14 00:37:09,133 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:09,134 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:09,161 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:09,161 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,161 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-14 00:37:09,162 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:09,162 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:09,162 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:09,163 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-14 00:37:09,289 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local2087849887_0002
2015-08-14 00:37:09,290 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:09,297 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:09,305 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:09,305 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:09,320 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,320 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-14 00:37:09,342 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-14 00:37:09,394 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-14 00:37:09,415 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:09,415 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:09,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:09,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,441 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-14 00:37:09,442 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:09,442 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:09,442 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:09,442 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-14 00:37:09,519 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local356681799_0003
2015-08-14 00:37:09,520 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:09,528 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:09,537 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:09,537 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:09,551 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,551 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-14 00:37:09,572 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-14 00:37:09,606 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-14 00:37:09,624 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:09,625 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-14 00:37:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:09,647 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:09,648 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:09,648 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-14 00:37:09,706 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local865930210_0004
2015-08-14 00:37:09,706 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:09,712 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:09,719 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:09,720 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:09,731 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,732 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-14 00:37:09,748 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-14 00:37:09,778 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-14 00:37:09,789 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:09,790 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:09,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:09,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-14 00:37:09,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:09,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:09,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:09,812 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-14 00:37:09,872 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local58783430_0005
2015-08-14 00:37:09,873 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:09,878 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:09,885 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:09,885 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:09,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-14 00:37:09,915 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-14 00:37:09,940 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-14 00:37:09,950 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:09,951 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:09,970 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:09,971 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:09,971 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-14 00:37:09,971 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:09,971 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:09,971 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:09,972 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-14 00:37:10,026 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local2117935146_0006
2015-08-14 00:37:10,026 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,032 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,038 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,038 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,049 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,049 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-14 00:37:10,069 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-14 00:37:10,095 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-14 00:37:10,105 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,105 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,113 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-14 00:37:10,122 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,123 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-14 00:37:10,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,143 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,143 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-14 00:37:10,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1798462945_0007
2015-08-14 00:37:10,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,199 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,207 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,217 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,218 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-14 00:37:10,239 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-14 00:37:10,262 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-14 00:37:10,272 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,272 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,291 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,291 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-14 00:37:10,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,292 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,293 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-14 00:37:10,342 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1578154744_0008
2015-08-14 00:37:10,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,348 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,354 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,355 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,364 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,365 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-14 00:37:10,389 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-14 00:37:10,427 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-14 00:37:10,436 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,436 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-14 00:37:10,455 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,456 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,456 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,457 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-14 00:37:10,496 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1607464407_0009
2015-08-14 00:37:10,496 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,502 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,507 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,508 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,517 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-14 00:37:10,540 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-14 00:37:10,563 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-14 00:37:10,572 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,573 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,590 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,590 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,590 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-14 00:37:10,591 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,591 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,591 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,592 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-14 00:37:10,631 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local404343128_0010
2015-08-14 00:37:10,632 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,638 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,643 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,644 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,653 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-14 00:37:10,655 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,665 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,667 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,670 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local404343128_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.run(LocalJobRunner.java:354)
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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,673 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local404343128_0010 state at FAILED
2015-08-14 00:37:10,673 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 00:37:10,675 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 00:37:10,675 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 00:37:10,675 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 00:37:10,677 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-14 00:37:10,677 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 00:37:10,678 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-14 00:37:10,678 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-08-14 00:37:10,687 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,688 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,694 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-14 00:37:10,703 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,703 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,720 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,720 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,720 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-14 00:37:10,721 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,721 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,721 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,722 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-14 00:37:10,761 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1248938324_0011
2015-08-14 00:37:10,762 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,770 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,775 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-14 00:37:10,784 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,785 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,786 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,788 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1248938324_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.run(LocalJobRunner.java:354)
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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,793 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local1248938324_0011 state at FAILED
2015-08-14 00:37:10,793 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 00:37:10,793 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 00:37:10,793 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 00:37:10,794 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 00:37:10,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-14 00:37:10,796 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 00:37:10,797 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-14 00:37:10,797 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-14 00:37:10,806 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,807 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,824 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-14 00:37:10,825 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,825 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,825 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,826 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-14 00:37:10,869 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local401427665_0012
2015-08-14 00:37:10,870 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,876 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,881 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,881 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:10,890 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,890 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-14 00:37:10,891 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,892 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,893 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,895 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local401427665_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.run(LocalJobRunner.java:354)
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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:10,901 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local401427665_0012 state at FAILED
2015-08-14 00:37:10,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 00:37:10,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 00:37:10,902 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 00:37:10,903 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 00:37:10,903 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-14 00:37:10,904 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 00:37:10,904 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-14 00:37:10,905 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-14 00:37:10,914 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,914 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,920 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-14 00:37:10,929 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:10,930 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:10,945 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:10,945 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:10,946 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-14 00:37:10,946 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:10,946 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:10,946 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:10,947 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-14 00:37:10,985 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local828497717_0013
2015-08-14 00:37:10,986 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:10,992 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:10,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:10,997 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,006 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,006 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-14 00:37:11,029 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-14 00:37:11,050 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-14 00:37:11,060 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,060 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,065 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-14 00:37:11,086 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,087 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,101 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,102 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,102 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-14 00:37:11,103 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,103 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,104 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,104 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-14 00:37:11,140 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local2117570702_0014
2015-08-14 00:37:11,141 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,146 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,160 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,160 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-14 00:37:11,184 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-14 00:37:11,205 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-08-14 00:37:11,213 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,214 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,227 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,228 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,228 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-14 00:37:11,229 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,229 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,230 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,230 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-14 00:37:11,268 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local884553161_0015
2015-08-14 00:37:11,269 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,274 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,279 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,287 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,287 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-14 00:37:11,303 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-14 00:37:11,323 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-14 00:37:11,332 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,332 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,345 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,345 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,345 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-14 00:37:11,345 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,346 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,348 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,348 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-14 00:37:11,384 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local838856592_0016
2015-08-14 00:37:11,385 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,391 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,396 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,396 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,404 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-14 00:37:11,428 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-14 00:37:11,448 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-14 00:37:11,456 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,457 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-14 00:37:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,469 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,470 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-14 00:37:11,501 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local21738294_0017
2015-08-14 00:37:11,502 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,506 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,510 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,510 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,518 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-14 00:37:11,534 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-14 00:37:11,554 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-08-14 00:37:11,562 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,563 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-14 00:37:11,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,576 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-14 00:37:11,610 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local127979381_0018
2015-08-14 00:37:11,610 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,614 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,618 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,618 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,626 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,626 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-14 00:37:11,642 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-14 00:37:11,670 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-14 00:37:11,678 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,679 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,683 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-14 00:37:11,691 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,692 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,703 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,704 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,704 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-14 00:37:11,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,706 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-14 00:37:11,738 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local874124940_0019
2015-08-14 00:37:11,739 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,743 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,754 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,754 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-14 00:37:11,771 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-14 00:37:11,791 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-14 00:37:11,799 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,799 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-14 00:37:11,811 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,812 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,812 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-14 00:37:11,844 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local489385130_0020
2015-08-14 00:37:11,844 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,849 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,853 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,859 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,860 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-14 00:37:11,876 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-14 00:37:11,895 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-14 00:37:11,903 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,904 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,914 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:11,914 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-14 00:37:11,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:11,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:11,915 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:11,916 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-14 00:37:11,950 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1185785618_0021
2015-08-14 00:37:11,950 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:11,955 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:11,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:11,959 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:11,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:11,966 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-14 00:37:11,967 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:11,967 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:11,968 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:11,970 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1185785618_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.run(LocalJobRunner.java:354)
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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:11,973 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local1185785618_0021 state at FAILED
2015-08-14 00:37:11,974 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 00:37:11,974 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 00:37:11,975 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 00:37:11,975 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 00:37:11,975 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-14 00:37:11,976 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 00:37:11,976 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-14 00:37:11,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-08-14 00:37:11,985 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,985 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:11,989 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-14 00:37:11,997 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:11,997 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,007 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-14 00:37:12,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,008 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,009 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,010 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-14 00:37:12,041 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1509450946_0022
2015-08-14 00:37:12,042 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,046 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,051 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,058 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-14 00:37:12,059 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,060 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,061 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,063 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1509450946_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.run(LocalJobRunner.java:354)
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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,073 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local1509450946_0022 state at FAILED
2015-08-14 00:37:12,073 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 00:37:12,073 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 00:37:12,073 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 00:37:12,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 00:37:12,076 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-14 00:37:12,076 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 00:37:12,077 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-14 00:37:12,077 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-14 00:37:12,085 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,086 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,095 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-14 00:37:12,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,097 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-14 00:37:12,128 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local822912216_0023
2015-08-14 00:37:12,128 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,138 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,142 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,149 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,149 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-14 00:37:12,150 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,150 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,151 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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,153 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local822912216_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.run(LocalJobRunner.java:354)
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:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	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 00:37:12,153 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local822912216_0023 state at FAILED
2015-08-14 00:37:12,154 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-14 00:37:12,154 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-14 00:37:12,154 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-14 00:37:12,154 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-14 00:37:12,155 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-14 00:37:12,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-14 00:37:12,156 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-14 00:37:12,156 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-08-14 00:37:12,166 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,166 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,176 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-14 00:37:12,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,177 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,178 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-14 00:37:12,209 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1332462543_0024
2015-08-14 00:37:12,209 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,216 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,220 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,220 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,227 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-14 00:37:12,241 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-14 00:37:12,263 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-08-14 00:37:12,272 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,273 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,277 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-14 00:37:12,286 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,286 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-14 00:37:12,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,298 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-14 00:37:12,330 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1823996055_0025
2015-08-14 00:37:12,331 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,335 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,339 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,346 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,346 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-14 00:37:12,363 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-14 00:37:12,385 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-14 00:37:12,395 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,395 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,399 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-08-14 00:37:12,408 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,409 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,419 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-14 00:37:12,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,420 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,421 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-14 00:37:12,451 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1488931610_0026
2015-08-14 00:37:12,452 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,457 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,461 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,461 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,467 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-14 00:37:12,484 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-14 00:37:12,503 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-14 00:37:12,511 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,512 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,521 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-14 00:37:12,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,523 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-14 00:37:12,553 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1088568991_0027
2015-08-14 00:37:12,553 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,558 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,562 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,562 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,569 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-14 00:37:12,586 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-14 00:37:12,605 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-14 00:37:12,614 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,614 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,628 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,628 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,628 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-14 00:37:12,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,629 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,629 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-14 00:37:12,658 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local825042691_0028
2015-08-14 00:37:12,660 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,664 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,669 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,669 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,676 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,676 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-14 00:37:12,692 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-14 00:37:12,711 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-14 00:37:12,719 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,719 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,728 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-14 00:37:12,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,729 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,729 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-14 00:37:12,758 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local1932757130_0029
2015-08-14 00:37:12,758 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,762 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,766 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,766 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-14 00:37:12,790 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-14 00:37:12,809 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-14 00:37:12,817 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,817 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,826 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,826 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,827 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-14 00:37:12,827 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,827 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,832 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,833 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-14 00:37:12,861 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local570826539_0030
2015-08-14 00:37:12,863 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,866 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,870 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,870 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-14 00:37:12,895 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-14 00:37:12,913 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-14 00:37:12,921 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:12,922 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:12,930 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-14 00:37:12,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-14 00:37:12,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-14 00:37:12,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-14 00:37:12,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-14 00:37:12,932 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-14 00:37:12,960 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local431469814_0031
2015-08-14 00:37:12,961 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-14 00:37:12,965 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt
2015-08-14 00:37:12,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 00:37:12,968 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 00:37:12,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/classes/test/data/nums.20.txt"]
2015-08-14 00:37:12,975 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-14 00:37:12,993 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-14 00:37:13,012 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-14 00:37:13,020 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 00:37:13,020 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-14 00:37:13,023 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.2.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'