Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

0

ignored

3.855s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.330s passed
testHeader 0.204s passed
testHeaderAll 0.257s passed
testHeaderFieldsAll 0.291s passed
testQuotedText 0.264s passed
testQuotedTextAll 0.345s passed
testQuotedTextSpecChar 1.592s passed
testQuotedTextSpecCharAll 0.385s passed
testStrict 0.187s passed

Standard output

2015-05-20 15:54:46,869 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 15:54:46,899 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 15:54:46,899 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2015-05-20 15:54:46,915 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-05-20 15:54:47,361 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-05-20 15:54:47,547 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:47,549 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:47,559 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: D2E3940A99844EC19899E6CDEEA521A1
2015-05-20 15:54:47,732 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 15:54:47,733 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:47,734 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-spec-char.txt"]
2015-05-20 15:54:47,734 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse"]
2015-05-20 15:54:47,734 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:47,734 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:47,735 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:47,736 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2015-05-20 15:54:48,145 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1914338803/.staging/job_local1914338803_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:48,151 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1914338803/.staging/job_local1914338803_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:48,245 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1914338803_0001/job_local1914338803_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:48,250 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1914338803_0001/job_local1914338803_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:48,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1914338803_0001
2015-05-20 15:54:48,256 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:48,299 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-spec-char.txt
2015-05-20 15:54:48,323 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:48,324 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:48,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-spec-char.txt"]
2015-05-20 15:54:48,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse"]
2015-05-20 15:54:48,414 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse/_temporary
2015-05-20 15:54:48,506 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse
2015-05-20 15:54:48,530 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:48,531 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:48,546 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:48,547 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:48,547 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue"]
2015-05-20 15:54:48,547 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:48,547 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:48,547 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:48,548 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2015-05-20 15:54:48,641 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1250001157/.staging/job_local1250001157_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:48,643 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1250001157/.staging/job_local1250001157_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:48,699 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1250001157_0002/job_local1250001157_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:48,700 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1250001157_0002/job_local1250001157_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:48,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1250001157_0002
2015-05-20 15:54:48,701 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:48,706 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt
2015-05-20 15:54:48,716 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:48,716 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:48,722 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:48,722 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue"]
2015-05-20 15:54:48,752 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue/_temporary
2015-05-20 15:54:48,852 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/normchartrue
2015-05-20 15:54:48,880 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:48,881 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:48,901 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:48,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-spec-char.txt"]
2015-05-20 15:54:48,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue"]
2015-05-20 15:54:48,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:48,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:48,902 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:48,903 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2015-05-20 15:54:49,049 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi593159649/.staging/job_local593159649_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,051 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi593159649/.staging/job_local593159649_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,127 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local593159649_0003/job_local593159649_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,129 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local593159649_0003/job_local593159649_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,130 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local593159649_0003
2015-05-20 15:54:49,130 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:49,135 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-spec-char.txt
2015-05-20 15:54:49,145 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:49,145 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:49,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-spec-char.txt"]
2015-05-20 15:54:49,151 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue"]
2015-05-20 15:54:49,168 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue/_temporary
2015-05-20 15:54:49,239 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/specchartrue
2015-05-20 15:54:49,261 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:49,262 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:49,274 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:49,274 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:49,274 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall"]
2015-05-20 15:54:49,275 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:49,275 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:49,275 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:49,275 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2015-05-20 15:54:49,360 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi2140768262/.staging/job_local2140768262_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,361 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi2140768262/.staging/job_local2140768262_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,406 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local2140768262_0004/job_local2140768262_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,407 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local2140768262_0004/job_local2140768262_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,408 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local2140768262_0004
2015-05-20 15:54:49,408 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:49,413 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt
2015-05-20 15:54:49,423 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:49,423 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:49,428 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:49,429 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall"]
2015-05-20 15:54:49,456 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall/_temporary
2015-05-20 15:54:49,496 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/headerall
2015-05-20 15:54:49,513 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:49,514 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:49,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:49,524 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:49,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse"]
2015-05-20 15:54:49,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:49,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:49,525 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:49,525 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2015-05-20 15:54:49,607 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1074457922/.staging/job_local1074457922_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,608 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1074457922/.staging/job_local1074457922_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,647 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1074457922_0005/job_local1074457922_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,648 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1074457922_0005/job_local1074457922_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,648 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1074457922_0005
2015-05-20 15:54:49,648 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:49,652 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt
2015-05-20 15:54:49,661 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:49,661 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:49,665 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:49,666 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse"]
2015-05-20 15:54:49,683 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse/_temporary
2015-05-20 15:54:49,761 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse
2015-05-20 15:54:49,846 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:49,846 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:49,866 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:49,866 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]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache-clean.10.txt"]
2015-05-20 15:54:49,867 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]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion"]
2015-05-20 15:54:49,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:49,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:49,867 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:49,867 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2015-05-20 15:54:49,929 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1786696081/.staging/job_local1786696081_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,930 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1786696081/.staging/job_local1786696081_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,964 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1786696081_0006/job_local1786696081_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:49,965 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1786696081_0006/job_local1786696081_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:49,965 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1786696081_0006
2015-05-20 15:54:49,966 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:49,970 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache-clean.10.txt
2015-05-20 15:54:49,976 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:49,977 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:49,988 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]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache-clean.10.txt"]
2015-05-20 15:54:49,988 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]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion"]
2015-05-20 15:54:50,060 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/_temporary
2015-05-20 15:54:50,092 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/testFieldCoercion
2015-05-20 15:54:50,109 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:50,109 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:50,141 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:50,141 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-header.txt"]
2015-05-20 15:54:50,141 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]]]
2015-05-20 15:54:50,141 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:50,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:50,142 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:50,142 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...4FEEA41529D1FC3F841626928
2015-05-20 15:54:50,203 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1788852199/.staging/job_local1788852199_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:50,204 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi1788852199/.staging/job_local1788852199_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:50,241 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1788852199_0007/job_local1788852199_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:50,242 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local1788852199_0007/job_local1788852199_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:50,243 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1788852199_0007
2015-05-20 15:54:50,243 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:50,247 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-header.txt
2015-05-20 15:54:50,248 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:50,249 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:50,253 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-header.txt"]
2015-05-20 15:54:50,254 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]]]
2015-05-20 15:54:50,254 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"]
2015-05-20 15:54:50,257 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local1788852199_0007_m_000000_0' - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local1788852199_0007_m_000000_0
2015-05-20 15:54:50,258 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 15:54:50,264 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]
2015-05-20 15:54:50,265 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local1788852199_0007_m_000000_0' - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local1788852199_0007_m_000000_0
2015-05-20 15:54:50,266 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-05-20 15:54:50,273 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/part-00000
2015-05-20 15:54:50,274 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local1788852199_0007_m_000000_0' - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local1788852199_0007_m_000000_0
2015-05-20 15:54:50,276 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local1788852199_0007_m_000000_0' to file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1
2015-05-20 15:54:50,276 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/part-00000
2015-05-20 15:54:50,277 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local1788852199_0007_m_000000_0' - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local1788852199_0007_m_000000_0
2015-05-20 15:54:50,278 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local1788852199_0007_m_000000_0' to file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2
2015-05-20 15:54:50,382 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/headerfieldsall2
2015-05-20 15:54:50,383 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/headerfieldsall1
2015-05-20 15:54:50,401 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:50,401 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:50,409 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:50,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:50,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/header"]
2015-05-20 15:54:50,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:50,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:50,410 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:50,411 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2015-05-20 15:54:50,482 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi122992397/.staging/job_local122992397_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:50,483 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi122992397/.staging/job_local122992397_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:50,525 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local122992397_0008/job_local122992397_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:50,526 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local122992397_0008/job_local122992397_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:50,527 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local122992397_0008
2015-05-20 15:54:50,527 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:50,531 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt
2015-05-20 15:54:50,538 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:50,538 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:50,543 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited.txt"]
2015-05-20 15:54:50,543 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/header"]
2015-05-20 15:54:50,563 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/header/_temporary
2015-05-20 15:54:50,589 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/header
2015-05-20 15:54:50,607 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:54:50,607 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 15:54:50,619 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-05-20 15:54:50,619 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-extra-field.txt"]
2015-05-20 15:54:50,619 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic"]
2015-05-20 15:54:50,620 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-05-20 15:54:50,620 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-05-20 15:54:50,620 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-05-20 15:54:50,620 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2015-05-20 15:54:50,695 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi952888910/.staging/job_local952888910_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:50,696 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/staging/soberoi952888910/.staging/job_local952888910_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:50,749 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local952888910_0009/job_local952888910_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2015-05-20 15:54:50,750 WARN  conf.Configuration (Configuration.java:loadProperty(2510)) - file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/tmp/mapred/local/localRunner/soberoi/job_local952888910_0009/job_local952888910_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2015-05-20 15:54:50,751 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local952888910_0009
2015-05-20 15:54:50,751 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-05-20 15:54:50,755 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-extra-field.txt
2015-05-20 15:54:50,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-05-20 15:54:50,761 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-05-20 15:54:50,765 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/delimited-extra-field.txt"]
2015-05-20 15:54:50,765 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic"]
2015-05-20 15:54:50,767 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
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
2015-05-20 15:54:50,768 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
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
2015-05-20 15:54:50,770 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local952888910_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/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:/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
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
2015-05-20 15:54:50,774 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] hadoop job job_local952888910_0009 state at FAILED
2015-05-20 15:54:50,774 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] failure info: NA
2015-05-20 15:54:50,775 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events identify failed tasks
2015-05-20 15:54:50,775 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events count: 0
2015-05-20 15:54:50,776 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopping all jobs
2015-05-20 15:54:50,776 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2015-05-20 15:54:50,777 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopped all jobs
2015-05-20 15:54:50,777 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic/_temporary
2015-05-20 15:54:50,777 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/textdelimitedplatform/strict-nondeterministic