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