Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

2.894s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.478s passed
testHeader 0.133s passed
testHeaderAll 0.167s passed
testHeaderFieldsAll 0.156s passed
testQuotedText 0.161s passed
testQuotedTextAll 0.280s passed
testQuotedTextSpecChar 1.214s passed
testQuotedTextSpecCharAll 0.203s passed
testStrict 0.102s passed

Standard output

2013-11-20 14:32:43,401 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 14:32:43,425 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 14:32:43,425 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2013-11-20 14:32:43,453 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 14:32:43,824 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:43,826 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:43,839 INFO  property.AppProps (AppProps.java:getAppID(162)) - using app.id: 11BE0773E1CC4A7DAA8B84598639F371
2013-11-20 14:32:44,024 INFO  util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 14:32:44,028 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:44,030 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 14:32:44,031 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2013-11-20 14:32:44,032 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:44,033 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:44,034 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:44,036 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2013-11-20 14:32:44,080 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-11-20 14:32:44,147 WARN  snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-11-20 14:32:44,155 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,364 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local2009669985_0001
2013-11-20 14:32:44,395 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:44,399 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local2009669985_0001_m_000000_0
2013-11-20 14:32:44,453 INFO  util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 14:32:44,461 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6e82254d
2013-11-20 14:32:44,469 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2013-11-20 14:32:44,469 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@6bc5af2e
2013-11-20 14:32:44,478 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:44,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:44,490 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:44,523 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 14:32:44,524 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2013-11-20 14:32:44,542 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local2009669985_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:44,547 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:44,547 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local2009669985_0001_m_000000_0 is allowed to commit now
2013-11-20 14:32:44,553 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local2009669985_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse
2013-11-20 14:32:44,555 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt:0+197
2013-11-20 14:32:44,555 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local2009669985_0001_m_000000_0' done.
2013-11-20 14:32:44,556 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local2009669985_0001_m_000000_0
2013-11-20 14:32:44,557 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:44,581 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2013-11-20 14:32:44,607 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,633 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,659 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,664 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2013-11-20 14:32:44,690 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:44,691 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:44,710 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:44,711 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:44,711 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2013-11-20 14:32:44,712 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:44,712 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:44,713 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:44,714 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2013-11-20 14:32:44,729 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,822 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local1801125960_0002
2013-11-20 14:32:44,826 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:44,827 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1801125960_0002_m_000000_0
2013-11-20 14:32:44,829 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@6a42a6eb
2013-11-20 14:32:44,831 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt
2013-11-20 14:32:44,832 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@32c26ede
2013-11-20 14:32:44,833 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:44,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:44,840 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:44,849 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:44,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2013-11-20 14:32:44,855 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1801125960_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:44,857 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:44,857 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1801125960_0002_m_000000_0 is allowed to commit now
2013-11-20 14:32:44,861 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1801125960_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue
2013-11-20 14:32:44,863 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2013-11-20 14:32:44,863 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1801125960_0002_m_000000_0' done.
2013-11-20 14:32:44,863 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1801125960_0002_m_000000_0
2013-11-20 14:32:44,863 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:44,874 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2013-11-20 14:32:44,896 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,919 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,941 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:44,945 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2013-11-20 14:32:44,966 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:44,966 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:44,986 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:44,987 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 14:32:44,988 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2013-11-20 14:32:44,989 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:44,990 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:44,991 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:44,992 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2013-11-20 14:32:45,008 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,053 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local1229862448_0003
2013-11-20 14:32:45,057 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:45,057 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1229862448_0003_m_000000_0
2013-11-20 14:32:45,060 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2bf8f8c8
2013-11-20 14:32:45,062 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2013-11-20 14:32:45,062 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@3a87d472
2013-11-20 14:32:45,064 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:45,069 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:45,069 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:45,080 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 14:32:45,081 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2013-11-20 14:32:45,085 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1229862448_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:45,087 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:45,087 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1229862448_0003_m_000000_0 is allowed to commit now
2013-11-20 14:32:45,091 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1229862448_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue
2013-11-20 14:32:45,093 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt:0+197
2013-11-20 14:32:45,093 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1229862448_0003_m_000000_0' done.
2013-11-20 14:32:45,093 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1229862448_0003_m_000000_0
2013-11-20 14:32:45,093 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:45,105 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2013-11-20 14:32:45,118 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,131 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,146 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,149 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2013-11-20 14:32:45,162 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:45,163 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:45,186 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:45,188 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:45,190 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2013-11-20 14:32:45,191 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:45,192 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:45,192 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:45,194 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2013-11-20 14:32:45,209 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,248 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local1503094245_0004
2013-11-20 14:32:45,251 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:45,252 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local1503094245_0004_m_000000_0
2013-11-20 14:32:45,253 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@75a9883d
2013-11-20 14:32:45,255 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt
2013-11-20 14:32:45,255 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@76d78df0
2013-11-20 14:32:45,256 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:45,261 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:45,262 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:45,271 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:45,271 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2013-11-20 14:32:45,275 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local1503094245_0004_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:45,278 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:45,278 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local1503094245_0004_m_000000_0 is allowed to commit now
2013-11-20 14:32:45,282 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local1503094245_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall
2013-11-20 14:32:45,284 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2013-11-20 14:32:45,285 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local1503094245_0004_m_000000_0' done.
2013-11-20 14:32:45,285 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local1503094245_0004_m_000000_0
2013-11-20 14:32:45,286 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:45,300 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2013-11-20 14:32:45,314 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,317 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerall
2013-11-20 14:32:45,328 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:45,329 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:45,343 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:45,343 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:45,343 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2013-11-20 14:32:45,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:45,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:45,344 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:45,345 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2013-11-20 14:32:45,360 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,399 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local643340772_0005
2013-11-20 14:32:45,402 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:45,402 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local643340772_0005_m_000000_0
2013-11-20 14:32:45,404 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@268c858a
2013-11-20 14:32:45,406 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt
2013-11-20 14:32:45,406 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@52c51614
2013-11-20 14:32:45,407 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:45,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:45,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:45,420 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:45,420 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2013-11-20 14:32:45,424 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local643340772_0005_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:45,426 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:45,426 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local643340772_0005_m_000000_0 is allowed to commit now
2013-11-20 14:32:45,429 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local643340772_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse
2013-11-20 14:32:45,431 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2013-11-20 14:32:45,431 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local643340772_0005_m_000000_0' done.
2013-11-20 14:32:45,431 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local643340772_0005_m_000000_0
2013-11-20 14:32:45,431 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:45,441 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2013-11-20 14:32:45,451 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,463 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,475 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,478 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2013-11-20 14:32:45,693 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:45,694 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:45,722 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:45,723 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [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/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2013-11-20 14:32:45,724 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [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/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2013-11-20 14:32:45,724 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:45,725 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:45,725 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:45,726 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2013-11-20 14:32:45,739 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,777 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local283819858_0006
2013-11-20 14:32:45,780 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:45,780 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local283819858_0006_m_000000_0
2013-11-20 14:32:45,782 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1f5fa713
2013-11-20 14:32:45,784 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache-clean.10.txt
2013-11-20 14:32:45,784 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@665b6d00
2013-11-20 14:32:45,785 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:45,789 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:45,790 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:45,808 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - 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/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2013-11-20 14:32:45,809 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - 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/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2013-11-20 14:32:45,922 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local283819858_0006_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:45,924 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:45,925 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local283819858_0006_m_000000_0 is allowed to commit now
2013-11-20 14:32:45,928 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local283819858_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion
2013-11-20 14:32:45,929 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/apache-clean.10.txt:0+1449
2013-11-20 14:32:45,929 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local283819858_0006_m_000000_0' done.
2013-11-20 14:32:45,929 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local283819858_0006_m_000000_0
2013-11-20 14:32:45,930 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:45,941 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2013-11-20 14:32:45,951 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,956 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2013-11-20 14:32:45,968 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:45,968 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:45,982 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:45,996 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:45,997 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2013-11-20 14:32:45,997 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall"]
2013-11-20 14:32:45,997 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:45,998 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:45,998 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:45,998 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...dplatform/headerfieldsall
2013-11-20 14:32:46,010 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:46,042 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local459640071_0007
2013-11-20 14:32:46,045 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:46,045 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local459640071_0007_m_000000_0
2013-11-20 14:32:46,047 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2c79cd09
2013-11-20 14:32:46,048 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-header.txt
2013-11-20 14:32:46,049 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@4bb4df9c
2013-11-20 14:32:46,050 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:46,054 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:46,054 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:46,061 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2013-11-20 14:32:46,062 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall"]
2013-11-20 14:32:46,066 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local459640071_0007_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:46,068 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:46,069 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local459640071_0007_m_000000_0 is allowed to commit now
2013-11-20 14:32:46,072 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local459640071_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall
2013-11-20 14:32:46,073 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-header.txt:0+244
2013-11-20 14:32:46,074 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local459640071_0007_m_000000_0' done.
2013-11-20 14:32:46,074 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local459640071_0007_m_000000_0
2013-11-20 14:32:46,074 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:46,084 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall/_temporary
2013-11-20 14:32:46,097 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:46,111 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:46,112 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall
2013-11-20 14:32:46,123 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:46,124 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:46,138 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:46,139 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:46,139 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header"]
2013-11-20 14:32:46,140 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:46,140 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:46,141 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:46,142 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2013-11-20 14:32:46,153 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:46,184 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local542686172_0008
2013-11-20 14:32:46,186 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:46,187 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local542686172_0008_m_000000_0
2013-11-20 14:32:46,189 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2279ecf4
2013-11-20 14:32:46,190 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt
2013-11-20 14:32:46,190 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@675ee9e3
2013-11-20 14:32:46,192 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:46,196 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:46,196 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:46,204 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt"]
2013-11-20 14:32:46,204 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header"]
2013-11-20 14:32:46,208 INFO  mapred.Task (Task.java:done(858)) - Task:attempt_local542686172_0008_m_000000_0 is done. And is in the process of commiting
2013-11-20 14:32:46,210 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - 
2013-11-20 14:32:46,210 INFO  mapred.Task (Task.java:commit(1011)) - Task attempt_local542686172_0008_m_000000_0 is allowed to commit now
2013-11-20 14:32:46,213 INFO  mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local542686172_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header
2013-11-20 14:32:46,214 INFO  mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(466)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited.txt:0+198
2013-11-20 14:32:46,214 INFO  mapred.Task (Task.java:sendDone(970)) - Task 'attempt_local542686172_0008_m_000000_0' done.
2013-11-20 14:32:46,215 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(229)) - Finishing task: attempt_local542686172_0008_m_000000_0
2013-11-20 14:32:46,215 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:46,226 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2013-11-20 14:32:46,243 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:46,246 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/header
2013-11-20 14:32:46,256 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 14:32:46,256 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(203)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/artifacts-24/filestore/cascading/cascading-hadoop/2.2.0/jar/c7b52bd4c6da523ebde0a5d6eca2475123783db2/cascading-hadoop-2.2.0.jar
2013-11-20 14:32:46,270 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 14:32:46,270 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2013-11-20 14:32:46,271 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2013-11-20 14:32:46,271 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  parallel execution is enabled: false
2013-11-20 14:32:46,272 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  starting jobs: 1
2013-11-20 14:32:46,272 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe]  allocating threads: 1
2013-11-20 14:32:46,273 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2013-11-20 14:32:46,288 INFO  mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 14:32:46,314 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local189906387_0009
2013-11-20 14:32:46,317 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(340)) - Waiting for map tasks
2013-11-20 14:32:46,317 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(204)) - Starting task: attempt_local189906387_0009_m_000000_0
2013-11-20 14:32:46,319 INFO  mapred.Task (Task.java:initialize(534)) -  Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@14235085
2013-11-20 14:32:46,322 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
2013-11-20 14:32:46,322 INFO  mapred.MapTask (MapTask.java:updateJobWithSplit(455)) - Processing split: cascading.tap.hadoop.io.MultiInputSplit@40ad8bb4
2013-11-20 14:32:46,324 INFO  mapred.MapTask (MapTask.java:runOldMapper(419)) - numReduceTasks: 0
2013-11-20 14:32:46,328 INFO  hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 14:32:46,328 INFO  hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 14:32:46,335 INFO  hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2013-11-20 14:32:46,335 INFO  hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2013-11-20 14:32:46,338 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/d1f96f51023738a5/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:127)
	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:395)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1006)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
	... 12 more
2013-11-20 14:32:46,341 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/d1f96f51023738a5/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:127)
	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:395)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1006)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
	... 12 more
2013-11-20 14:32:46,342 INFO  mapred.LocalJobRunner (LocalJobRunner.java:run(348)) - Map task executor complete.
2013-11-20 14:32:46,343 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local189906387_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/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/d1f96f51023738a5/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:127)
	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:395)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1006)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:140)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:120)
	... 12 more
2013-11-20 14:32:46,346 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [pipe] task completion events identify failed tasks
2013-11-20 14:32:46,346 WARN  flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [pipe] task completion events count: 0
2013-11-20 14:32:46,346 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] stopping all jobs
2013-11-20 14:32:46,347 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2013-11-20 14:32:46,347 INFO  flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] stopped all jobs
2013-11-20 14:32:46,347 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2013-11-20 14:32:46,348 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic