Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

3.190s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.520s passed
testHeader 0.145s passed
testHeaderAll 0.168s passed
testHeaderFieldsAll 0.211s passed
testQuotedText 0.175s passed
testQuotedTextAll 0.296s passed
testQuotedTextSpecChar 1.349s passed
testQuotedTextSpecCharAll 0.218s passed
testStrict 0.108s passed

Standard output

2015-02-10 17:18:48,883 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-02-10 17:18:48,932 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-02-10 17:18:48,932 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2015-02-10 17:18:48,964 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-02-10 17:18:49,394 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:49,396 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:49,409 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: EFF0C422A5A74E5DAC359698C6369E6A
2015-02-10 17:18:49,618 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.6.3
2015-02-10 17:18:49,621 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:49,621 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2015-02-10 17:18:49,622 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2015-02-10 17:18:49,622 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:49,622 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:49,623 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:49,624 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2015-02-10 17:18:49,674 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-02-10 17:18:49,746 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-02-10 17:18:49,749 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:49,983 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1870049322_0001
2015-02-10 17:18:49,984 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:50,017 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:50,021 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1870049322_0001_m_000000_0
2015-02-10 17:18:50,083 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2015-02-10 17:18:50,091 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3ecec78d
2015-02-10 17:18:50,100 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2015-02-10 17:18:50,101 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@48baa31b
2015-02-10 17:18:50,115 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:50,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:50,127 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:50,167 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2015-02-10 17:18:50,168 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2015-02-10 17:18:50,189 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1870049322_0001_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:50,194 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:50,195 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1870049322_0001_m_000000_0 is allowed to commit now
2015-02-10 17:18:50,200 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1870049322_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse
2015-02-10 17:18:50,202 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt:0+197
2015-02-10 17:18:50,202 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1870049322_0001_m_000000_0' done.
2015-02-10 17:18:50,202 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1870049322_0001_m_000000_0
2015-02-10 17:18:50,203 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:50,221 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2015-02-10 17:18:50,248 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,276 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,305 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,310 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2015-02-10 17:18:50,341 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:50,342 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:50,365 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2015-02-10 17:18:50,366 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:50,367 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:50,367 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:50,367 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2015-02-10 17:18:50,385 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,480 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local181489276_0002
2015-02-10 17:18:50,480 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:50,483 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:50,483 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local181489276_0002_m_000000_0
2015-02-10 17:18:50,485 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5893bca2
2015-02-10 17:18:50,487 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt
2015-02-10 17:18:50,488 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2e9dca26
2015-02-10 17:18:50,490 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:50,495 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:50,496 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:50,506 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:50,507 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2015-02-10 17:18:50,512 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local181489276_0002_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:50,514 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:50,515 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local181489276_0002_m_000000_0 is allowed to commit now
2015-02-10 17:18:50,519 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local181489276_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue
2015-02-10 17:18:50,521 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2015-02-10 17:18:50,521 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local181489276_0002_m_000000_0' done.
2015-02-10 17:18:50,522 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local181489276_0002_m_000000_0
2015-02-10 17:18:50,522 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:50,533 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2015-02-10 17:18:50,556 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,580 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,604 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,608 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2015-02-10 17:18:50,630 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:50,631 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:50,653 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:50,654 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2015-02-10 17:18:50,654 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2015-02-10 17:18:50,655 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:50,655 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:50,655 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:50,656 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2015-02-10 17:18:50,674 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,720 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local963544510_0003
2015-02-10 17:18:50,721 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:50,724 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:50,724 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local963544510_0003_m_000000_0
2015-02-10 17:18:50,726 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@622b2af3
2015-02-10 17:18:50,728 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2015-02-10 17:18:50,728 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3b5ad1da
2015-02-10 17:18:50,730 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:50,736 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:50,736 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:50,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2015-02-10 17:18:50,747 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2015-02-10 17:18:50,752 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local963544510_0003_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:50,754 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:50,754 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local963544510_0003_m_000000_0 is allowed to commit now
2015-02-10 17:18:50,758 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local963544510_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue
2015-02-10 17:18:50,760 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt:0+197
2015-02-10 17:18:50,760 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local963544510_0003_m_000000_0' done.
2015-02-10 17:18:50,761 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local963544510_0003_m_000000_0
2015-02-10 17:18:50,761 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:50,773 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2015-02-10 17:18:50,787 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,807 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,824 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,827 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2015-02-10 17:18:50,843 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:50,844 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:50,865 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:50,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:50,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2015-02-10 17:18:50,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:50,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:50,866 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:50,867 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2015-02-10 17:18:50,884 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,926 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1623826558_0004
2015-02-10 17:18:50,926 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:50,929 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:50,929 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1623826558_0004_m_000000_0
2015-02-10 17:18:50,932 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@5b5b55bc
2015-02-10 17:18:50,934 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt
2015-02-10 17:18:50,934 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4cc5f20f
2015-02-10 17:18:50,937 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:50,943 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:50,943 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:50,954 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:50,955 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2015-02-10 17:18:50,959 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1623826558_0004_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:50,961 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:50,961 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1623826558_0004_m_000000_0 is allowed to commit now
2015-02-10 17:18:50,966 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1623826558_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall
2015-02-10 17:18:50,968 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2015-02-10 17:18:50,968 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1623826558_0004_m_000000_0' done.
2015-02-10 17:18:50,968 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1623826558_0004_m_000000_0
2015-02-10 17:18:50,968 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:50,979 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2015-02-10 17:18:50,993 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:50,996 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerall
2015-02-10 17:18:51,011 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:51,012 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:51,030 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:51,030 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:51,031 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2015-02-10 17:18:51,031 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:51,031 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:51,031 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:51,032 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2015-02-10 17:18:51,047 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,086 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1712017304_0005
2015-02-10 17:18:51,086 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:51,089 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:51,089 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1712017304_0005_m_000000_0
2015-02-10 17:18:51,091 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@546e3e5e
2015-02-10 17:18:51,092 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt
2015-02-10 17:18:51,093 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@27ed688f
2015-02-10 17:18:51,094 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:51,099 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:51,099 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:51,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:51,108 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2015-02-10 17:18:51,112 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1712017304_0005_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:51,114 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:51,115 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1712017304_0005_m_000000_0 is allowed to commit now
2015-02-10 17:18:51,118 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1712017304_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse
2015-02-10 17:18:51,120 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2015-02-10 17:18:51,120 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1712017304_0005_m_000000_0' done.
2015-02-10 17:18:51,120 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1712017304_0005_m_000000_0
2015-02-10 17:18:51,121 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:51,128 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2015-02-10 17:18:51,140 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,154 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,169 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,172 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2015-02-10 17:18:51,435 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:51,436 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:51,469 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:51,470 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2015-02-10 17:18:51,470 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2015-02-10 17:18:51,470 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:51,470 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:51,471 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:51,471 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2015-02-10 17:18:51,487 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,522 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1262799931_0006
2015-02-10 17:18:51,523 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:51,526 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:51,526 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1262799931_0006_m_000000_0
2015-02-10 17:18:51,527 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@66a8a81c
2015-02-10 17:18:51,529 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache-clean.10.txt
2015-02-10 17:18:51,529 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6a0d9205
2015-02-10 17:18:51,531 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:51,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:51,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:51,555 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2015-02-10 17:18:51,556 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2015-02-10 17:18:51,659 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1262799931_0006_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:51,661 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:51,661 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1262799931_0006_m_000000_0 is allowed to commit now
2015-02-10 17:18:51,664 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1262799931_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion
2015-02-10 17:18:51,666 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/apache-clean.10.txt:0+1449
2015-02-10 17:18:51,666 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1262799931_0006_m_000000_0' done.
2015-02-10 17:18:51,666 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1262799931_0006_m_000000_0
2015-02-10 17:18:51,667 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:51,676 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2015-02-10 17:18:51,687 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,692 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2015-02-10 17:18:51,711 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:51,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:51,728 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,758 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:51,759 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2015-02-10 17:18:51,759 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2015-02-10 17:18:51,760 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:51,760 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:51,760 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:51,761 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...F849C4EE3A84A6684E0386DDE
2015-02-10 17:18:51,774 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,808 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local468546469_0007
2015-02-10 17:18:51,809 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:51,811 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:51,811 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local468546469_0007_m_000000_0
2015-02-10 17:18:51,812 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3a1be20c
2015-02-10 17:18:51,814 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-header.txt
2015-02-10 17:18:51,814 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4d480773
2015-02-10 17:18:51,816 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:51,817 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:51,817 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:51,827 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2015-02-10 17:18:51,828 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2015-02-10 17:18:51,829 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"]
2015-02-10 17:18:51,832 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local468546469_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local468546469_0007_m_000000_0
2015-02-10 17:18:51,833 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-02-10 17:18:51,837 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]
2015-02-10 17:18:51,839 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local468546469_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local468546469_0007_m_000000_0
2015-02-10 17:18:51,839 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-02-10 17:18:51,847 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/part-00000
2015-02-10 17:18:51,848 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local468546469_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local468546469_0007_m_000000_0
2015-02-10 17:18:51,850 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local468546469_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1
2015-02-10 17:18:51,851 INFO  io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/part-00000
2015-02-10 17:18:51,851 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local468546469_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local468546469_0007_m_000000_0
2015-02-10 17:18:51,854 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local468546469_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2
2015-02-10 17:18:51,855 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local468546469_0007_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:51,857 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-header.txt:0+244
2015-02-10 17:18:51,857 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local468546469_0007_m_000000_0' done.
2015-02-10 17:18:51,857 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local468546469_0007_m_000000_0
2015-02-10 17:18:51,857 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:51,874 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,888 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,900 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,902 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall2
2015-02-10 17:18:51,903 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall1
2015-02-10 17:18:51,923 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:51,924 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:51,940 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:51,941 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:51,941 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header"]
2015-02-10 17:18:51,941 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:51,942 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:51,942 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:51,942 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2015-02-10 17:18:51,954 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:51,985 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1090926235_0008
2015-02-10 17:18:51,986 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:51,989 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:51,989 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1090926235_0008_m_000000_0
2015-02-10 17:18:51,991 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6cd9ceea
2015-02-10 17:18:51,993 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt
2015-02-10 17:18:51,993 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@dae6456
2015-02-10 17:18:51,995 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:51,999 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:52,000 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:52,009 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt"]
2015-02-10 17:18:52,009 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header"]
2015-02-10 17:18:52,013 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1090926235_0008_m_000000_0 is done. And is in the process of commiting
2015-02-10 17:18:52,015 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2015-02-10 17:18:52,015 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1090926235_0008_m_000000_0 is allowed to commit now
2015-02-10 17:18:52,019 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1090926235_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header
2015-02-10 17:18:52,020 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2015-02-10 17:18:52,021 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1090926235_0008_m_000000_0' done.
2015-02-10 17:18:52,021 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1090926235_0008_m_000000_0
2015-02-10 17:18:52,021 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:52,033 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2015-02-10 17:18:52,045 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:52,048 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/header
2015-02-10 17:18:52,061 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-02-10 17:18:52,062 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(225)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.6.3/417f6462b56e135b8a02e18f34ce18a2fad9c8c4/cascading-hadoop-2.6.3.jar
2015-02-10 17:18:52,078 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] starting
2015-02-10 17:18:52,078 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2015-02-10 17:18:52,078 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2015-02-10 17:18:52,079 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  parallel execution is enabled: false
2015-02-10 17:18:52,079 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  starting jobs: 1
2015-02-10 17:18:52,079 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe]  allocating threads: 1
2015-02-10 17:18:52,080 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2015-02-10 17:18:52,091 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2015-02-10 17:18:52,118 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1806209360_0009
2015-02-10 17:18:52,119 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2015-02-10 17:18:52,121 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2015-02-10 17:18:52,121 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1806209360_0009_m_000000_0
2015-02-10 17:18:52,123 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2075a744
2015-02-10 17:18:52,124 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
2015-02-10 17:18:52,125 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6f0e0eb5
2015-02-10 17:18:52,126 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2015-02-10 17:18:52,130 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.6.3
2015-02-10 17:18:52,130 INFO  hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-02-10 17:18:52,137 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2015-02-10 17:18:52,137 INFO  hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2015-02-10 17:18:52,140 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(103)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:149)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:163)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:136)
	... 12 more
2015-02-10 17:18:52,143 ERROR stream.SourceStage (SourceStage.java:map(110)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:149)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:163)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:136)
	... 12 more
2015-02-10 17:18:52,144 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2015-02-10 17:18:52,145 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1806209360_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:149)
	at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
	at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:430)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:163)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:136)
	... 12 more
2015-02-10 17:18:52,150 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] hadoop job job_local1806209360_0009 state at FAILED
2015-02-10 17:18:52,151 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] failure info: NA
2015-02-10 17:18:52,153 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] task completion events identify failed tasks
2015-02-10 17:18:52,153 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] task completion events count: 0
2015-02-10 17:18:52,154 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] stopping all jobs
2015-02-10 17:18:52,155 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2015-02-10 17:18:52,155 INFO  flow.Flow (BaseFlow.java:logInfo(1378)) - [pipe] stopped all jobs
2015-02-10 17:18:52,156 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2015-02-10 17:18:52,156 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/84ab5c9b70b89230/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic