Class cascading.detail.EachEachPipeAssemblyPlatformTest

all > cascading.detail > EachEachPipeAssemblyPlatformTest
40

tests
0

failures
0

ignored
10.225s

duration
100%

successful

Tests

Test Duration Result
-1_'field'_RESULTS.-1_'field2'_'field'[hadoop2-mr1] 0.500s passed
-1_'field'_RESULTS.-1_'field2'_'field2'[hadoop2-mr1] 0.440s passed
-1_'field'_RESULTS.-1_'field2'_-1[hadoop2-mr1] 2.275s passed
-1_'field'_RESULTS.-1_'field2'_ALL[hadoop2-mr1] 0.297s passed
-1_'field'_RESULTS.-1_'field2'_RESULTS[hadoop2-mr1] 0.379s passed
-1_'field'_RESULTS.-1_ARGS_'field2'[hadoop2-mr1] 0.034s passed
-1_'field'_RESULTS.-1_ARGS_ALL[hadoop2-mr1] 0.032s passed
-1_'field'_RESULTS.-1_ARGS_RESULTS[hadoop2-mr1] 0.255s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field'[hadoop2-mr1] 0.259s passed
-1_'field'_RESULTS.-1_UNKNOWN_'field2'[hadoop2-mr1] 0.042s passed
-1_'field'_RESULTS.-1_UNKNOWN_-1[hadoop2-mr1] 0.301s passed
-1_'field'_RESULTS.-1_UNKNOWN_ALL[hadoop2-mr1] 0.311s passed
-1_'field'_RESULTS.-1_UNKNOWN_RESULTS[hadoop2-mr1] 0.262s passed
-1_'field'_RESULTS.-1_VALUES_'field2'[hadoop2-mr1] 0.040s passed
-1_'field'_RESULTS.-1_VALUES_-1[hadoop2-mr1] 0.264s passed
-1_'field'_RESULTS.-1_VALUES_ALL[hadoop2-mr1] 0.192s passed
-1_'field'_RESULTS.-1_VALUES_RESULTS[hadoop2-mr1] 0.222s passed
-1_'field'_RESULTS.0_'field2'_'field2'[hadoop2-mr1] 0.218s passed
-1_'field'_RESULTS.0_'field2'_-1[hadoop2-mr1] 0.266s passed
-1_'field'_RESULTS.0_'field2'_ALL[hadoop2-mr1] 0.281s passed
-1_'field'_RESULTS.0_'field2'_RESULTS[hadoop2-mr1] 0.312s passed
-1_'field'_RESULTS.0_ARGS_'field2'[hadoop2-mr1] 0.024s passed
-1_'field'_RESULTS.0_ARGS_-1[hadoop2-mr1] 0.211s passed
-1_'field'_RESULTS.0_ARGS_ALL[hadoop2-mr1] 0.020s passed
-1_'field'_RESULTS.0_ARGS_RESULTS[hadoop2-mr1] 0.215s passed
-1_'field'_RESULTS.0_UNKNOWN_'field2'[hadoop2-mr1] 0.025s passed
-1_'field'_RESULTS.0_UNKNOWN_-1[hadoop2-mr1] 0.228s passed
-1_'field'_RESULTS.0_UNKNOWN_ALL[hadoop2-mr1] 0.210s passed
-1_'field'_RESULTS.0_UNKNOWN_RESULTS[hadoop2-mr1] 0.224s passed
-1_'field'_RESULTS.0_VALUES_'field2'[hadoop2-mr1] 0.026s passed
-1_'field'_RESULTS.0_VALUES_-1[hadoop2-mr1] 0.176s passed
-1_'field'_RESULTS.0_VALUES_ALL[hadoop2-mr1] 0.173s passed
-1_'field'_RESULTS.0_VALUES_RESULTS[hadoop2-mr1] 0.183s passed
-1_'field'_RESULTS.ALL_'field2'_'field'[hadoop2-mr1] 0.218s passed
-1_'field'_RESULTS.ALL_'field2'_'field2'[hadoop2-mr1] 0.214s passed
-1_'field'_RESULTS.ALL_'field2'_-1[hadoop2-mr1] 0.250s passed
-1_'field'_RESULTS.ALL_'field2'_ALL[hadoop2-mr1] 0.231s passed
-1_'field'_RESULTS.ALL_'field2'_RESULTS[hadoop2-mr1] 0.203s passed
-1_'field'_RESULTS.ALL_UNKNOWN_'field2'[hadoop2-mr1] 0.020s passed
-1_'field'_RESULTS.ALL_UNKNOWN_-1[hadoop2-mr1] 0.192s passed

Standard output

2016-01-15 00:03:14,224 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-15 00:03:14,255 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.detail.EachEachPipeAssemblyPlatformTest, with platform: hadoop2-mr1
2016-01-15 00:03:14,785 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-15 00:03:15,352 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-15 00:03:15,480 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-15 00:03:15,607 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:15,609 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:15,722 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: D7BA8921DE4E4B9E9F4085430FC949D3
2016-01-15 00:03:15,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.093
2016-01-15 00:03:15,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:15,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:16,018 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-15 00:03:16,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:16,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:16,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-15 00:03:16,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:16,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:16,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:16,024 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_'field2'_-1
2016-01-15 00:03:16,593 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1439399052/.staging/job_local1439399052_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:16,605 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1439399052/.staging/job_local1439399052_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:16,729 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1439399052_0001/job_local1439399052_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:16,738 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1439399052_0001/job_local1439399052_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:16,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1439399052_0001
2016-01-15 00:03:16,749 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:16,830 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:16,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:16,851 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:16,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F406C1EC431D4D0E879CFC9CC3160015, ordinal: 0
2016-01-15 00:03:16,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:16,907 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1"]
2016-01-15 00:03:16,908 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F406C1EC431D4D0E879CFC9CC3160015, mem on start (mb), free: 182, total: 223, max: 672
2016-01-15 00:03:16,921 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F406C1EC431D4D0E879CFC9CC3160015, mem on close (mb), free: 181, total: 223, max: 672
2016-01-15 00:03:16,972 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_-1/_temporary
2016-01-15 00:03:16,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.951
2016-01-15 00:03:17,058 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_-1
2016-01-15 00:03:17,087 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:17,088 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:17,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-15 00:03:17,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:17,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:17,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:17,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:17,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-15 00:03:17,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:17,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:17,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:17,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.-1_'field2'_'field2'
2016-01-15 00:03:17,277 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity779174669/.staging/job_local779174669_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:17,279 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity779174669/.staging/job_local779174669_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:17,353 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local779174669_0002/job_local779174669_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:17,356 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local779174669_0002/job_local779174669_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:17,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local779174669_0002
2016-01-15 00:03:17,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:17,366 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:17,377 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:17,377 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:17,387 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D413D0D9DB50468B95F1C6BD7BFE17A3, ordinal: 0
2016-01-15 00:03:17,388 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:17,390 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'"]
2016-01-15 00:03:17,390 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D413D0D9DB50468B95F1C6BD7BFE17A3, mem on start (mb), free: 250, total: 281, max: 672
2016-01-15 00:03:17,394 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D413D0D9DB50468B95F1C6BD7BFE17A3, mem on close (mb), free: 250, total: 281, max: 672
2016-01-15 00:03:17,416 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field2'/_temporary
2016-01-15 00:03:17,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.246
2016-01-15 00:03:17,499 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field2'
2016-01-15 00:03:17,529 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:17,530 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:17,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2016-01-15 00:03:17,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:17,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:17,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:17,605 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:17,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-15 00:03:17,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:17,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:17,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:17,609 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_'field'
2016-01-15 00:03:17,773 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity856350976/.staging/job_local856350976_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:17,775 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity856350976/.staging/job_local856350976_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:17,853 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local856350976_0003/job_local856350976_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:17,855 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local856350976_0003/job_local856350976_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:17,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local856350976_0003
2016-01-15 00:03:17,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:17,866 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:17,879 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:17,879 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:17,892 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F221296846C144F1B51E108265F082B5, ordinal: 0
2016-01-15 00:03:17,893 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:17,893 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'"]
2016-01-15 00:03:17,894 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F221296846C144F1B51E108265F082B5, mem on start (mb), free: 200, total: 281, max: 672
2016-01-15 00:03:17,897 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F221296846C144F1B51E108265F082B5, mem on close (mb), free: 200, total: 281, max: 672
2016-01-15 00:03:17,925 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_'field'/_temporary
2016-01-15 00:03:17,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.321
2016-01-15 00:03:17,998 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_'field'
2016-01-15 00:03:18,016 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:18,017 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:18,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.047
2016-01-15 00:03:18,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:18,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:18,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:18,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:18,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-15 00:03:18,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:18,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:18,086 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:18,087 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.-1_'field2'_RESULTS
2016-01-15 00:03:18,170 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1674084440/.staging/job_local1674084440_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:18,171 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1674084440/.staging/job_local1674084440_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:18,265 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1674084440_0004/job_local1674084440_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:18,266 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1674084440_0004/job_local1674084440_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:18,267 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1674084440_0004
2016-01-15 00:03:18,267 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:18,279 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:18,290 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:18,290 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:18,299 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FAFCB461D4964817A7882CDAE4CAF175, ordinal: 0
2016-01-15 00:03:18,300 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:18,300 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS"]
2016-01-15 00:03:18,300 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FAFCB461D4964817A7882CDAE4CAF175, mem on start (mb), free: 266, total: 281, max: 672
2016-01-15 00:03:18,303 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FAFCB461D4964817A7882CDAE4CAF175, mem on close (mb), free: 266, total: 281, max: 672
2016-01-15 00:03:18,325 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_RESULTS/_temporary
2016-01-15 00:03:18,326 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.240
2016-01-15 00:03:18,377 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_RESULTS
2016-01-15 00:03:18,391 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:18,391 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:18,427 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-15 00:03:18,428 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:18,429 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:18,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:18,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:18,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-15 00:03:18,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:18,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:18,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:18,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_'field2'_ALL
2016-01-15 00:03:18,518 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1097441329/.staging/job_local1097441329_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:18,519 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1097441329/.staging/job_local1097441329_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:18,557 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1097441329_0005/job_local1097441329_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:18,559 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1097441329_0005/job_local1097441329_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:18,559 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1097441329_0005
2016-01-15 00:03:18,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:18,565 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:18,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:18,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:18,588 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AB2342A0797641AAA139D193E294F5B3, ordinal: 0
2016-01-15 00:03:18,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:18,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL"]
2016-01-15 00:03:18,590 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB2342A0797641AAA139D193E294F5B3, mem on start (mb), free: 216, total: 281, max: 672
2016-01-15 00:03:18,595 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AB2342A0797641AAA139D193E294F5B3, mem on close (mb), free: 216, total: 281, max: 672
2016-01-15 00:03:18,618 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_'field2'_ALL/_temporary
2016-01-15 00:03:18,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.177
2016-01-15 00:03:18,674 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_'field2'_ALL
2016-01-15 00:03:18,696 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:18,696 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:18,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-15 00:03:18,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:18,732 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:18,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:18,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:18,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-15 00:03:18,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:18,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:18,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:18,748 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_UNKNOWN_-1
2016-01-15 00:03:18,812 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity132379264/.staging/job_local132379264_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:18,813 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity132379264/.staging/job_local132379264_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:18,859 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local132379264_0006/job_local132379264_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:18,860 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local132379264_0006/job_local132379264_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:18,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local132379264_0006
2016-01-15 00:03:18,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:18,867 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:18,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:18,875 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:18,884 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C44C4F60BAC7424484DD26874B9B0664, ordinal: 0
2016-01-15 00:03:18,884 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:18,885 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1"]
2016-01-15 00:03:18,885 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C44C4F60BAC7424484DD26874B9B0664, mem on start (mb), free: 166, total: 281, max: 672
2016-01-15 00:03:18,888 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C44C4F60BAC7424484DD26874B9B0664, mem on close (mb), free: 166, total: 281, max: 672
2016-01-15 00:03:18,905 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_-1/_temporary
2016-01-15 00:03:18,906 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.159
2016-01-15 00:03:18,975 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_-1
2016-01-15 00:03:18,994 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:18,994 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:19,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.015
2016-01-15 00:03:19,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:19,018 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field2'
2016-01-15 00:03:19,031 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:19,032 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:19,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-15 00:03:19,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:19,067 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:19,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:19,080 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-15 00:03:19,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:19,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:19,081 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:19,082 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_'field'
2016-01-15 00:03:19,144 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1651101572/.staging/job_local1651101572_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:19,145 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1651101572/.staging/job_local1651101572_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:19,183 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1651101572_0007/job_local1651101572_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:19,184 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1651101572_0007/job_local1651101572_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:19,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1651101572_0007
2016-01-15 00:03:19,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:19,191 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:19,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:19,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:19,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CB65BAF2FED2483FAAF7E7A26BE32AB4, ordinal: 0
2016-01-15 00:03:19,206 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,207 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'"]
2016-01-15 00:03:19,207 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CB65BAF2FED2483FAAF7E7A26BE32AB4, mem on start (mb), free: 329, total: 395, max: 672
2016-01-15 00:03:19,209 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CB65BAF2FED2483FAAF7E7A26BE32AB4, mem on close (mb), free: 329, total: 395, max: 672
2016-01-15 00:03:19,232 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_'field'/_temporary
2016-01-15 00:03:19,233 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.152
2016-01-15 00:03:19,278 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_'field'
2016-01-15 00:03:19,290 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:19,290 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:19,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-15 00:03:19,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:19,323 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:19,334 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:19,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-15 00:03:19,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:19,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:19,335 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:19,336 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.-1_UNKNOWN_RESULTS
2016-01-15 00:03:19,403 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity81789576/.staging/job_local81789576_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:19,404 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity81789576/.staging/job_local81789576_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:19,442 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local81789576_0008/job_local81789576_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:19,443 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local81789576_0008/job_local81789576_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:19,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local81789576_0008
2016-01-15 00:03:19,444 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:19,449 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:19,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:19,457 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:19,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FC9185B12FAA4AFCBB2F9B82BC8F7D8E, ordinal: 0
2016-01-15 00:03:19,465 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,465 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS"]
2016-01-15 00:03:19,465 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC9185B12FAA4AFCBB2F9B82BC8F7D8E, mem on start (mb), free: 268, total: 395, max: 672
2016-01-15 00:03:19,468 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FC9185B12FAA4AFCBB2F9B82BC8F7D8E, mem on close (mb), free: 268, total: 395, max: 672
2016-01-15 00:03:19,489 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_RESULTS/_temporary
2016-01-15 00:03:19,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.154
2016-01-15 00:03:19,540 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_RESULTS
2016-01-15 00:03:19,553 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:19,554 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:19,593 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-01-15 00:03:19,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:19,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:19,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:19,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-15 00:03:19,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:19,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:19,607 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:19,608 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.-1_UNKNOWN_ALL
2016-01-15 00:03:19,687 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity223775638/.staging/job_local223775638_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:19,689 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity223775638/.staging/job_local223775638_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:19,743 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local223775638_0009/job_local223775638_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:19,745 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local223775638_0009/job_local223775638_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:19,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local223775638_0009
2016-01-15 00:03:19,746 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:19,752 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:19,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:19,762 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:19,771 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2F40793DC25492E926DFBAF4FAB29A8, ordinal: 0
2016-01-15 00:03:19,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL"]
2016-01-15 00:03:19,773 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2F40793DC25492E926DFBAF4FAB29A8, mem on start (mb), free: 209, total: 395, max: 672
2016-01-15 00:03:19,777 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2F40793DC25492E926DFBAF4FAB29A8, mem on close (mb), free: 209, total: 395, max: 672
2016-01-15 00:03:19,794 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_UNKNOWN_ALL/_temporary
2016-01-15 00:03:19,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.187
2016-01-15 00:03:19,852 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_UNKNOWN_ALL
2016-01-15 00:03:19,868 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:19,868 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:19,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-15 00:03:19,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:19,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:19,923 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:19,923 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:19,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-15 00:03:19,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:19,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:19,924 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:19,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-15 00:03:19,998 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1190488947/.staging/job_local1190488947_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,000 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1190488947/.staging/job_local1190488947_0010/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,068 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1190488947_0010/job_local1190488947_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,069 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1190488947_0010/job_local1190488947_0010.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1190488947_0010
2016-01-15 00:03:20,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:20,075 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:20,083 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:20,083 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:20,091 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E2D2382FDA004E8383C7E3A3B4C3E3A3, ordinal: 0
2016-01-15 00:03:20,091 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,091 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1"]
2016-01-15 00:03:20,092 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2D2382FDA004E8383C7E3A3B4C3E3A3, mem on start (mb), free: 372, total: 390, max: 672
2016-01-15 00:03:20,093 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,095 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,097 ERROR element.SourceStage (SourceStage.java:map(118)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,100 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E2D2382FDA004E8383C7E3A3B4C3E3A3, mem on close (mb), free: 371, total: 390, max: 672
2016-01-15 00:03:20,103 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1190488947_0010
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,112 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1190488947_0010 state at FAILED
2016-01-15 00:03:20,112 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 00:03:20,113 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 00:03:20,113 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 00:03:20,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 00:03:20,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.-1_VALUES_-1
2016-01-15 00:03:20,115 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 00:03:20,116 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_-1/_temporary
2016-01-15 00:03:20,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.192
2016-01-15 00:03:20,116 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_-1
2016-01-15 00:03:20,137 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,137 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.015
2016-01-15 00:03:20,156 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:20,157 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_'field2'
2016-01-15 00:03:20,174 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,175 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,212 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-15 00:03:20,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:20,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:20,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:20,223 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-15 00:03:20,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:20,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:20,225 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:20,226 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-15 00:03:20,284 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity45489023/.staging/job_local45489023_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,285 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity45489023/.staging/job_local45489023_0011/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,323 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local45489023_0011/job_local45489023_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,323 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local45489023_0011/job_local45489023_0011.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local45489023_0011
2016-01-15 00:03:20,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:20,330 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:20,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:20,342 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:20,353 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D749A3CD34D648A4866BA7B4A0D9A515, ordinal: 0
2016-01-15 00:03:20,354 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,354 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS"]
2016-01-15 00:03:20,355 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D749A3CD34D648A4866BA7B4A0D9A515, mem on start (mb), free: 318, total: 390, max: 672
2016-01-15 00:03:20,356 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,360 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,363 ERROR element.SourceStage (SourceStage.java:map(118)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,367 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D749A3CD34D648A4866BA7B4A0D9A515, mem on close (mb), free: 318, total: 390, max: 672
2016-01-15 00:03:20,369 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local45489023_0011
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,376 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local45489023_0011 state at FAILED
2016-01-15 00:03:20,376 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 00:03:20,376 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 00:03:20,376 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 00:03:20,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 00:03:20,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...RESULTS.-1_VALUES_RESULTS
2016-01-15 00:03:20,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 00:03:20,378 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_RESULTS/_temporary
2016-01-15 00:03:20,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.155
2016-01-15 00:03:20,379 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_RESULTS
2016-01-15 00:03:20,396 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,397 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-15 00:03:20,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:20,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:20,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:20,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-15 00:03:20,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:20,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:20,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:20,439 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-15 00:03:20,496 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1106860996/.staging/job_local1106860996_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,497 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1106860996/.staging/job_local1106860996_0012/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,539 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1106860996_0012/job_local1106860996_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,539 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1106860996_0012/job_local1106860996_0012.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,540 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1106860996_0012
2016-01-15 00:03:20,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:20,546 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:20,553 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:20,553 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:20,559 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CD6848A7BE7449B1A62528D73349A4CA, ordinal: 0
2016-01-15 00:03:20,560 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,560 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL"]
2016-01-15 00:03:20,560 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD6848A7BE7449B1A62528D73349A4CA, mem on start (mb), free: 270, total: 390, max: 672
2016-01-15 00:03:20,561 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,562 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,562 ERROR element.SourceStage (SourceStage.java:map(118)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,563 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CD6848A7BE7449B1A62528D73349A4CA, mem on close (mb), free: 270, total: 390, max: 672
2016-01-15 00:03:20,565 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1106860996_0012
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:20,568 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1106860996_0012 state at FAILED
2016-01-15 00:03:20,568 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 00:03:20,568 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 00:03:20,568 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 00:03:20,568 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 00:03:20,569 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ld'_RESULTS.-1_VALUES_ALL
2016-01-15 00:03:20,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 00:03:20,570 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_VALUES_ALL/_temporary
2016-01-15 00:03:20,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.132
2016-01-15 00:03:20,571 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_VALUES_ALL
2016-01-15 00:03:20,589 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,590 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,605 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.009
2016-01-15 00:03:20,605 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:20,606 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_'field2'
2016-01-15 00:03:20,619 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,620 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 00:03:20,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:20,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:20,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:20,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-15 00:03:20,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:20,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:20,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:20,658 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.-1_ARGS_RESULTS
2016-01-15 00:03:20,730 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1182936968/.staging/job_local1182936968_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,731 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1182936968/.staging/job_local1182936968_0013/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,769 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1182936968_0013/job_local1182936968_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:20,770 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1182936968_0013/job_local1182936968_0013.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:20,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1182936968_0013
2016-01-15 00:03:20,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:20,776 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:20,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:20,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:20,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A070FF99E33F46A8ADA545F40FB8008A, ordinal: 0
2016-01-15 00:03:20,791 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,792 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS"]
2016-01-15 00:03:20,792 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A070FF99E33F46A8ADA545F40FB8008A, mem on start (mb), free: 217, total: 390, max: 672
2016-01-15 00:03:20,795 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A070FF99E33F46A8ADA545F40FB8008A, mem on close (mb), free: 217, total: 390, max: 672
2016-01-15 00:03:20,818 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.-1_ARGS_RESULTS/_temporary
2016-01-15 00:03:20,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.163
2016-01-15 00:03:20,861 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_RESULTS
2016-01-15 00:03:20,874 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,875 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.012
2016-01-15 00:03:20,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:20,894 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.-1_ARGS_ALL
2016-01-15 00:03:20,909 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:20,910 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:20,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-15 00:03:20,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:20,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:20,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:20,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:20,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-15 00:03:20,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:20,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:20,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:20,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_'field2'_-1
2016-01-15 00:03:21,022 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1261636041/.staging/job_local1261636041_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,023 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1261636041/.staging/job_local1261636041_0014/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,060 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1261636041_0014/job_local1261636041_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,061 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1261636041_0014/job_local1261636041_0014.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,062 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1261636041_0014
2016-01-15 00:03:21,062 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:21,067 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:21,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:21,073 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:21,080 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FCB4FF1EFD024B21AEFF7969470A6C7E, ordinal: 0
2016-01-15 00:03:21,080 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1"]
2016-01-15 00:03:21,081 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCB4FF1EFD024B21AEFF7969470A6C7E, mem on start (mb), free: 153, total: 390, max: 672
2016-01-15 00:03:21,084 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FCB4FF1EFD024B21AEFF7969470A6C7E, mem on close (mb), free: 153, total: 390, max: 672
2016-01-15 00:03:21,114 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_-1/_temporary
2016-01-15 00:03:21,115 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.156
2016-01-15 00:03:21,160 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_-1
2016-01-15 00:03:21,171 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:21,171 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:21,200 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2016-01-15 00:03:21,201 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:21,201 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:21,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:21,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-15 00:03:21,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:21,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:21,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:21,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...SULTS.0_'field2'_'field2'
2016-01-15 00:03:21,266 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity203855380/.staging/job_local203855380_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,267 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity203855380/.staging/job_local203855380_0015/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,297 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local203855380_0015/job_local203855380_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,298 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local203855380_0015/job_local203855380_0015.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local203855380_0015
2016-01-15 00:03:21,300 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:21,304 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:21,310 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:21,311 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:21,317 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EDEF0797B42544379D5263C6E0DDA217, ordinal: 0
2016-01-15 00:03:21,318 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,318 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'"]
2016-01-15 00:03:21,318 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EDEF0797B42544379D5263C6E0DDA217, mem on start (mb), free: 328, total: 395, max: 672
2016-01-15 00:03:21,321 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EDEF0797B42544379D5263C6E0DDA217, mem on close (mb), free: 328, total: 395, max: 672
2016-01-15 00:03:21,333 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_'field2'/_temporary
2016-01-15 00:03:21,333 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.123
2016-01-15 00:03:21,378 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_'field2'
2016-01-15 00:03:21,389 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:21,390 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:21,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-15 00:03:21,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:21,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:21,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:21,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-15 00:03:21,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:21,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:21,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:21,438 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ESULTS.0_'field2'_RESULTS
2016-01-15 00:03:21,516 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1876951642/.staging/job_local1876951642_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,517 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1876951642/.staging/job_local1876951642_0016/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,569 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1876951642_0016/job_local1876951642_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,570 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1876951642_0016/job_local1876951642_0016.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1876951642_0016
2016-01-15 00:03:21,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:21,580 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:21,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:21,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:21,599 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F22C49C0AA4A47948ADA671FBB7F512F, ordinal: 0
2016-01-15 00:03:21,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,600 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS"]
2016-01-15 00:03:21,600 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F22C49C0AA4A47948ADA671FBB7F512F, mem on start (mb), free: 272, total: 395, max: 672
2016-01-15 00:03:21,603 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F22C49C0AA4A47948ADA671FBB7F512F, mem on close (mb), free: 271, total: 395, max: 672
2016-01-15 00:03:21,626 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_RESULTS/_temporary
2016-01-15 00:03:21,627 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.190
2016-01-15 00:03:21,690 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_RESULTS
2016-01-15 00:03:21,708 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:21,708 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:21,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-01-15 00:03:21,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:21,747 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:21,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:21,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,760 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-15 00:03:21,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:21,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:21,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:21,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_'field2'_ALL
2016-01-15 00:03:21,846 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1527078754/.staging/job_local1527078754_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,847 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1527078754/.staging/job_local1527078754_0017/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,885 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1527078754_0017/job_local1527078754_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:21,886 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1527078754_0017/job_local1527078754_0017.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:21,886 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1527078754_0017
2016-01-15 00:03:21,886 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:21,891 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:21,899 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:21,899 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:21,906 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DE2C134FB31F4A1DA9384FCAAD6B4EAC, ordinal: 0
2016-01-15 00:03:21,907 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:21,907 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL"]
2016-01-15 00:03:21,907 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE2C134FB31F4A1DA9384FCAAD6B4EAC, mem on start (mb), free: 214, total: 395, max: 672
2016-01-15 00:03:21,910 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DE2C134FB31F4A1DA9384FCAAD6B4EAC, mem on close (mb), free: 214, total: 395, max: 672
2016-01-15 00:03:21,930 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_'field2'_ALL/_temporary
2016-01-15 00:03:21,930 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.170
2016-01-15 00:03:21,971 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_'field2'_ALL
2016-01-15 00:03:21,986 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:21,986 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-15 00:03:22,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:22,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:22,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:22,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-15 00:03:22,017 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:22,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:22,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:22,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_UNKNOWN_-1
2016-01-15 00:03:22,074 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1059564802/.staging/job_local1059564802_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,074 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1059564802/.staging/job_local1059564802_0018/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,106 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1059564802_0018/job_local1059564802_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,107 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1059564802_0018/job_local1059564802_0018.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1059564802_0018
2016-01-15 00:03:22,108 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:22,112 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:22,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:22,119 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:22,126 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E92EC883B10D4482BDCDFAF0B8A92BBA, ordinal: 0
2016-01-15 00:03:22,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1"]
2016-01-15 00:03:22,127 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E92EC883B10D4482BDCDFAF0B8A92BBA, mem on start (mb), free: 158, total: 395, max: 672
2016-01-15 00:03:22,130 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E92EC883B10D4482BDCDFAF0B8A92BBA, mem on close (mb), free: 158, total: 395, max: 672
2016-01-15 00:03:22,157 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_-1/_temporary
2016-01-15 00:03:22,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.140
2016-01-15 00:03:22,200 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_-1
2016-01-15 00:03:22,212 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:22,213 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.007
2016-01-15 00:03:22,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:22,225 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_'field2'
2016-01-15 00:03:22,238 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:22,238 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,261 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2016-01-15 00:03:22,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:22,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:22,271 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:22,271 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,271 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-15 00:03:22,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:22,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:22,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:22,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...RESULTS.0_UNKNOWN_RESULTS
2016-01-15 00:03:22,329 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1604999738/.staging/job_local1604999738_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,330 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1604999738/.staging/job_local1604999738_0019/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,362 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1604999738_0019/job_local1604999738_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,363 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1604999738_0019/job_local1604999738_0019.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,363 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1604999738_0019
2016-01-15 00:03:22,365 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:22,369 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:22,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:22,375 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:22,381 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CDA0200CFDC94E6E82EBA787D2DE98E3, ordinal: 0
2016-01-15 00:03:22,382 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,382 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS"]
2016-01-15 00:03:22,382 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDA0200CFDC94E6E82EBA787D2DE98E3, mem on start (mb), free: 323, total: 395, max: 672
2016-01-15 00:03:22,386 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CDA0200CFDC94E6E82EBA787D2DE98E3, mem on close (mb), free: 323, total: 395, max: 672
2016-01-15 00:03:22,408 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_RESULTS/_temporary
2016-01-15 00:03:22,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.137
2016-01-15 00:03:22,449 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_RESULTS
2016-01-15 00:03:22,459 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:22,459 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-01-15 00:03:22,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:22,484 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:22,495 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:22,495 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-15 00:03:22,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:22,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:22,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:22,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ld'_RESULTS.0_UNKNOWN_ALL
2016-01-15 00:03:22,552 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1099801941/.staging/job_local1099801941_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,553 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1099801941/.staging/job_local1099801941_0020/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,584 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1099801941_0020/job_local1099801941_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,584 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1099801941_0020/job_local1099801941_0020.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1099801941_0020
2016-01-15 00:03:22,585 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:22,589 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:22,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:22,595 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:22,601 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E4D6C4BB44F74EEB8552A5766557DD03, ordinal: 0
2016-01-15 00:03:22,602 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,602 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL"]
2016-01-15 00:03:22,602 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4D6C4BB44F74EEB8552A5766557DD03, mem on start (mb), free: 265, total: 395, max: 672
2016-01-15 00:03:22,605 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E4D6C4BB44F74EEB8552A5766557DD03, mem on close (mb), free: 265, total: 395, max: 672
2016-01-15 00:03:22,618 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_UNKNOWN_ALL/_temporary
2016-01-15 00:03:22,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.123
2016-01-15 00:03:22,658 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_UNKNOWN_ALL
2016-01-15 00:03:22,669 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:22,669 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2016-01-15 00:03:22,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:22,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:22,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:22,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-15 00:03:22,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:22,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:22,699 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:22,700 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-15 00:03:22,760 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity42208459/.staging/job_local42208459_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,761 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity42208459/.staging/job_local42208459_0021/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,794 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local42208459_0021/job_local42208459_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,795 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local42208459_0021/job_local42208459_0021.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:22,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local42208459_0021
2016-01-15 00:03:22,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:22,799 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:22,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:22,805 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:22,814 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C9798E25C52A41849CE812154055CCBB, ordinal: 0
2016-01-15 00:03:22,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1"]
2016-01-15 00:03:22,815 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9798E25C52A41849CE812154055CCBB, mem on start (mb), free: 209, total: 395, max: 672
2016-01-15 00:03:22,816 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:22,820 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:22,824 ERROR element.SourceStage (SourceStage.java:map(118)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:22,828 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C9798E25C52A41849CE812154055CCBB, mem on close (mb), free: 208, total: 395, max: 672
2016-01-15 00:03:22,829 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local42208459_0021
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:22,832 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local42208459_0021 state at FAILED
2016-01-15 00:03:22,833 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 00:03:22,833 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 00:03:22,833 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 00:03:22,833 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 00:03:22,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...ield'_RESULTS.0_VALUES_-1
2016-01-15 00:03:22,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 00:03:22,834 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_-1/_temporary
2016-01-15 00:03:22,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.136
2016-01-15 00:03:22,835 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_-1
2016-01-15 00:03:22,848 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:22,849 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,859 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.008
2016-01-15 00:03:22,860 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:22,860 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_'field2'
2016-01-15 00:03:22,872 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:22,872 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:22,899 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-01-15 00:03:22,901 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:22,901 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:22,909 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:22,909 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:22,909 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-15 00:03:22,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:22,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:22,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:22,910 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-15 00:03:22,968 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1864289696/.staging/job_local1864289696_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:22,969 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1864289696/.staging/job_local1864289696_0022/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,004 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1864289696_0022/job_local1864289696_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,004 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1864289696_0022/job_local1864289696_0022.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1864289696_0022
2016-01-15 00:03:23,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:23,010 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:23,017 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:23,017 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:23,022 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BAD58317628C44C3ABA1B31760176B91, ordinal: 0
2016-01-15 00:03:23,022 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,022 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS"]
2016-01-15 00:03:23,023 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAD58317628C44C3ABA1B31760176B91, mem on start (mb), free: 159, total: 395, max: 672
2016-01-15 00:03:23,023 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,026 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,028 ERROR element.SourceStage (SourceStage.java:map(118)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,031 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BAD58317628C44C3ABA1B31760176B91, mem on close (mb), free: 158, total: 395, max: 672
2016-01-15 00:03:23,032 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1864289696_0022
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,039 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1864289696_0022 state at FAILED
2016-01-15 00:03:23,039 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 00:03:23,040 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 00:03:23,040 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 00:03:23,041 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 00:03:23,042 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ..._RESULTS.0_VALUES_RESULTS
2016-01-15 00:03:23,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 00:03:23,043 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_RESULTS/_temporary
2016-01-15 00:03:23,044 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.134
2016-01-15 00:03:23,044 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_RESULTS
2016-01-15 00:03:23,065 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,065 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-15 00:03:23,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:23,085 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:23,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:23,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-15 00:03:23,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:23,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:23,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:23,096 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-15 00:03:23,150 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1540555878/.staging/job_local1540555878_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,151 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1540555878/.staging/job_local1540555878_0023/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,181 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1540555878_0023/job_local1540555878_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,181 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1540555878_0023/job_local1540555878_0023.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,182 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1540555878_0023
2016-01-15 00:03:23,182 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:23,186 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:23,193 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:23,193 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:23,198 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C195DAFA29B2406B865200E4603D36E5, ordinal: 0
2016-01-15 00:03:23,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,199 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL"]
2016-01-15 00:03:23,199 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C195DAFA29B2406B865200E4603D36E5, mem on start (mb), free: 324, total: 379, max: 672
2016-01-15 00:03:23,201 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,202 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,203 ERROR element.SourceStage (SourceStage.java:map(118)) - 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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,203 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C195DAFA29B2406B865200E4603D36E5, mem on close (mb), free: 324, total: 379, max: 672
2016-01-15 00:03:23,205 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1540555878_0023
java.lang.Exception: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: operation added the wrong number of fields, expected: [NONE], got result size: 1
	at cascading.tuple.TupleEntryCollector.add(TupleEntryCollector.java:125)
	at cascading.TestFunction.operate(TestFunction.java:86)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.FunctionEachStage$1.collect(FunctionEachStage.java:81)
	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.element.FunctionEachStage.receive(FunctionEachStage.java:100)
	at cascading.flow.stream.element.FunctionEachStage.receive(FunctionEachStage.java:40)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:110)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
2016-01-15 00:03:23,213 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] hadoop job job_local1540555878_0023 state at FAILED
2016-01-15 00:03:23,213 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] failure info: NA
2016-01-15 00:03:23,214 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events identify failed tasks
2016-01-15 00:03:23,214 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [each.each] task completion events count: 0
2016-01-15 00:03:23,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping all jobs
2016-01-15 00:03:23,214 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopping: (1/1) ...eld'_RESULTS.0_VALUES_ALL
2016-01-15 00:03:23,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] stopped all jobs
2016-01-15 00:03:23,216 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_VALUES_ALL/_temporary
2016-01-15 00:03:23,217 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.123
2016-01-15 00:03:23,217 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_VALUES_ALL
2016-01-15 00:03:23,228 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,228 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,249 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2016-01-15 00:03:23,250 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:23,250 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:23,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:23,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-15 00:03:23,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:23,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:23,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:23,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'field'_RESULTS.0_ARGS_-1
2016-01-15 00:03:23,310 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1742076503/.staging/job_local1742076503_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,310 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1742076503/.staging/job_local1742076503_0024/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,339 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1742076503_0024/job_local1742076503_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,340 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1742076503_0024/job_local1742076503_0024.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,341 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1742076503_0024
2016-01-15 00:03:23,341 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:23,345 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:23,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:23,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:23,356 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D562EAA5E86B43D9B0AAC41F295FEAC9, ordinal: 0
2016-01-15 00:03:23,357 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,357 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1"]
2016-01-15 00:03:23,357 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D562EAA5E86B43D9B0AAC41F295FEAC9, mem on start (mb), free: 277, total: 379, max: 672
2016-01-15 00:03:23,360 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D562EAA5E86B43D9B0AAC41F295FEAC9, mem on close (mb), free: 277, total: 379, max: 672
2016-01-15 00:03:23,375 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_-1/_temporary
2016-01-15 00:03:23,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.118
2016-01-15 00:03:23,427 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_-1
2016-01-15 00:03:23,440 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,440 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-15 00:03:23,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:23,452 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_'field2'
2016-01-15 00:03:23,464 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,464 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-15 00:03:23,482 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:23,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:23,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:23,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-15 00:03:23,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:23,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:23,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:23,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.0_ARGS_RESULTS
2016-01-15 00:03:23,543 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1718997955/.staging/job_local1718997955_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,544 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1718997955/.staging/job_local1718997955_0025/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,575 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1718997955_0025/job_local1718997955_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,576 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1718997955_0025/job_local1718997955_0025.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1718997955_0025
2016-01-15 00:03:23,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:23,583 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:23,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:23,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:23,598 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F6597CF43F4A481CA4048D451137AB3A, ordinal: 0
2016-01-15 00:03:23,598 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,599 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS"]
2016-01-15 00:03:23,599 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6597CF43F4A481CA4048D451137AB3A, mem on start (mb), free: 211, total: 379, max: 672
2016-01-15 00:03:23,604 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F6597CF43F4A481CA4048D451137AB3A, mem on close (mb), free: 211, total: 379, max: 672
2016-01-15 00:03:23,625 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.0_ARGS_RESULTS/_temporary
2016-01-15 00:03:23,626 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.136
2016-01-15 00:03:23,668 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_RESULTS
2016-01-15 00:03:23,678 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,679 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-15 00:03:23,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:23,688 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.0_ARGS_ALL
2016-01-15 00:03:23,698 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,698 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,718 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 00:03:23,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:23,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:23,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:23,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-15 00:03:23,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:23,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:23,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:23,729 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...'_RESULTS.ALL_'field2'_-1
2016-01-15 00:03:23,803 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity236077276/.staging/job_local236077276_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,805 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity236077276/.staging/job_local236077276_0026/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,841 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local236077276_0026/job_local236077276_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:23,842 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local236077276_0026/job_local236077276_0026.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:23,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local236077276_0026
2016-01-15 00:03:23,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:23,848 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:23,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:23,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:23,867 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FF4187F0EF3B4135905EB4B83A3EDCD1, ordinal: 0
2016-01-15 00:03:23,867 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,868 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1"]
2016-01-15 00:03:23,868 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF4187F0EF3B4135905EB4B83A3EDCD1, mem on start (mb), free: 356, total: 371, max: 672
2016-01-15 00:03:23,870 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FF4187F0EF3B4135905EB4B83A3EDCD1, mem on close (mb), free: 356, total: 371, max: 672
2016-01-15 00:03:23,893 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_-1/_temporary
2016-01-15 00:03:23,894 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.165
2016-01-15 00:03:23,938 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_-1
2016-01-15 00:03:23,953 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:23,954 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:23,974 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 00:03:23,974 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:23,975 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:23,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:23,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:23,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-15 00:03:23,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:23,983 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:23,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:23,984 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...LTS.ALL_'field2'_'field2'
2016-01-15 00:03:24,037 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1413818125/.staging/job_local1413818125_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,038 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1413818125/.staging/job_local1413818125_0027/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,072 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1413818125_0027/job_local1413818125_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,074 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1413818125_0027/job_local1413818125_0027.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1413818125_0027
2016-01-15 00:03:24,075 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:24,080 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:24,086 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:24,086 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:24,090 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D9C75B830EF8432EB1B59CDE204E78D5, ordinal: 0
2016-01-15 00:03:24,091 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,091 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'"]
2016-01-15 00:03:24,091 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9C75B830EF8432EB1B59CDE204E78D5, mem on start (mb), free: 301, total: 371, max: 672
2016-01-15 00:03:24,093 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D9C75B830EF8432EB1B59CDE204E78D5, mem on close (mb), free: 300, total: 371, max: 672
2016-01-15 00:03:24,110 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field2'/_temporary
2016-01-15 00:03:24,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.128
2016-01-15 00:03:24,153 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field2'
2016-01-15 00:03:24,163 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:24,163 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:24,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-01-15 00:03:24,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:24,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:24,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:24,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-15 00:03:24,199 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:24,199 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:24,199 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:24,200 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_'field'
2016-01-15 00:03:24,266 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity34654187/.staging/job_local34654187_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,267 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity34654187/.staging/job_local34654187_0028/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,296 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local34654187_0028/job_local34654187_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,297 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local34654187_0028/job_local34654187_0028.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,297 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local34654187_0028
2016-01-15 00:03:24,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:24,301 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:24,307 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:24,307 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:24,312 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3CE3F517DC04E63A3AAB554D03E4889, ordinal: 0
2016-01-15 00:03:24,313 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,313 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'"]
2016-01-15 00:03:24,313 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3CE3F517DC04E63A3AAB554D03E4889, mem on start (mb), free: 246, total: 371, max: 672
2016-01-15 00:03:24,316 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3CE3F517DC04E63A3AAB554D03E4889, mem on close (mb), free: 245, total: 371, max: 672
2016-01-15 00:03:24,331 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_'field'/_temporary
2016-01-15 00:03:24,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.133
2016-01-15 00:03:24,371 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_'field'
2016-01-15 00:03:24,382 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:24,383 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:24,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2016-01-15 00:03:24,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:24,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:24,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:24,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-15 00:03:24,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:24,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:24,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:24,412 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...ULTS.ALL_'field2'_RESULTS
2016-01-15 00:03:24,466 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity2110058050/.staging/job_local2110058050_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,467 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity2110058050/.staging/job_local2110058050_0029/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,496 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2110058050_0029/job_local2110058050_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,497 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2110058050_0029/job_local2110058050_0029.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local2110058050_0029
2016-01-15 00:03:24,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:24,503 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:24,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:24,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:24,513 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DC38E582C1334F6495BB45CF684E03DC, ordinal: 0
2016-01-15 00:03:24,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,514 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS"]
2016-01-15 00:03:24,514 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC38E582C1334F6495BB45CF684E03DC, mem on start (mb), free: 191, total: 371, max: 672
2016-01-15 00:03:24,517 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DC38E582C1334F6495BB45CF684E03DC, mem on close (mb), free: 190, total: 371, max: 672
2016-01-15 00:03:24,535 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_RESULTS/_temporary
2016-01-15 00:03:24,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.125
2016-01-15 00:03:24,574 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_RESULTS
2016-01-15 00:03:24,585 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:24,586 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:24,602 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2016-01-15 00:03:24,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:24,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:24,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:24,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-15 00:03:24,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:24,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:24,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:24,614 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ..._RESULTS.ALL_'field2'_ALL
2016-01-15 00:03:24,674 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity125885842/.staging/job_local125885842_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,676 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity125885842/.staging/job_local125885842_0030/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,720 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local125885842_0030/job_local125885842_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,721 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local125885842_0030/job_local125885842_0030.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local125885842_0030
2016-01-15 00:03:24,722 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:24,726 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:24,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:24,733 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:24,738 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF635354A82C4F6C8DD51D7CB11A56F4, ordinal: 0
2016-01-15 00:03:24,739 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL"]
2016-01-15 00:03:24,740 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF635354A82C4F6C8DD51D7CB11A56F4, mem on start (mb), free: 338, total: 363, max: 672
2016-01-15 00:03:24,743 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF635354A82C4F6C8DD51D7CB11A56F4, mem on close (mb), free: 338, total: 363, max: 672
2016-01-15 00:03:24,765 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_'field2'_ALL/_temporary
2016-01-15 00:03:24,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.153
2016-01-15 00:03:24,806 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_'field2'_ALL
2016-01-15 00:03:24,816 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:24,816 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:24,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2016-01-15 00:03:24,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-15 00:03:24,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-15 00:03:24,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting
2016-01-15 00:03:24,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-15 00:03:24,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  parallel execution of steps is enabled: false
2016-01-15 00:03:24,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  executing total steps: 1
2016-01-15 00:03:24,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  allocating management threads: 1
2016-01-15 00:03:24,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] starting step: (1/1) ...d'_RESULTS.ALL_UNKNOWN_-1
2016-01-15 00:03:24,891 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1499404174/.staging/job_local1499404174_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,891 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/tmp/cascading/staging/teamcity1499404174/.staging/job_local1499404174_0031/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,920 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1499404174_0031/job_local1499404174_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-15 00:03:24,921 WARN  conf.Configuration (Configuration.java:loadProperty(2368)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1499404174_0031/job_local1499404174_0031.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-15 00:03:24,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] submitted hadoop job: job_local1499404174_0031
2016-01-15 00:03:24,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] tracking url: http://localhost:8080/
2016-01-15 00:03:24,927 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt
2016-01-15 00:03:24,933 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-15 00:03:24,933 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-15 00:03:24,938 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BA98B84B3AB94431B75F365F4D386575, ordinal: 0
2016-01-15 00:03:24,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/classes/test/data/nums.20.txt"]
2016-01-15 00:03:24,939 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1"]
2016-01-15 00:03:24,939 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA98B84B3AB94431B75F365F4D386575, mem on start (mb), free: 282, total: 363, max: 672
2016-01-15 00:03:24,942 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BA98B84B3AB94431B75F365F4D386575, mem on close (mb), free: 282, total: 363, max: 672
2016-01-15 00:03:24,956 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output/hadoop2-mr1/eacheachpipeassemblyplatform/-1_'field'_RESULTS.ALL_UNKNOWN_-1/_temporary
2016-01-15 00:03:24,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each]  completed in: 00:00.115
2016-01-15 00:03:24,999 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_-1
2016-01-15 00:03:25,009 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-15 00:03:25,009 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-15 00:03:25,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.006
2016-01-15 00:03:25,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [each.each] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2016-01-15 00:03:25,019 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.5.x/build/test/output//hadoop2-mr1/eacheachpipeassemblyplatform//-1_'field'_RESULTS.ALL_UNKNOWN_'field2'