Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

5.671s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.581s passed
testHeader 0.288s passed
testHeaderAll 0.322s passed
testHeaderFieldsAll 0.420s passed
testQuotedText 0.371s passed
testQuotedTextAll 0.464s passed
testQuotedTextSpecChar 2.478s passed
testQuotedTextSpecCharAll 0.513s passed
testStrict 0.234s passed

Standard output

2015-08-14 04:03:46,993 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 04:03:47,055 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 04:03:47,056 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2015-08-14 04:03:47,095 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-08-14 04:03:47,724 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-14 04:03:47,883 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-08-14 04:03:48,028 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:48,030 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:48,042 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 17DC455F5B9046DEA27CCE1E637A1478
2015-08-14 04:03:48,274 INFO  util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 04:03:48,276 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:48,277 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-14 04:03:48,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse"]
2015-08-14 04:03:48,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:48,278 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:48,279 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:48,282 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2015-08-14 04:03:48,962 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity985106134/.staging/job_local985106134_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:48,963 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity985106134/.staging/job_local985106134_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:49,150 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local985106134_0001/job_local985106134_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:49,151 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local985106134_0001/job_local985106134_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:49,166 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local985106134_0001
2015-08-14 04:03:49,166 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:49,287 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-spec-char.txt
2015-08-14 04:03:49,317 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:49,317 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:49,358 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-14 04:03:49,359 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse"]
2015-08-14 04:03:49,441 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse/_temporary
2015-08-14 04:03:49,570 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse
2015-08-14 04:03:49,607 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:49,608 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:49,641 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:49,641 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:49,641 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue"]
2015-08-14 04:03:49,642 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:49,642 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:49,642 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:49,643 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2015-08-14 04:03:49,763 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1375723169/.staging/job_local1375723169_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:49,763 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1375723169/.staging/job_local1375723169_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:49,850 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1375723169_0002/job_local1375723169_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:49,851 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1375723169_0002/job_local1375723169_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:49,853 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1375723169_0002
2015-08-14 04:03:49,853 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:49,861 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt
2015-08-14 04:03:49,876 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:49,877 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:49,887 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:49,888 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue"]
2015-08-14 04:03:49,919 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue/_temporary
2015-08-14 04:03:50,037 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/normchartrue
2015-08-14 04:03:50,079 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:50,080 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:50,105 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:50,106 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-14 04:03:50,106 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue"]
2015-08-14 04:03:50,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:50,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:50,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:50,109 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2015-08-14 04:03:50,249 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity886813048/.staging/job_local886813048_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:50,250 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity886813048/.staging/job_local886813048_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:50,356 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local886813048_0003/job_local886813048_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:50,357 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local886813048_0003/job_local886813048_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:50,359 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local886813048_0003
2015-08-14 04:03:50,359 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:50,370 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-spec-char.txt
2015-08-14 04:03:50,383 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:50,384 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:50,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-14 04:03:50,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue"]
2015-08-14 04:03:50,434 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue/_temporary
2015-08-14 04:03:50,551 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/specchartrue
2015-08-14 04:03:50,577 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:50,578 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:50,601 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:50,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:50,602 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall"]
2015-08-14 04:03:50,603 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:50,603 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:50,603 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:50,604 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2015-08-14 04:03:50,713 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2131925484/.staging/job_local2131925484_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:50,713 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity2131925484/.staging/job_local2131925484_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:50,776 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2131925484_0004/job_local2131925484_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:50,776 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2131925484_0004/job_local2131925484_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:50,778 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local2131925484_0004
2015-08-14 04:03:50,778 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:50,787 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt
2015-08-14 04:03:50,799 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:50,800 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:50,809 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:50,809 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall"]
2015-08-14 04:03:50,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall/_temporary
2015-08-14 04:03:50,873 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/headerall
2015-08-14 04:03:50,901 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:50,901 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:50,925 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:50,925 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:50,925 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse"]
2015-08-14 04:03:50,926 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:50,926 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:50,926 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:50,927 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2015-08-14 04:03:51,031 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1911145829/.staging/job_local1911145829_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:51,031 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1911145829/.staging/job_local1911145829_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:51,087 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1911145829_0005/job_local1911145829_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:51,087 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1911145829_0005/job_local1911145829_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:51,088 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1911145829_0005
2015-08-14 04:03:51,089 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:51,098 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt
2015-08-14 04:03:51,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:51,109 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:51,118 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:51,118 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse"]
2015-08-14 04:03:51,148 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse/_temporary
2015-08-14 04:03:51,246 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse
2015-08-14 04:03:51,411 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:51,411 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:51,451 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:51,452 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-14 04:03:51,452 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion"]
2015-08-14 04:03:51,452 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:51,452 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:51,453 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:51,454 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2015-08-14 04:03:51,548 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity535017491/.staging/job_local535017491_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:51,549 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity535017491/.staging/job_local535017491_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:51,606 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local535017491_0006/job_local535017491_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:51,606 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local535017491_0006/job_local535017491_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:51,608 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local535017491_0006
2015-08-14 04:03:51,608 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:51,618 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache-clean.10.txt
2015-08-14 04:03:51,630 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:51,630 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:51,652 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-14 04:03:51,653 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion"]
2015-08-14 04:03:51,788 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/_temporary
2015-08-14 04:03:51,827 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testFieldCoercion
2015-08-14 04:03:51,860 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:51,861 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:51,916 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:51,916 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-header.txt"]
2015-08-14 04:03:51,917 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]]]
2015-08-14 04:03:51,918 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:51,918 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:51,918 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:51,919 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...F8A154B3BAD0AA0E767AB9F0D
2015-08-14 04:03:52,005 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity652386050/.staging/job_local652386050_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:52,005 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity652386050/.staging/job_local652386050_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:52,063 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local652386050_0007/job_local652386050_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:52,063 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local652386050_0007/job_local652386050_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:52,064 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local652386050_0007
2015-08-14 04:03:52,065 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:52,071 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-header.txt
2015-08-14 04:03:52,074 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:52,074 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:52,085 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-header.txt"]
2015-08-14 04:03:52,085 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]]]
2015-08-14 04:03:52,086 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"]
2015-08-14 04:03:52,091 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local652386050_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local652386050_0007_m_000000_0
2015-08-14 04:03:52,091 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-08-14 04:03:52,099 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]
2015-08-14 04:03:52,102 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local652386050_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local652386050_0007_m_000000_0
2015-08-14 04:03:52,103 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-08-14 04:03:52,116 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/part-00000
2015-08-14 04:03:52,117 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local652386050_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local652386050_0007_m_000000_0
2015-08-14 04:03:52,120 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local652386050_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1
2015-08-14 04:03:52,120 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/part-00000
2015-08-14 04:03:52,121 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local652386050_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local652386050_0007_m_000000_0
2015-08-14 04:03:52,125 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local652386050_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2
2015-08-14 04:03:52,248 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/headerfieldsall2
2015-08-14 04:03:52,249 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/headerfieldsall1
2015-08-14 04:03:52,276 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:52,277 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:52,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:52,297 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:52,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/header"]
2015-08-14 04:03:52,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:52,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:52,298 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:52,299 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2015-08-14 04:03:52,387 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity384223008/.staging/job_local384223008_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:52,387 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity384223008/.staging/job_local384223008_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:52,441 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local384223008_0008/job_local384223008_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:52,441 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local384223008_0008/job_local384223008_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:52,446 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local384223008_0008
2015-08-14 04:03:52,446 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:52,453 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt
2015-08-14 04:03:52,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:52,464 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:52,474 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited.txt"]
2015-08-14 04:03:52,475 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/header"]
2015-08-14 04:03:52,502 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/header/_temporary
2015-08-14 04:03:52,537 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/header
2015-08-14 04:03:52,558 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 04:03:52,559 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 04:03:52,575 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-14 04:03:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt"]
2015-08-14 04:03:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic"]
2015-08-14 04:03:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-08-14 04:03:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-08-14 04:03:52,576 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-08-14 04:03:52,578 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2015-08-14 04:03:52,669 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1108592219/.staging/job_local1108592219_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:52,670 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/staging/teamcity1108592219/.staging/job_local1108592219_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:52,722 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1108592219_0009/job_local1108592219_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-08-14 04:03:52,723 WARN  conf.Configuration (Configuration.java:loadProperty(2345)) - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1108592219_0009/job_local1108592219_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-08-14 04:03:52,725 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1108592219_0009
2015-08-14 04:03:52,725 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-14 04:03:52,733 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt
2015-08-14 04:03:52,744 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-14 04:03:52,744 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-14 04:03:52,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt"]
2015-08-14 04:03:52,752 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic"]
2015-08-14 04:03:52,757 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 12 more
2015-08-14 04:03:52,759 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 12 more
2015-08-14 04:03:52,763 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1108592219_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt
	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: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 12 more
2015-08-14 04:03:52,766 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] hadoop job job_local1108592219_0009 state at FAILED
2015-08-14 04:03:52,766 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] failure info: NA
2015-08-14 04:03:52,768 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events identify failed tasks
2015-08-14 04:03:52,768 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events count: 0
2015-08-14 04:03:52,768 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopping all jobs
2015-08-14 04:03:52,769 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2015-08-14 04:03:52,769 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopped all jobs
2015-08-14 04:03:52,770 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] shutting down job executor
2015-08-14 04:03:52,770 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] shutdown complete
2015-08-14 04:03:52,771 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic/_temporary
2015-08-14 04:03:52,771 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/textdelimitedplatform/strict-nondeterministic