2013-10-02 03:46:01,565 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-10-02 03:46:01,593 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-10-02 03:46:01,594 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2013-10-02 03:46:01,626 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-10-02 03:46:01,996 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:01,998 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:02,010 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 8DCDCEF2C5754A1B84124E80DCF0CE41
2013-10-02 03:46:02,190 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0-wip-122
2013-10-02 03:46:02,194 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:02,195 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt"]
2013-10-02 03:46:02,196 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2013-10-02 03:46:02,197 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:02,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:02,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:02,200 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2013-10-02 03:46:02,245 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2013-10-02 03:46:02,289 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2013-10-02 03:46:02,295 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:02,480 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0001
2013-10-02 03:46:02,539 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-10-02 03:46:02,547 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@135c40eb
2013-10-02 03:46:02,555 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt
2013-10-02 03:46:02,561 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:02,572 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:02,572 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:02,605 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt"]
2013-10-02 03:46:02,606 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2013-10-02 03:46:02,624 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:02,627 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:02,628 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-10-02 03:46:02,633 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0001_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse
2013-10-02 03:46:05,524 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt:0+197
2013-10-02 03:46:05,525 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2013-10-02 03:46:05,541 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2013-10-02 03:46:05,566 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:05,589 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:05,613 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:05,617 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2013-10-02 03:46:05,651 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:05,652 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:05,671 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:05,672 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:05,673 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2013-10-02 03:46:05,673 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:05,674 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:05,674 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:05,676 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2013-10-02 03:46:05,694 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:05,768 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0002
2013-10-02 03:46:05,773 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3dae160
2013-10-02 03:46:05,775 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt
2013-10-02 03:46:05,776 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:05,781 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:05,782 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:05,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:05,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2013-10-02 03:46:05,796 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:05,797 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:05,798 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2013-10-02 03:46:05,802 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0002_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue
2013-10-02 03:46:08,773 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt:0+198
2013-10-02 03:46:08,776 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2013-10-02 03:46:08,810 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2013-10-02 03:46:08,831 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:08,851 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:08,871 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:08,875 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2013-10-02 03:46:08,894 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:08,895 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:08,914 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:08,915 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt"]
2013-10-02 03:46:08,916 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2013-10-02 03:46:08,916 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:08,917 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:08,917 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:08,918 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2013-10-02 03:46:08,935 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:08,994 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0003
2013-10-02 03:46:09,000 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@534a55e5
2013-10-02 03:46:09,002 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt
2013-10-02 03:46:09,004 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:09,009 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:09,009 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:09,018 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt"]
2013-10-02 03:46:09,019 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2013-10-02 03:46:09,023 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:09,025 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:09,026 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2013-10-02 03:46:09,030 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0003_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue
2013-10-02 03:46:12,000 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-spec-char.txt:0+197
2013-10-02 03:46:12,000 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2013-10-02 03:46:12,014 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2013-10-02 03:46:12,027 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:12,040 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:12,053 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:12,056 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2013-10-02 03:46:12,067 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:12,068 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:12,085 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:12,085 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:12,087 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2013-10-02 03:46:12,087 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:12,088 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:12,088 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:12,089 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2013-10-02 03:46:12,104 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:12,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0004
2013-10-02 03:46:12,143 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@72ebf3f0
2013-10-02 03:46:12,145 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt
2013-10-02 03:46:12,146 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:12,151 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:12,151 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:12,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:12,160 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2013-10-02 03:46:12,165 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:12,166 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:12,166 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2013-10-02 03:46:12,172 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0004_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerall
2013-10-02 03:46:15,143 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt:0+198
2013-10-02 03:46:15,144 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2013-10-02 03:46:15,158 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2013-10-02 03:46:15,168 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:15,171 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/headerall
2013-10-02 03:46:15,182 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:15,183 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:15,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:15,198 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:15,199 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2013-10-02 03:46:15,199 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:15,199 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:15,199 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:15,200 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2013-10-02 03:46:15,217 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:15,267 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0005
2013-10-02 03:46:15,271 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@53933acb
2013-10-02 03:46:15,273 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt
2013-10-02 03:46:15,274 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:15,279 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:15,279 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:15,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:15,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2013-10-02 03:46:15,292 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:15,293 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:15,294 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2013-10-02 03:46:15,297 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0005_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse
2013-10-02 03:46:18,271 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt:0+198
2013-10-02 03:46:18,272 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2013-10-02 03:46:18,305 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2013-10-02 03:46:18,315 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:18,327 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:18,339 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:18,342 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2013-10-02 03:46:18,565 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:18,565 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:18,598 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:18,599 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/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache-clean.10.txt"]
2013-10-02 03:46:18,599 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/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2013-10-02 03:46:18,600 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:18,600 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:18,600 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:18,601 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2013-10-02 03:46:18,653 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:18,683 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0006
2013-10-02 03:46:18,687 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@1f5fa713
2013-10-02 03:46:18,689 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache-clean.10.txt
2013-10-02 03:46:18,690 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:18,694 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:18,694 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:18,711 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/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache-clean.10.txt"]
2013-10-02 03:46:18,711 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/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2013-10-02 03:46:18,824 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:18,824 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:18,825 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2013-10-02 03:46:18,828 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0006_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion
2013-10-02 03:46:21,687 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/apache-clean.10.txt:0+1449
2013-10-02 03:46:21,688 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2013-10-02 03:46:21,696 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2013-10-02 03:46:21,706 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:21,710 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2013-10-02 03:46:21,722 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:21,722 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:21,735 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:21,750 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:21,751 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-header.txt"]
2013-10-02 03:46:21,751 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall"]
2013-10-02 03:46:21,752 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:21,753 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:21,753 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:21,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...dplatform/headerfieldsall
2013-10-02 03:46:21,771 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:21,801 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0007
2013-10-02 03:46:21,820 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@23087d61
2013-10-02 03:46:21,821 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-header.txt
2013-10-02 03:46:21,822 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:21,827 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:21,827 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:21,834 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-header.txt"]
2013-10-02 03:46:21,835 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall"]
2013-10-02 03:46:21,838 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:21,839 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:21,840 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2013-10-02 03:46:21,843 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall
2013-10-02 03:46:24,820 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-header.txt:0+244
2013-10-02 03:46:24,821 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2013-10-02 03:46:25,061 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall/_temporary
2013-10-02 03:46:25,072 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:25,083 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:25,085 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall
2013-10-02 03:46:25,094 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:25,095 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:25,108 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:25,109 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:25,110 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/header"]
2013-10-02 03:46:25,110 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:25,111 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:25,111 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:25,113 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2013-10-02 03:46:25,124 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:25,150 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0008
2013-10-02 03:46:25,155 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7a6dd8e1
2013-10-02 03:46:25,156 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt
2013-10-02 03:46:25,158 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:25,161 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:25,161 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:25,168 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt"]
2013-10-02 03:46:25,169 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/header"]
2013-10-02 03:46:25,172 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2013-10-02 03:46:25,173 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-10-02 03:46:25,173 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-10-02 03:46:25,176 INFO mapred.FileOutputCommitter (FileOutputCommitter.java:commitTask(138)) - Saved output of task 'attempt_local_0008_m_000000_0' to file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/header
2013-10-02 03:46:28,155 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited.txt:0+198
2013-10-02 03:46:28,156 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2013-10-02 03:46:28,160 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2013-10-02 03:46:28,169 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:28,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/header
2013-10-02 03:46:28,181 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-10-02 03:46:28,181 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-wip-122/jar/5b86bf7816e41bd8a370cd0fec30495eaf465243/cascading-hadoop-2.2.0-wip-122.jar
2013-10-02 03:46:28,194 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-10-02 03:46:28,195 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-extra-field.txt"]
2013-10-02 03:46:28,195 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2013-10-02 03:46:28,196 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-10-02 03:46:28,196 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-10-02 03:46:28,197 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-10-02 03:46:28,198 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2013-10-02 03:46:28,210 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-10-02 03:46:28,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0009
2013-10-02 03:46:28,240 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@13d86a73
2013-10-02 03:46:28,242 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-extra-field.txt
2013-10-02 03:46:28,243 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-10-02 03:46:28,246 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0-wip-122
2013-10-02 03:46:28,246 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-10-02 03:46:28,252 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/classes/test/data/delimited-extra-field.txt"]
2013-10-02 03:46:28,253 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2013-10-02 03:46:28,256 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/764fbec8be3dd025/apache-1.0.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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 6 more
2013-10-02 03:46:28,258 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/764fbec8be3dd025/apache-1.0.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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 6 more
2013-10-02 03:46:28,259 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0009
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.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:436)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
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)
... 6 more
2013-10-02 03:46:28,270 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [pipe] task completion events identify failed tasks
2013-10-02 03:46:28,270 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [pipe] task completion events count: 0
2013-10-02 03:46:28,271 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] stopping all jobs
2013-10-02 03:46:28,271 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2013-10-02 03:46:28,272 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] stopped all jobs
2013-10-02 03:46:28,272 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2013-10-02 03:46:28,273 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/764fbec8be3dd025/apache-1.0.x/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic