Class cascading.detail.EveryEveryPipeAssemblyPlatformTest

40

tests

0

failures

5.149s

duration

100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop] 0.218s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop] 0.287s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop] 1.256s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop] 0.162s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop] 0.161s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop] 0.016s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop] 0.030s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop] 0.132s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop] 0.148s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop] 0.021s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop] 0.162s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop] 0.141s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop] 0.159s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop] 0.016s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop] 0.116s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop] 0.114s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop] 0.123s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop] 0.124s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop] 0.116s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop] 0.108s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop] 0.110s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop] 0.103s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop] 0.011s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop] 0.103s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop] 0.012s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop] 0.110s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop] 0.104s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop] 0.107s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop] 0.013s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop] 0.077s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop] 0.083s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop] 0.079s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop] 0.100s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop] 0.107s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop] 0.102s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop] 0.100s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop] 0.096s 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-13 23:27:49,778 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 23:27:49,829 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 23:27:49,830 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.detail.EveryEveryPipeAssemblyPlatformTest
2015-08-13 23:27:49,920 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,938 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,949 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,959 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,966 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,973 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,979 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,980 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,986 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,991 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,997 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,997 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,998 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:49,999 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,000 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,000 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,006 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,007 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,013 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,021 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,029 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,037 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,044 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,045 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,049 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,054 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,055 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,055 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,056 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,057 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,061 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,061 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,065 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,066 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,070 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,074 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,078 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,081 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,085 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,089 INFO  detail.PipeAssemblyTestBase (PipeAssemblyTestBase.java:makeSuites(90)) - installing platform: hadoop
2015-08-13 23:27:50,406 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-13 23:27:50,702 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-13 23:27:50,797 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:50,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-13 23:27:50,812 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: FEE275DDC8914EC18BF28FFD8167C979
2015-08-13 23:27:51,022 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 23:27:51,024 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:51,024 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:51,025 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-13 23:27:51,025 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:51,026 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:51,026 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:51,028 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2015-08-13 23:27:51,076 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 23:27:51,142 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 23:27:51,394 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0001
2015-08-13 23:27:51,395 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:51,475 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:51,497 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:51,498 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:51,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:51,568 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2015-08-13 23:27:51,603 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2015-08-13 23:27:51,659 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1
2015-08-13 23:27:51,686 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:51,687 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-13 23:27:51,715 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:51,716 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:51,716 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-13 23:27:51,716 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:51,717 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:51,717 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:51,718 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2015-08-13 23:27:51,846 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0002
2015-08-13 23:27:51,846 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:51,852 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:51,860 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:51,860 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:51,874 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:51,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2015-08-13 23:27:51,898 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2015-08-13 23:27:51,948 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'
2015-08-13 23:27:51,969 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:51,970 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-13 23:27:51,994 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:51,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:51,995 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-13 23:27:51,996 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:51,996 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:51,996 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:51,997 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2015-08-13 23:27:52,082 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0003
2015-08-13 23:27:52,083 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:52,089 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:52,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:52,098 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:52,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2015-08-13 23:27:52,138 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2015-08-13 23:27:52,167 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'
2015-08-13 23:27:52,178 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,179 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-13 23:27:52,199 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:52,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-13 23:27:52,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:52,200 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:52,201 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:52,201 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2015-08-13 23:27:52,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0004
2015-08-13 23:27:52,260 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:52,266 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:52,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:52,272 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:52,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,284 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2015-08-13 23:27:52,301 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2015-08-13 23:27:52,328 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS
2015-08-13 23:27:52,339 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,340 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-13 23:27:52,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:52,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,359 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-13 23:27:52,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:52,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:52,360 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:52,361 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2015-08-13 23:27:52,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0005
2015-08-13 23:27:52,422 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:52,427 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:52,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:52,433 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:52,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,444 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2015-08-13 23:27:52,463 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2015-08-13 23:27:52,491 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL
2015-08-13 23:27:52,502 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,503 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-13 23:27:52,522 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:52,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.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-13 23:27:52,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:52,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:52,523 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:52,524 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2015-08-13 23:27:52,583 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0006
2015-08-13 23:27:52,583 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:52,588 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:52,594 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:52,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:52,606 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,606 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2015-08-13 23:27:52,624 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2015-08-13 23:27:52,653 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1
2015-08-13 23:27:52,664 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,666 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-13 23:27:52,674 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2015-08-13 23:27:52,685 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,685 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-13 23:27:52,704 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:52,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-13 23:27:52,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:52,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:52,705 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:52,706 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2015-08-13 23:27:52,756 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0007
2015-08-13 23:27:52,756 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:52,761 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:52,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:52,769 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:52,779 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,780 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2015-08-13 23:27:52,797 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2015-08-13 23:27:52,822 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'
2015-08-13 23:27:52,832 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,833 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-13 23:27:52,852 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:52,852 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,853 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-13 23:27:52,853 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:52,854 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:52,854 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:52,855 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2015-08-13 23:27:52,901 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0008
2015-08-13 23:27:52,901 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:52,906 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:52,913 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:52,913 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:52,923 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:52,924 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2015-08-13 23:27:52,943 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2015-08-13 23:27:52,982 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2015-08-13 23:27:52,992 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:52,993 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-13 23:27:53,011 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,012 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,012 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-13 23:27:53,012 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,012 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,013 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,013 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2015-08-13 23:27:53,057 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0009
2015-08-13 23:27:53,058 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,063 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,068 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,068 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,078 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,078 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2015-08-13 23:27:53,100 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2015-08-13 23:27:53,123 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL
2015-08-13 23:27:53,133 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,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-13 23:27:53,151 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-13 23:27:53,152 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,153 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,154 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-13 23:27:53,195 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0010
2015-08-13 23:27:53,196 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,201 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,216 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2015-08-13 23:27:53,218 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,220 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,221 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,223 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0010
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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,227 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local_0010 state at FAILED
2015-08-13 23:27:53,227 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-13 23:27:53,235 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-13 23:27:53,236 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-13 23:27:53,237 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-13 23:27:53,238 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2015-08-13 23:27:53,238 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-13 23:27:53,239 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2015-08-13 23:27:53,239 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1
2015-08-13 23:27:53,249 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,250 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-13 23:27:53,256 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_'field2'
2015-08-13 23:27:53,265 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,266 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-13 23:27:53,283 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,283 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-13 23:27:53,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,284 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,285 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-13 23:27:53,325 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0011
2015-08-13 23:27:53,326 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,332 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,337 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,338 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,348 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,349 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2015-08-13 23:27:53,350 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,357 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,361 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,368 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0011
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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,377 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local_0011 state at FAILED
2015-08-13 23:27:53,377 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-13 23:27:53,377 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-13 23:27:53,377 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-13 23:27:53,378 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-13 23:27:53,378 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2015-08-13 23:27:53,379 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-13 23:27:53,379 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2015-08-13 23:27:53,380 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS
2015-08-13 23:27:53,389 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,390 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-13 23:27:53,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,407 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,408 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-13 23:27:53,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,411 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-13 23:27:53,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0012
2015-08-13 23:27:53,450 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,456 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,462 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,472 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,473 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2015-08-13 23:27:53,474 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,482 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,484 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,486 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0012
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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:53,492 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local_0012 state at FAILED
2015-08-13 23:27:53,492 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-13 23:27:53,492 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-13 23:27:53,492 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-13 23:27:53,493 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-13 23:27:53,493 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2015-08-13 23:27:53,494 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-13 23:27:53,494 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2015-08-13 23:27:53,495 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL
2015-08-13 23:27:53,504 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,505 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-13 23:27:53,511 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_'field2'
2015-08-13 23:27:53,520 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,521 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-13 23:27:53,537 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,538 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-13 23:27:53,539 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,540 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,541 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,542 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2015-08-13 23:27:53,580 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0013
2015-08-13 23:27:53,581 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,586 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,592 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2015-08-13 23:27:53,622 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2015-08-13 23:27:53,643 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS
2015-08-13 23:27:53,653 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,654 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-13 23:27:53,672 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_ALL
2015-08-13 23:27:53,684 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,684 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-13 23:27:53,700 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,700 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,700 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-13 23:27:53,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,701 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,703 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2015-08-13 23:27:53,738 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0014
2015-08-13 23:27:53,740 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,745 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,749 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,757 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,758 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2015-08-13 23:27:53,771 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2015-08-13 23:27:53,791 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1
2015-08-13 23:27:53,800 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,800 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-13 23:27:53,814 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,815 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,815 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-13 23:27:53,816 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,816 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,817 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,818 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2015-08-13 23:27:53,853 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0015
2015-08-13 23:27:53,853 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,859 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2015-08-13 23:27:53,896 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2015-08-13 23:27:53,916 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'
2015-08-13 23:27:53,924 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:53,925 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-13 23:27:53,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:53,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-13 23:27:53,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:53,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:53,941 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:53,942 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2015-08-13 23:27:53,975 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0016
2015-08-13 23:27:53,976 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:53,981 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:53,986 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:53,986 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:53,993 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:53,994 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2015-08-13 23:27:54,007 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2015-08-13 23:27:54,027 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS
2015-08-13 23:27:54,035 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,035 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-13 23:27:54,048 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,049 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-13 23:27:54,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,050 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,051 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2015-08-13 23:27:54,083 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0017
2015-08-13 23:27:54,084 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,088 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,092 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,092 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,100 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,100 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2015-08-13 23:27:54,115 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2015-08-13 23:27:54,134 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL
2015-08-13 23:27:54,142 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,143 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-13 23:27:54,155 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-13 23:27:54,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,156 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,157 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2015-08-13 23:27:54,188 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0018
2015-08-13 23:27:54,189 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,193 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,197 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,197 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,204 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,204 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2015-08-13 23:27:54,220 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2015-08-13 23:27:54,245 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1
2015-08-13 23:27:54,253 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,254 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-13 23:27:54,258 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_'field2'
2015-08-13 23:27:54,266 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,266 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-13 23:27:54,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-13 23:27:54,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,280 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,280 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,281 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2015-08-13 23:27:54,314 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0019
2015-08-13 23:27:54,315 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,319 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,323 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,323 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,330 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,331 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2015-08-13 23:27:54,346 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2015-08-13 23:27:54,365 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2015-08-13 23:27:54,373 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,374 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-13 23:27:54,385 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-13 23:27:54,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,386 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,387 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2015-08-13 23:27:54,420 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0020
2015-08-13 23:27:54,420 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,424 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,428 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,428 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,435 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,435 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2015-08-13 23:27:54,451 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2015-08-13 23:27:54,470 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL
2015-08-13 23:27:54,479 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,479 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-13 23:27:54,490 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-13 23:27:54,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,491 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,492 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-13 23:27:54,524 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0021
2015-08-13 23:27:54,525 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,529 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,539 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,540 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2015-08-13 23:27:54,540 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,541 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,541 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,543 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0021
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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,545 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local_0021 state at FAILED
2015-08-13 23:27:54,545 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-13 23:27:54,545 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-13 23:27:54,546 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-13 23:27:54,546 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-13 23:27:54,546 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2015-08-13 23:27:54,547 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-13 23:27:54,547 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2015-08-13 23:27:54,547 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1
2015-08-13 23:27:54,556 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,557 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-13 23:27:54,560 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_'field2'
2015-08-13 23:27:54,568 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,569 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-13 23:27:54,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,580 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,581 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-13 23:27:54,581 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,582 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,582 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,583 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-13 23:27:54,613 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0022
2015-08-13 23:27:54,614 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,618 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,622 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,622 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,628 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,629 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2015-08-13 23:27:54,629 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,630 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,630 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,632 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0022
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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,634 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local_0022 state at FAILED
2015-08-13 23:27:54,635 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-13 23:27:54,637 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-13 23:27:54,637 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-13 23:27:54,638 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-13 23:27:54,638 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2015-08-13 23:27:54,639 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-13 23:27:54,639 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2015-08-13 23:27:54,639 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS
2015-08-13 23:27:54,648 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,649 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-13 23:27:54,659 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,660 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,660 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-13 23:27:54,661 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,661 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,661 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,662 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-13 23:27:54,698 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0023
2015-08-13 23:27:54,698 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,702 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,705 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,706 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2015-08-13 23:27:54,713 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,714 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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,714 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.FunctionEachStage$1.collect(FunctionEachStage.java:80)
	at cascading.tuple.TupleEntryCollector.safeCollect(TupleEntryCollector.java:145)
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:133)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:99)
	at cascading.flow.stream.FunctionEachStage.receive(FunctionEachStage.java:39)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:102)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,716 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0023
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:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:214)
2015-08-13 23:27:54,720 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] hadoop job job_local_0023 state at FAILED
2015-08-13 23:27:54,721 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] failure info: NA
2015-08-13 23:27:54,721 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events identify failed tasks
2015-08-13 23:27:54,721 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [every.every] task completion events count: 0
2015-08-13 23:27:54,721 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopping all jobs
2015-08-13 23:27:54,722 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2015-08-13 23:27:54,722 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] stopped all jobs
2015-08-13 23:27:54,722 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2015-08-13 23:27:54,723 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL
2015-08-13 23:27:54,731 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,732 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-13 23:27:54,742 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,742 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,743 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-13 23:27:54,743 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,743 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,744 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,745 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2015-08-13 23:27:54,775 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0024
2015-08-13 23:27:54,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,780 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,784 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2015-08-13 23:27:54,807 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2015-08-13 23:27:54,826 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1
2015-08-13 23:27:54,834 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,834 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-13 23:27:54,838 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_'field2'
2015-08-13 23:27:54,846 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,846 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-13 23:27:54,856 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,857 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,857 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-13 23:27:54,857 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,858 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,858 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,859 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2015-08-13 23:27:54,889 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0025
2015-08-13 23:27:54,890 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:54,894 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:54,898 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:54,898 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:54,905 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,905 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2015-08-13 23:27:54,921 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2015-08-13 23:27:54,940 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS
2015-08-13 23:27:54,948 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,949 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-13 23:27:54,952 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_ALL
2015-08-13 23:27:54,960 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:54,961 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-13 23:27:54,970 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:54,970 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:54,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.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-13 23:27:54,972 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:54,972 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:54,972 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:54,973 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2015-08-13 23:27:55,003 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0026
2015-08-13 23:27:55,005 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:55,009 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:55,013 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:55,013 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:55,019 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,020 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2015-08-13 23:27:55,036 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2015-08-13 23:27:55,055 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1
2015-08-13 23:27:55,063 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:55,063 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-13 23:27:55,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:55,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-13 23:27:55,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:55,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:55,075 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:55,075 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2015-08-13 23:27:55,106 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0027
2015-08-13 23:27:55,107 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:55,111 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:55,114 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:55,114 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:55,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,121 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2015-08-13 23:27:55,139 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2015-08-13 23:27:55,161 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'
2015-08-13 23:27:55,170 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:55,170 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-13 23:27:55,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:55,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-13 23:27:55,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:55,180 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:55,181 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:55,181 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2015-08-13 23:27:55,211 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0028
2015-08-13 23:27:55,212 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:55,215 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:55,218 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:55,219 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:55,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,225 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2015-08-13 23:27:55,243 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2015-08-13 23:27:55,261 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'
2015-08-13 23:27:55,269 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:55,270 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-13 23:27:55,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:55,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-13 23:27:55,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:55,280 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:55,280 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:55,280 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2015-08-13 23:27:55,308 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0029
2015-08-13 23:27:55,309 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:55,312 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:55,316 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:55,316 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:55,322 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,322 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2015-08-13 23:27:55,340 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2015-08-13 23:27:55,358 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS
2015-08-13 23:27:55,366 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:55,367 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-13 23:27:55,376 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:55,377 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,377 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-13 23:27:55,377 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:55,377 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:55,377 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:55,379 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2015-08-13 23:27:55,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0030
2015-08-13 23:27:55,407 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:55,411 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:55,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:55,414 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:55,421 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,421 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2015-08-13 23:27:55,438 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2015-08-13 23:27:55,457 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL
2015-08-13 23:27:55,465 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:55,466 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-13 23:27:55,474 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every] starting
2015-08-13 23:27:55,475 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,475 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-13 23:27:55,475 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  parallel execution is enabled: false
2015-08-13 23:27:55,475 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  starting jobs: 1
2015-08-13 23:27:55,476 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [every.every]  allocating threads: 1
2015-08-13 23:27:55,476 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2015-08-13 23:27:55,506 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] submitted hadoop job: job_local_0031
2015-08-13 23:27:55,507 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [every.every] tracking url: http://localhost:8080/
2015-08-13 23:27:55,510 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt
2015-08-13 23:27:55,513 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:27:55,513 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:27:55,520 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/nums.20.txt"]
2015-08-13 23:27:55,520 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2015-08-13 23:27:55,538 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2015-08-13 23:27:55,556 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1
2015-08-13 23:27:55,564 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:27:55,564 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-13 23:27:55,567 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/everyeverypipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_'field2'