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