Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

0

ignored

5.102s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.482s passed
testHeader 0.236s passed
testHeaderAll 0.266s passed
testHeaderFieldsAll 0.317s passed
testQuotedText 0.306s passed
testQuotedTextAll 0.397s passed
testQuotedTextSpecChar 2.333s passed
testQuotedTextSpecCharAll 0.547s passed
testStrict 0.218s passed

Standard output

2016-05-17 22:26:52,636 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:26:52,667 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.scheme.TextDelimitedPlatformTest, with platform: hadoop2-mr1
2016-05-17 22:26:52,701 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-05-17 22:26:53,338 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 22:26:53,479 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides: 
2016-05-17 22:26:53,599 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:53,601 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:53,712 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 6286C134BEF3464886F787C882D4E889
2016-05-17 22:26:53,845 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2016-05-17 22:26:53,848 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:53,848 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:54,005 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:26:54,007 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:54,007 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:26:54,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-05-17 22:26:54,008 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:54,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:54,009 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:54,010 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...Char/quoted/speccharfalse
2016-05-17 22:26:54,560 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity913644392/.staging/job_local913644392_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:54,571 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity913644392/.staging/job_local913644392_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:54,717 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local913644392_0001/job_local913644392_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:54,717 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local913644392_0001/job_local913644392_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:54,727 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local913644392_0001
2016-05-17 22:26:54,727 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:54,807 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-spec-char.txt
2016-05-17 22:26:54,830 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:54,831 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:54,843 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE5AB7863DC24C50A1151B0C2D110654, ordinal: 0
2016-05-17 22:26:54,863 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:26:54,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-05-17 22:26:54,865 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE5AB7863DC24C50A1151B0C2D110654, mem on start (mb), free: 253, total: 281, max: 672
2016-05-17 22:26:54,882 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE5AB7863DC24C50A1151B0C2D110654, mem on close (mb), free: 252, total: 281, max: 672
2016-05-17 22:26:54,924 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse/_temporary
2016-05-17 22:26:54,924 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.916
2016-05-17 22:26:55,030 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse
2016-05-17 22:26:55,059 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:55,059 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:55,108 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2016-05-17 22:26:55,109 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:55,109 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:55,125 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:55,125 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:55,126 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-05-17 22:26:55,126 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:55,127 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:55,127 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:55,129 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...xtAll/quoted/normchartrue
2016-05-17 22:26:55,207 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1546804835/.staging/job_local1546804835_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:55,213 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1546804835/.staging/job_local1546804835_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:55,279 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1546804835_0002/job_local1546804835_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:55,280 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1546804835_0002/job_local1546804835_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:55,282 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1546804835_0002
2016-05-17 22:26:55,282 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:55,290 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt
2016-05-17 22:26:55,304 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:55,305 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:55,315 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D8D6677A7E3F41109A1DDA96134A3958, ordinal: 0
2016-05-17 22:26:55,315 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:55,316 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-05-17 22:26:55,316 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8D6677A7E3F41109A1DDA96134A3958, mem on start (mb), free: 201, total: 281, max: 672
2016-05-17 22:26:55,319 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D8D6677A7E3F41109A1DDA96134A3958, mem on close (mb), free: 201, total: 281, max: 672
2016-05-17 22:26:55,338 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue/_temporary
2016-05-17 22:26:55,339 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.213
2016-05-17 22:26:55,429 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue
2016-05-17 22:26:55,453 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:55,454 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:55,500 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2016-05-17 22:26:55,501 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:55,502 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:55,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:55,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:26:55,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-05-17 22:26:55,516 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:55,517 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:55,517 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:55,517 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...arAll/quoted/specchartrue
2016-05-17 22:26:55,672 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1475708877/.staging/job_local1475708877_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:55,674 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1475708877/.staging/job_local1475708877_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:55,803 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1475708877_0003/job_local1475708877_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:55,804 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1475708877_0003/job_local1475708877_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:55,806 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1475708877_0003
2016-05-17 22:26:55,806 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:55,814 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-spec-char.txt
2016-05-17 22:26:55,851 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:55,852 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:55,862 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DBC0CBCA337B481AB0F2E66E0A843253, ordinal: 0
2016-05-17 22:26:55,863 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:26:55,863 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-05-17 22:26:55,864 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBC0CBCA337B481AB0F2E66E0A843253, mem on start (mb), free: 268, total: 281, max: 672
2016-05-17 22:26:55,867 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DBC0CBCA337B481AB0F2E66E0A843253, mem on close (mb), free: 268, total: 281, max: 672
2016-05-17 22:26:55,893 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue/_temporary
2016-05-17 22:26:55,894 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.377
2016-05-17 22:26:55,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue
2016-05-17 22:26:55,995 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:55,996 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:56,040 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2016-05-17 22:26:56,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:56,042 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:56,053 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:56,053 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:56,053 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall"]
2016-05-17 22:26:56,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:56,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:56,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:56,054 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...m/testHeaderAll/headerall
2016-05-17 22:26:56,129 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1081468565/.staging/job_local1081468565_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:56,131 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1081468565/.staging/job_local1081468565_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:56,167 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1081468565_0004/job_local1081468565_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:56,167 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1081468565_0004/job_local1081468565_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:56,168 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1081468565_0004
2016-05-17 22:26:56,168 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:56,175 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt
2016-05-17 22:26:56,184 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:56,184 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:56,192 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D3F912F4A1A54D7D9A2B7CEC18046C0E, ordinal: 0
2016-05-17 22:26:56,193 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:56,193 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall"]
2016-05-17 22:26:56,194 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D3F912F4A1A54D7D9A2B7CEC18046C0E, mem on start (mb), free: 220, total: 281, max: 672
2016-05-17 22:26:56,197 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D3F912F4A1A54D7D9A2B7CEC18046C0E, mem on close (mb), free: 220, total: 281, max: 672
2016-05-17 22:26:56,216 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall/_temporary
2016-05-17 22:26:56,217 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.163
2016-05-17 22:26:56,243 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall
2016-05-17 22:26:56,259 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:56,260 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:56,297 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-17 22:26:56,299 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:56,299 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:56,311 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:56,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:56,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-05-17 22:26:56,312 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:56,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:56,313 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:56,314 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...Text/quoted/normcharfalse
2016-05-17 22:26:56,387 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1032799908/.staging/job_local1032799908_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:56,388 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1032799908/.staging/job_local1032799908_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:56,425 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1032799908_0005/job_local1032799908_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:56,426 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1032799908_0005/job_local1032799908_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:56,427 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1032799908_0005
2016-05-17 22:26:56,427 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:56,435 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt
2016-05-17 22:26:56,443 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:56,444 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:56,454 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BFB71FE888A149D9B7E6A30624AC6759, ordinal: 0
2016-05-17 22:26:56,455 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:56,456 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-05-17 22:26:56,456 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFB71FE888A149D9B7E6A30624AC6759, mem on start (mb), free: 178, total: 281, max: 672
2016-05-17 22:26:56,460 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BFB71FE888A149D9B7E6A30624AC6759, mem on close (mb), free: 178, total: 281, max: 672
2016-05-17 22:26:56,486 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse/_temporary
2016-05-17 22:26:56,487 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.174
2016-05-17 22:26:56,550 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse
2016-05-17 22:26:56,692 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:56,693 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:56,730 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-05-17 22:26:56,731 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:56,731 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:56,756 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:56,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-17 22:26:56,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-05-17 22:26:56,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:56,757 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:56,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:56,758 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...oercion/testFieldCoercion
2016-05-17 22:26:56,819 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1912795645/.staging/job_local1912795645_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:56,822 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1912795645/.staging/job_local1912795645_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:56,855 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1912795645_0006/job_local1912795645_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:56,855 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1912795645_0006/job_local1912795645_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:56,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1912795645_0006
2016-05-17 22:26:56,856 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:56,862 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache-clean.10.txt
2016-05-17 22:26:56,874 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:56,874 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:56,887 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A5C729815B8C42369E051B132A07FE23, ordinal: 0
2016-05-17 22:26:56,895 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - 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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-17 22:26:56,895 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - 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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-05-17 22:26:56,895 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5C729815B8C42369E051B132A07FE23, mem on start (mb), free: 344, total: 397, max: 672
2016-05-17 22:26:56,974 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A5C729815B8C42369E051B132A07FE23, mem on close (mb), free: 340, total: 397, max: 672
2016-05-17 22:26:57,000 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion/_temporary
2016-05-17 22:26:57,001 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.244
2016-05-17 22:26:57,032 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion
2016-05-17 22:26:57,048 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:57,048 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:57,093 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-05-17 22:26:57,094 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:57,095 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:57,118 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:57,118 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-header.txt"]
2016-05-17 22:26:57,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-05-17 22:26:57,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:57,119 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:57,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:57,120 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...956E743A3A14857086F1CAB00
2016-05-17 22:26:57,178 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity2019833482/.staging/job_local2019833482_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:57,179 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity2019833482/.staging/job_local2019833482_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:57,213 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2019833482_0007/job_local2019833482_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:57,214 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2019833482_0007/job_local2019833482_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:57,215 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local2019833482_0007
2016-05-17 22:26:57,216 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:57,221 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-header.txt
2016-05-17 22:26:57,223 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:57,223 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:57,231 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FEC2E0FDFD994A0891D6E3BA8AAA8438, ordinal: 0
2016-05-17 22:26:57,232 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-header.txt"]
2016-05-17 22:26:57,232 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-05-17 22:26:57,232 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEC2E0FDFD994A0891D6E3BA8AAA8438, mem on start (mb), free: 289, total: 397, max: 672
2016-05-17 22:26:57,234 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"]
2016-05-17 22:26:57,237 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local2019833482_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local2019833482_0007_m_000000_0
2016-05-17 22:26:57,237 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 22:26:57,243 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]
2016-05-17 22:26:57,245 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local2019833482_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local2019833482_0007_m_000000_0
2016-05-17 22:26:57,246 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 22:26:57,255 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/part-00000
2016-05-17 22:26:57,256 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local2019833482_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local2019833482_0007_m_000000_0
2016-05-17 22:26:57,258 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local2019833482_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-05-17 22:26:57,258 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/part-00000
2016-05-17 22:26:57,259 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local2019833482_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local2019833482_0007_m_000000_0
2016-05-17 22:26:57,262 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local2019833482_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-05-17 22:26:57,262 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEC2E0FDFD994A0891D6E3BA8AAA8438, mem on close (mb), free: 285, total: 397, max: 672
2016-05-17 22:26:57,283 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.164
2016-05-17 22:26:57,349 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-05-17 22:26:57,349 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-05-17 22:26:57,363 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:57,363 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:57,388 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2016-05-17 22:26:57,389 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:57,390 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:57,399 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:57,399 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:57,399 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header"]
2016-05-17 22:26:57,399 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:57,400 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:57,400 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:57,401 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...latform/testHeader/header
2016-05-17 22:26:57,463 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1635616457/.staging/job_local1635616457_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:57,465 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1635616457/.staging/job_local1635616457_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:57,509 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1635616457_0008/job_local1635616457_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:57,509 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1635616457_0008/job_local1635616457_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:57,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1635616457_0008
2016-05-17 22:26:57,511 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:57,517 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt
2016-05-17 22:26:57,525 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:57,525 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:57,532 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AE42A558CD894BA2A5D9CE870D1DD42D, ordinal: 0
2016-05-17 22:26:57,532 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited.txt"]
2016-05-17 22:26:57,533 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header"]
2016-05-17 22:26:57,533 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE42A558CD894BA2A5D9CE870D1DD42D, mem on start (mb), free: 225, total: 397, max: 672
2016-05-17 22:26:57,535 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE42A558CD894BA2A5D9CE870D1DD42D, mem on close (mb), free: 225, total: 397, max: 672
2016-05-17 22:26:57,557 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header/_temporary
2016-05-17 22:26:57,558 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.158
2016-05-17 22:26:57,586 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeader/header
2016-05-17 22:26:57,604 INFO  util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:26:57,605 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.1.0/fdadb6ac788ea19f3412b9569a43a7635318b0c5/cascading-hadoop2-mr1-3.1.0.jar
2016-05-17 22:26:57,634 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-17 22:26:57,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:26:57,635 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:26:57,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:26:57,645 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt"]
2016-05-17 22:26:57,646 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-05-17 22:26:57,646 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  parallel execution of steps is enabled: false
2016-05-17 22:26:57,646 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  executing total steps: 1
2016-05-17 22:26:57,646 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  allocating management threads: 1
2016-05-17 22:26:57,647 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...t/strict-nondeterministic
2016-05-17 22:26:57,715 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1818354082/.staging/job_local1818354082_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:57,717 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/tmp/cascading/staging/teamcity1818354082/.staging/job_local1818354082_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:57,760 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1818354082_0009/job_local1818354082_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-05-17 22:26:57,760 WARN  conf.Configuration (Configuration.java:loadProperty(2172)) - file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1818354082_0009/job_local1818354082_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-05-17 22:26:57,762 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1818354082_0009
2016-05-17 22:26:57,762 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:26:57,768 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt
2016-05-17 22:26:57,776 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:26:57,776 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:26:57,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D77CDF645BEF4358BF71DF92DAB60FFA, ordinal: 0
2016-05-17 22:26:57,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt"]
2016-05-17 22:26:57,783 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-05-17 22:26:57,783 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D77CDF645BEF4358BF71DF92DAB60FFA, mem on start (mb), free: 175, total: 397, max: 672
2016-05-17 22:26:57,787 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:84)
	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:429)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:235)
	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)
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)
	... 11 more
2016-05-17 22:26:57,789 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:84)
	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:429)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:235)
	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)
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)
	... 11 more
2016-05-17 22:26:57,793 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D77CDF645BEF4358BF71DF92DAB60FFA, mem on close (mb), free: 174, total: 397, max: 672
2016-05-17 22:26:57,795 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(482)) - job_local1818354082_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:403)
Caused by: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:84)
	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:429)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:341)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:235)
	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)
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)
	... 11 more
2016-05-17 22:26:57,797 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] hadoop job job_local1818354082_0009 state at FAILED
2016-05-17 22:26:57,798 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] failure info: NA
2016-05-17 22:26:57,799 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] task completion events identify failed tasks
2016-05-17 22:26:57,799 WARN  flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] task completion events count: 0
2016-05-17 22:26:57,800 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopping all jobs
2016-05-17 22:26:57,803 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopping: (1/1) ...t/strict-nondeterministic
2016-05-17 22:26:57,804 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopped all jobs
2016-05-17 22:26:57,804 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic/_temporary
2016-05-17 22:26:57,805 INFO  flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe]  completed in: 00:00.159
2016-05-17 22:26:57,805 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/9c1cc778dcd1fc2f/apache-2.2.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic