Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

0

ignored

4.212s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.416s passed
testHeader 0.229s passed
testHeaderAll 0.315s passed
testHeaderFieldsAll 0.307s passed
testQuotedText 0.287s passed
testQuotedTextAll 0.334s passed
testQuotedTextSpecChar 1.736s passed
testQuotedTextSpecCharAll 0.398s passed
testStrict 0.190s passed

Standard output

2015-07-17 15:30:47,805 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:30:47,822 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:30:47,822 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2015-07-17 15:30:47,844 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(105)) - not using cluster
2015-07-17 15:30:48,373 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-07-17 15:30:48,475 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 15:30:48,577 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:48,579 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:48,589 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: 0C2893BA386B41F297463EE5E2051DA2
2015-07-17 15:30:48,746 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:30:48,747 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:48,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-17 15:30:48,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse"]
2015-07-17 15:30:48,748 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:48,749 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:48,749 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:48,751 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2015-07-17 15:30:49,309 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local446870552_0001
2015-07-17 15:30:49,309 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:49,369 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt
2015-07-17 15:30:49,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:49,394 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:49,422 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-17 15:30:49,422 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse"]
2015-07-17 15:30:49,485 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse/_temporary
2015-07-17 15:30:49,578 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/speccharfalse
2015-07-17 15:30:49,597 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:49,598 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:49,615 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:49,615 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:49,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue"]
2015-07-17 15:30:49,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:49,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:49,616 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:49,617 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2015-07-17 15:30:49,760 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1322748065_0002
2015-07-17 15:30:49,760 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:49,765 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-17 15:30:49,777 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:49,778 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:49,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:49,782 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue"]
2015-07-17 15:30:49,812 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normchartrue/_temporary
2015-07-17 15:30:49,914 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/normchartrue
2015-07-17 15:30:49,941 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:49,942 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:49,963 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:49,963 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-17 15:30:49,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue"]
2015-07-17 15:30:49,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:49,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:49,964 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:49,964 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2015-07-17 15:30:50,185 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1252396851_0003
2015-07-17 15:30:50,186 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:50,190 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt
2015-07-17 15:30:50,202 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:50,203 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:50,208 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-17 15:30:50,208 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue"]
2015-07-17 15:30:50,239 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/specchartrue/_temporary
2015-07-17 15:30:50,313 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/specchartrue
2015-07-17 15:30:50,345 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:50,345 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall"]
2015-07-17 15:30:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:50,367 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:50,367 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:50,367 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2015-07-17 15:30:50,549 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local170673710_0004
2015-07-17 15:30:50,550 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:50,554 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-17 15:30:50,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:50,567 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:50,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:50,573 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall"]
2015-07-17 15:30:50,598 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerall/_temporary
2015-07-17 15:30:50,629 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/headerall
2015-07-17 15:30:50,647 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:50,648 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:50,664 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:50,664 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:50,665 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse"]
2015-07-17 15:30:50,665 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:50,665 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:50,665 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:50,665 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2015-07-17 15:30:50,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1488045180_0005
2015-07-17 15:30:50,794 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:50,798 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-17 15:30:50,810 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:50,810 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:50,814 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:50,814 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse"]
2015-07-17 15:30:50,831 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse/_temporary
2015-07-17 15:30:50,917 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/quoted/normcharfalse
2015-07-17 15:30:51,024 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:51,025 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:51,056 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:51,056 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/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache-clean.10.txt"]
2015-07-17 15:30:51,056 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/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion"]
2015-07-17 15:30:51,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:51,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:51,057 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:51,057 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2015-07-17 15:30:51,197 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local973949130_0006
2015-07-17 15:30:51,197 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:51,201 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache-clean.10.txt
2015-07-17 15:30:51,211 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:51,211 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:51,222 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/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache-clean.10.txt"]
2015-07-17 15:30:51,222 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/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion"]
2015-07-17 15:30:51,307 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/_temporary
2015-07-17 15:30:51,333 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testFieldCoercion
2015-07-17 15:30:51,350 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:51,351 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:51,381 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:51,382 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-header.txt"]
2015-07-17 15:30:51,382 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]]]
2015-07-17 15:30:51,382 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:51,382 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:51,382 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:51,383 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...8E76147EB89DCBA16499C513E
2015-07-17 15:30:51,499 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1632844595_0007
2015-07-17 15:30:51,499 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:51,503 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-header.txt
2015-07-17 15:30:51,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:51,505 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:51,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-header.txt"]
2015-07-17 15:30:51,509 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]]]
2015-07-17 15:30:51,510 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1"]
2015-07-17 15:30:51,512 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local1632844595_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local1632844595_0007_m_000000_0
2015-07-17 15:30:51,512 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-07-17 15:30:51,520 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2"]
2015-07-17 15:30:51,522 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local1632844595_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local1632844595_0007_m_000000_0
2015-07-17 15:30:51,522 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-07-17 15:30:51,532 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/part-00000
2015-07-17 15:30:51,532 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local1632844595_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local1632844595_0007_m_000000_0
2015-07-17 15:30:51,536 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local1632844595_0007_m_000000_0' to file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall1
2015-07-17 15:30:51,536 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/part-00000
2015-07-17 15:30:51,536 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local1632844595_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local1632844595_0007_m_000000_0
2015-07-17 15:30:51,540 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local1632844595_0007_m_000000_0' to file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/headerfieldsall2
2015-07-17 15:30:51,640 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/headerfieldsall2
2015-07-17 15:30:51,641 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/headerfieldsall1
2015-07-17 15:30:51,654 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:51,654 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:51,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:51,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:51,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/header"]
2015-07-17 15:30:51,666 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:51,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:51,667 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:51,667 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2015-07-17 15:30:51,797 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1001746535_0008
2015-07-17 15:30:51,797 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:51,801 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-17 15:30:51,810 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:51,810 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:51,814 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-17 15:30:51,815 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/header"]
2015-07-17 15:30:51,840 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/header/_temporary
2015-07-17 15:30:51,870 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/header
2015-07-17 15:30:51,886 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:30:51,887 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:30:51,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-07-17 15:30:51,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt"]
2015-07-17 15:30:51,897 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic"]
2015-07-17 15:30:51,898 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  parallel execution is enabled: false
2015-07-17 15:30:51,898 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  starting jobs: 1
2015-07-17 15:30:51,898 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe]  allocating threads: 1
2015-07-17 15:30:51,899 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2015-07-17 15:30:52,032 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local1212837162_0009
2015-07-17 15:30:52,032 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-07-17 15:30:52,035 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt
2015-07-17 15:30:52,044 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.0
2015-07-17 15:30:52,044 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-07-17 15:30:52,048 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt"]
2015-07-17 15:30:52,049 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic"]
2015-07-17 15:30:52,051 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/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-07-17 15:30:52,052 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/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-07-17 15:30:52,054 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local1212837162_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/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/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/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-07-17 15:30:52,057 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] hadoop job job_local1212837162_0009 state at FAILED
2015-07-17 15:30:52,057 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] failure info: NA
2015-07-17 15:30:52,058 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events identify failed tasks
2015-07-17 15:30:52,058 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events count: 0
2015-07-17 15:30:52,058 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopping all jobs
2015-07-17 15:30:52,059 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2015-07-17 15:30:52,059 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopped all jobs
2015-07-17 15:30:52,060 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/strict-nondeterministic/_temporary
2015-07-17 15:30:52,060 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/strict-nondeterministic

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]