2013-11-20 12:09:02,673 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2013-11-20 12:09:02,699 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2013-11-20 12:09:02,699 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2013-11-20 12:09:02,728 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2013-11-20 12:09:03,084 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:03,085 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 12:09:03,097 INFO property.AppProps (AppProps.java:getAppID(162)) - using app.id: 7B1B7147AF024A8586505F2549BD9FA4
2013-11-20 12:09:03,277 INFO util.Version (Version.java:printBanner(78)) - Concurrent, Inc - Cascading 2.2.0
2013-11-20 12:09:03,280 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:03,281 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 12:09:03,281 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2013-11-20 12:09:03,281 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:03,282 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:03,282 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:03,284 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2013-11-20 12:09:03,323 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 12:09:03,372 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:03,574 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0001
2013-11-20 12:09:03,633 INFO util.ProcessTree (ProcessTree.java:isSetsidSupported(63)) - setsid exited with exit code 0
2013-11-20 12:09:03,642 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@26c59ad5
2013-11-20 12:09:03,648 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2013-11-20 12:09:03,655 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:03,667 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:03,668 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:03,703 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 12:09:03,704 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2013-11-20 12:09:03,723 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0001_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:03,727 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:03,728 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0001_m_000000_0 is allowed to commit now
2013-11-20 12:09:03,733 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse
2013-11-20 12:09:06,617 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt:0+197
2013-11-20 12:09:06,618 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0001_m_000000_0' done.
2013-11-20 12:09:06,629 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2013-11-20 12:09:06,654 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:06,678 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:06,702 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:06,706 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2013-11-20 12:09:06,742 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:06,742 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 12:09:06,763 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:06,763 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:06,764 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2013-11-20 12:09:06,764 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:06,765 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:06,765 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:06,766 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2013-11-20 12:09:06,781 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:06,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0002
2013-11-20 12:09:06,859 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@2e39060b
2013-11-20 12:09:06,861 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt
2013-11-20 12:09:06,864 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:06,870 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:06,870 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:06,880 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:06,881 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2013-11-20 12:09:06,885 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0002_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:06,886 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:06,887 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0002_m_000000_0 is allowed to commit now
2013-11-20 12:09:06,891 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue
2013-11-20 12:09:09,859 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt:0+198
2013-11-20 12:09:09,860 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0002_m_000000_0' done.
2013-11-20 12:09:09,873 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2013-11-20 12:09:09,893 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:09,914 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:09,935 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:09,939 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2013-11-20 12:09:09,958 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:09,959 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 12:09:09,977 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:09,978 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 12:09:09,978 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2013-11-20 12:09:09,978 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:09,979 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:09,979 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:09,980 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2013-11-20 12:09:09,997 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:10,089 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0003
2013-11-20 12:09:10,094 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@354d581b
2013-11-20 12:09:10,097 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2013-11-20 12:09:10,098 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:10,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:10,104 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:10,114 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2013-11-20 12:09:10,114 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2013-11-20 12:09:10,119 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0003_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:10,120 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:10,120 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0003_m_000000_0 is allowed to commit now
2013-11-20 12:09:10,124 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue
2013-11-20 12:09:13,095 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt:0+197
2013-11-20 12:09:13,096 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0003_m_000000_0' done.
2013-11-20 12:09:13,159 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2013-11-20 12:09:13,197 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:13,209 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:13,222 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:13,225 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2013-11-20 12:09:13,237 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:13,238 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 12:09:13,255 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:13,256 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:13,257 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall"]
2013-11-20 12:09:13,257 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:13,258 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:13,258 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:13,259 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2013-11-20 12:09:13,274 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:13,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0004
2013-11-20 12:09:13,314 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@4fb595f3
2013-11-20 12:09:13,316 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt
2013-11-20 12:09:13,318 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:13,323 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:13,323 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:13,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:13,355 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall"]
2013-11-20 12:09:13,359 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0004_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:13,360 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:13,360 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0004_m_000000_0 is allowed to commit now
2013-11-20 12:09:13,365 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall
2013-11-20 12:09:16,314 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt:0+198
2013-11-20 12:09:16,315 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0004_m_000000_0' done.
2013-11-20 12:09:16,328 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2013-11-20 12:09:16,364 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:16,367 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/headerall
2013-11-20 12:09:16,378 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:16,379 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 12:09:16,393 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:16,394 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:16,395 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2013-11-20 12:09:16,396 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:16,396 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:16,397 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:16,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2013-11-20 12:09:16,413 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:16,459 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0005
2013-11-20 12:09:16,464 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@889ec59
2013-11-20 12:09:16,466 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt
2013-11-20 12:09:16,469 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:16,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:16,474 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:16,484 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:16,484 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2013-11-20 12:09:16,488 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0005_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:16,488 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:16,489 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0005_m_000000_0 is allowed to commit now
2013-11-20 12:09:16,493 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse
2013-11-20 12:09:19,464 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt:0+198
2013-11-20 12:09:19,465 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0005_m_000000_0' done.
2013-11-20 12:09:19,478 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2013-11-20 12:09:19,514 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:19,525 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:19,537 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:19,539 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2013-11-20 12:09:19,763 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:19,763 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 12:09:19,797 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:19,798 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-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2013-11-20 12:09:19,798 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-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2013-11-20 12:09:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:19,799 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:19,800 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:19,800 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2013-11-20 12:09:19,815 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:19,843 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0006
2013-11-20 12:09:19,849 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@7087e9bf
2013-11-20 12:09:19,852 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt
2013-11-20 12:09:19,853 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:19,858 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:19,858 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:19,877 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-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2013-11-20 12:09:19,878 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-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2013-11-20 12:09:19,999 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0006_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:20,000 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:20,001 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0006_m_000000_0 is allowed to commit now
2013-11-20 12:09:20,005 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion
2013-11-20 12:09:22,849 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt:0+1449
2013-11-20 12:09:22,850 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0006_m_000000_0' done.
2013-11-20 12:09:22,863 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2013-11-20 12:09:22,873 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:22,878 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2013-11-20 12:09:22,889 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:22,889 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 12:09:22,902 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:22,917 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:22,917 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2013-11-20 12:09:22,917 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall"]
2013-11-20 12:09:22,918 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:22,918 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:22,918 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:22,920 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...dplatform/headerfieldsall
2013-11-20 12:09:22,971 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:23,052 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0007
2013-11-20 12:09:23,055 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@252a78ee
2013-11-20 12:09:23,057 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-header.txt
2013-11-20 12:09:23,058 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:23,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:23,062 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:23,069 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2013-11-20 12:09:23,070 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall"]
2013-11-20 12:09:23,073 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0007_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:23,074 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:23,074 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0007_m_000000_0 is allowed to commit now
2013-11-20 12:09:23,077 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall
2013-11-20 12:09:26,056 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-header.txt:0+244
2013-11-20 12:09:26,056 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0007_m_000000_0' done.
2013-11-20 12:09:26,062 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall/_temporary
2013-11-20 12:09:26,073 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:26,086 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:26,088 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/headerfieldsall
2013-11-20 12:09:26,101 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:26,102 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 12:09:26,115 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:26,116 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:26,116 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header"]
2013-11-20 12:09:26,116 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:26,116 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:26,117 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:26,117 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2013-11-20 12:09:26,128 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:26,154 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0008
2013-11-20 12:09:26,157 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@282bfa91
2013-11-20 12:09:26,159 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt
2013-11-20 12:09:26,160 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:26,164 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:26,164 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:26,172 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2013-11-20 12:09:26,172 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header"]
2013-11-20 12:09:26,176 INFO mapred.Task (Task.java:done(847)) - Task:attempt_local_0008_m_000000_0 is done. And is in the process of commiting
2013-11-20 12:09:26,177 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) -
2013-11-20 12:09:26,177 INFO mapred.Task (Task.java:commit(1000)) - Task attempt_local_0008_m_000000_0 is allowed to commit now
2013-11-20 12:09:26,180 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/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header
2013-11-20 12:09:29,157 INFO mapred.LocalJobRunner (LocalJobRunner.java:statusUpdate(321)) - file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited.txt:0+198
2013-11-20 12:09:29,158 INFO mapred.Task (Task.java:sendDone(959)) - Task 'attempt_local_0008_m_000000_0' done.
2013-11-20 12:09:29,162 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2013-11-20 12:09:29,208 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:29,211 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/header
2013-11-20 12:09:29,222 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(319)) - using default application jar, may cause class not found exceptions on the cluster
2013-11-20 12:09:29,223 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 12:09:29,237 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting
2013-11-20 12:09:29,237 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2013-11-20 12:09:29,238 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2013-11-20 12:09:29,238 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] parallel execution is enabled: false
2013-11-20 12:09:29,238 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] starting jobs: 1
2013-11-20 12:09:29,238 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] allocating threads: 1
2013-11-20 12:09:29,239 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2013-11-20 12:09:29,251 INFO mapred.FileInputFormat (FileInputFormat.java:listStatus(199)) - Total input paths to process : 1
2013-11-20 12:09:29,277 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] submitted hadoop job: job_local_0009
2013-11-20 12:09:29,281 INFO mapred.Task (Task.java:initialize(534)) - Using ResourceCalculatorPlugin : org.apache.hadoop.util.LinuxResourceCalculatorPlugin@3f65cebb
2013-11-20 12:09:29,283 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
2013-11-20 12:09:29,284 INFO mapred.MapTask (MapTask.java:runOldMapper(425)) - numReduceTasks: 0
2013-11-20 12:09:29,287 INFO hadoop.FlowMapper (FlowMapper.java:configure(70)) - cascading version: 2.2.0
2013-11-20 12:09:29,288 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - child jvm opts: -Xmx200m
2013-11-20 12:09:29,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(86)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2013-11-20 12:09:29,294 INFO hadoop.FlowMapper (FlowMapper.java:configure(89)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2013-11-20 12:09:29,297 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-0.20.205.0/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-11-20 12:09:29,299 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-0.20.205.0/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-11-20 12:09:29,301 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/d1f96f51023738a5/apache-0.20.205.0/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-11-20 12:09:29,310 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [pipe] task completion events identify failed tasks
2013-11-20 12:09:29,311 WARN flow.FlowStep (BaseFlowStep.java:logWarn(747)) - [pipe] task completion events count: 0
2013-11-20 12:09:29,311 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] stopping all jobs
2013-11-20 12:09:29,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(742)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2013-11-20 12:09:29,314 INFO flow.Flow (BaseFlow.java:logInfo(1306)) - [pipe] stopped all jobs
2013-11-20 12:09:29,315 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2013-11-20 12:09:29,315 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/d1f96f51023738a5/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic