2014-08-22 17:59:45,430 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2014-08-22 17:59:45,484 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2014-08-22 17:59:45,485 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2014-08-22 17:59:45,519 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2014-08-22 17:59:45,954 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:45,956 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:45,970 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: BE7FFEBC40CE4C0B8480EB414F8C1FC8
2014-08-22 17:59:46,178 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.5.6
2014-08-22 17:59:46,180 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:46,181 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2014-08-22 17:59:46,182 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2014-08-22 17:59:46,182 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:46,182 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:46,182 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:46,184 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2014-08-22 17:59:46,235 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2014-08-22 17:59:46,311 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2014-08-22 17:59:46,315 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:46,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local2052700674_0001
2014-08-22 17:59:46,562 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:46,597 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:46,601 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2052700674_0001_m_000000_0
2014-08-22 17:59:46,659 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2014-08-22 17:59:46,668 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1343a083
2014-08-22 17:59:46,676 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2014-08-22 17:59:46,676 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@109ce4a3
2014-08-22 17:59:46,683 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:46,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:46,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:46,775 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2014-08-22 17:59:46,776 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2014-08-22 17:59:46,795 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local2052700674_0001_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:46,800 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:46,801 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local2052700674_0001_m_000000_0 is allowed to commit now
2014-08-22 17:59:46,806 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2052700674_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse
2014-08-22 17:59:46,808 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt:0+197
2014-08-22 17:59:46,808 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2052700674_0001_m_000000_0' done.
2014-08-22 17:59:46,809 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2052700674_0001_m_000000_0
2014-08-22 17:59:46,809 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:46,821 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2014-08-22 17:59:46,848 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:46,881 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:46,912 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:46,916 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2014-08-22 17:59:46,947 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:46,948 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:46,973 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:46,974 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:46,974 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2014-08-22 17:59:46,974 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:46,975 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:46,975 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:46,975 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2014-08-22 17:59:46,995 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,101 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local739116946_0002
2014-08-22 17:59:47,102 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:47,104 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:47,104 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local739116946_0002_m_000000_0
2014-08-22 17:59:47,106 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@22c28cb7
2014-08-22 17:59:47,108 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt
2014-08-22 17:59:47,109 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4969dd64
2014-08-22 17:59:47,110 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:47,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:47,116 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:47,127 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:47,128 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2014-08-22 17:59:47,133 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local739116946_0002_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:47,135 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:47,135 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local739116946_0002_m_000000_0 is allowed to commit now
2014-08-22 17:59:47,140 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local739116946_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue
2014-08-22 17:59:47,142 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2014-08-22 17:59:47,142 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local739116946_0002_m_000000_0' done.
2014-08-22 17:59:47,142 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local739116946_0002_m_000000_0
2014-08-22 17:59:47,142 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:47,154 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2014-08-22 17:59:47,177 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,203 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,227 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,231 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2014-08-22 17:59:47,253 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:47,254 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:47,277 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:47,277 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2014-08-22 17:59:47,277 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2014-08-22 17:59:47,278 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:47,278 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:47,278 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:47,279 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2014-08-22 17:59:47,295 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,341 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1199114699_0003
2014-08-22 17:59:47,342 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:47,345 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:47,345 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1199114699_0003_m_000000_0
2014-08-22 17:59:47,347 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@25861086
2014-08-22 17:59:47,349 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2014-08-22 17:59:47,350 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@56f052d5
2014-08-22 17:59:47,351 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:47,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:47,357 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:47,368 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2014-08-22 17:59:47,369 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2014-08-22 17:59:47,373 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1199114699_0003_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:47,375 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:47,376 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1199114699_0003_m_000000_0 is allowed to commit now
2014-08-22 17:59:47,380 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1199114699_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue
2014-08-22 17:59:47,382 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt:0+197
2014-08-22 17:59:47,382 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1199114699_0003_m_000000_0' done.
2014-08-22 17:59:47,382 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1199114699_0003_m_000000_0
2014-08-22 17:59:47,382 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:47,394 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2014-08-22 17:59:47,409 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,423 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,454 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,457 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2014-08-22 17:59:47,472 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:47,472 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:47,493 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:47,493 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:47,494 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2014-08-22 17:59:47,494 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:47,494 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:47,494 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:47,495 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2014-08-22 17:59:47,511 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1679428788_0004
2014-08-22 17:59:47,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:47,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:47,556 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1679428788_0004_m_000000_0
2014-08-22 17:59:47,558 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6a6014f7
2014-08-22 17:59:47,559 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt
2014-08-22 17:59:47,559 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4486d1da
2014-08-22 17:59:47,561 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:47,566 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:47,566 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:47,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:47,576 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2014-08-22 17:59:47,580 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1679428788_0004_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:47,583 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:47,583 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1679428788_0004_m_000000_0 is allowed to commit now
2014-08-22 17:59:47,587 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1679428788_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall
2014-08-22 17:59:47,589 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2014-08-22 17:59:47,589 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1679428788_0004_m_000000_0' done.
2014-08-22 17:59:47,589 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1679428788_0004_m_000000_0
2014-08-22 17:59:47,589 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:47,605 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2014-08-22 17:59:47,618 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,621 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerall
2014-08-22 17:59:47,634 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:47,635 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:47,652 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:47,652 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:47,652 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2014-08-22 17:59:47,653 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:47,653 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:47,653 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:47,653 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2014-08-22 17:59:47,669 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,711 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local788916970_0005
2014-08-22 17:59:47,712 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:47,713 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:47,713 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local788916970_0005_m_000000_0
2014-08-22 17:59:47,715 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4b8706f6
2014-08-22 17:59:47,717 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt
2014-08-22 17:59:47,717 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@1fb88122
2014-08-22 17:59:47,718 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:47,723 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:47,724 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:47,733 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:47,734 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2014-08-22 17:59:47,737 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local788916970_0005_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:47,740 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:47,740 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local788916970_0005_m_000000_0 is allowed to commit now
2014-08-22 17:59:47,744 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local788916970_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse
2014-08-22 17:59:47,745 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2014-08-22 17:59:47,745 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local788916970_0005_m_000000_0' done.
2014-08-22 17:59:47,746 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local788916970_0005_m_000000_0
2014-08-22 17:59:47,746 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:47,754 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2014-08-22 17:59:47,766 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,779 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,792 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:47,795 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2014-08-22 17:59:48,043 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:48,044 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:48,085 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:48,086 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [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/3945655b04626318/apache-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2014-08-22 17:59:48,087 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [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/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2014-08-22 17:59:48,088 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:48,088 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:48,089 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:48,090 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2014-08-22 17:59:48,105 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,145 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local321980708_0006
2014-08-22 17:59:48,145 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:48,148 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:48,148 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local321980708_0006_m_000000_0
2014-08-22 17:59:48,150 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@706ee404
2014-08-22 17:59:48,152 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache-clean.10.txt
2014-08-22 17:59:48,153 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2583d260
2014-08-22 17:59:48,155 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:48,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:48,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:48,183 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/3945655b04626318/apache-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2014-08-22 17:59:48,183 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/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2014-08-22 17:59:48,321 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local321980708_0006_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:48,323 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:48,323 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local321980708_0006_m_000000_0 is allowed to commit now
2014-08-22 17:59:48,327 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local321980708_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion
2014-08-22 17:59:48,328 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/apache-clean.10.txt:0+1449
2014-08-22 17:59:48,329 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local321980708_0006_m_000000_0' done.
2014-08-22 17:59:48,329 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local321980708_0006_m_000000_0
2014-08-22 17:59:48,329 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:48,339 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2014-08-22 17:59:48,350 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,355 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2014-08-22 17:59:48,372 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:48,372 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:48,387 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,417 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:48,418 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2014-08-22 17:59:48,418 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2014-08-22 17:59:48,418 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:48,419 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:48,419 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:48,419 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...866FF4661904804DDD631EFFC
2014-08-22 17:59:48,432 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,465 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local729360220_0007
2014-08-22 17:59:48,466 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:48,469 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:48,469 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local729360220_0007_m_000000_0
2014-08-22 17:59:48,471 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@16d0a6a3
2014-08-22 17:59:48,472 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-header.txt
2014-08-22 17:59:48,473 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@41b9da92
2014-08-22 17:59:48,474 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:48,475 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:48,475 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:48,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2014-08-22 17:59:48,486 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2014-08-22 17:59:48,487 INFO tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"]
2014-08-22 17:59:48,491 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local729360220_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local729360220_0007_m_000000_0
2014-08-22 17:59:48,491 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2014-08-22 17:59:48,495 INFO tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]
2014-08-22 17:59:48,498 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local729360220_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local729360220_0007_m_000000_0
2014-08-22 17:59:48,498 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2014-08-22 17:59:48,505 INFO io.TapOutputCollector (TapOutputCollector.java:close(135)) - closing tap collector for: /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/part-00000
2014-08-22 17:59:48,506 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local729360220_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local729360220_0007_m_000000_0
2014-08-22 17:59:48,509 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local729360220_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1
2014-08-22 17:59:48,510 INFO io.TapOutputCollector (TapOutputCollector.java:close(135)) - closing tap collector for: /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/part-00000
2014-08-22 17:59:48,510 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local729360220_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local729360220_0007_m_000000_0
2014-08-22 17:59:48,513 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local729360220_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2
2014-08-22 17:59:48,513 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local729360220_0007_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:48,516 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-header.txt:0+244
2014-08-22 17:59:48,516 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local729360220_0007_m_000000_0' done.
2014-08-22 17:59:48,516 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local729360220_0007_m_000000_0
2014-08-22 17:59:48,516 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:48,544 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,558 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,570 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,572 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall1
2014-08-22 17:59:48,573 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall2
2014-08-22 17:59:48,585 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:48,586 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:48,602 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:48,602 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:48,603 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header"]
2014-08-22 17:59:48,603 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:48,603 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:48,603 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:48,604 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2014-08-22 17:59:48,616 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,659 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local1784421177_0008
2014-08-22 17:59:48,661 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:48,663 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:48,663 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1784421177_0008_m_000000_0
2014-08-22 17:59:48,665 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@46c80e21
2014-08-22 17:59:48,667 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt
2014-08-22 17:59:48,667 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@2898b13b
2014-08-22 17:59:48,670 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:48,674 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:48,674 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:48,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt"]
2014-08-22 17:59:48,683 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header"]
2014-08-22 17:59:48,687 INFO mapred.Task (Task.java:done(858)) - Task:attempt_local1784421177_0008_m_000000_0 is done. And is in the process of commiting
2014-08-22 17:59:48,689 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) -
2014-08-22 17:59:48,689 INFO mapred.Task (Task.java:commit(1011)) - Task attempt_local1784421177_0008_m_000000_0 is allowed to commit now
2014-08-22 17:59:48,692 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1784421177_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header
2014-08-22 17:59:48,694 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2014-08-22 17:59:48,694 INFO mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1784421177_0008_m_000000_0' done.
2014-08-22 17:59:48,694 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1784421177_0008_m_000000_0
2014-08-22 17:59:48,694 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:48,708 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2014-08-22 17:59:48,719 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,722 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/header
2014-08-22 17:59:48,733 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2014-08-22 17:59:48,734 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.5.6/a36851b185807587c9a4b9e914f06c5ea27801c9/cascading-hadoop-2.5.6.jar
2014-08-22 17:59:48,749 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting
2014-08-22 17:59:48,750 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2014-08-22 17:59:48,751 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2014-08-22 17:59:48,751 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] parallel execution is enabled: false
2014-08-22 17:59:48,752 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] starting jobs: 1
2014-08-22 17:59:48,752 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] allocating threads: 1
2014-08-22 17:59:48,753 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2014-08-22 17:59:48,765 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2014-08-22 17:59:48,792 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] submitted hadoop job: job_local834060160_0009
2014-08-22 17:59:48,793 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] tracking url: http://localhost:8080/
2014-08-22 17:59:48,795 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2014-08-22 17:59:48,796 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local834060160_0009_m_000000_0
2014-08-22 17:59:48,798 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2bf87baf
2014-08-22 17:59:48,800 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
2014-08-22 17:59:48,800 INFO mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@72e5c94
2014-08-22 17:59:48,802 INFO mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2014-08-22 17:59:48,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.5.6
2014-08-22 17:59:48,807 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2014-08-22 17:59:48,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2014-08-22 17:59:48,815 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2014-08-22 17:59:48,819 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/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:127)
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:1008)
at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
... 12 more
2014-08-22 17:59:48,822 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/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:127)
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:1008)
at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
... 12 more
2014-08-22 17:59:48,824 INFO mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2014-08-22 17:59:48,825 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local834060160_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/3945655b04626318/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/3945655b04626318/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:127)
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:1008)
at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
... 12 more
2014-08-22 17:59:48,835 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] hadoop job job_local834060160_0009 state at FAILED
2014-08-22 17:59:48,836 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] failure info: NA
2014-08-22 17:59:48,839 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] task completion events identify failed tasks
2014-08-22 17:59:48,839 WARN flow.FlowStep (BaseFlowStep.java:logWarn(839)) - [pipe] task completion events count: 0
2014-08-22 17:59:48,840 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] stopping all jobs
2014-08-22 17:59:48,840 INFO flow.FlowStep (BaseFlowStep.java:logInfo(834)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2014-08-22 17:59:48,841 INFO flow.Flow (BaseFlow.java:logInfo(1354)) - [pipe] stopped all jobs
2014-08-22 17:59:48,841 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2014-08-22 17:59:48,842 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/3945655b04626318/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic