2015-08-13 19:07:37,653 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 19:07:37,703 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 19:07:37,703 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2015-08-13 19:07:37,738 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-13 19:07:38,028 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-13 19:07:38,157 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:38,160 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:38,173 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 5F053E8C1A3442EA86D8CBC7C14E3416
2015-08-13 19:07:38,390 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 19:07:38,392 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:38,392 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 19:07:38,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2015-08-13 19:07:38,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:38,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:38,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:38,395 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2015-08-13 19:07:38,439 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-08-13 19:07:38,691 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0001
2015-08-13 19:07:38,693 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:38,773 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2015-08-13 19:07:38,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:38,791 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:38,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 19:07:38,830 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2015-08-13 19:07:41,754 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2015-08-13 19:07:41,841 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2015-08-13 19:07:41,871 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:41,871 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:41,894 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:41,894 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:07:41,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2015-08-13 19:07:41,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:41,895 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:41,896 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:41,896 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2015-08-13 19:07:42,001 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0002
2015-08-13 19:07:42,004 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:42,010 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt
2015-08-13 19:07:42,017 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:42,018 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:42,029 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:07:42,029 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2015-08-13 19:07:45,021 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2015-08-13 19:07:45,089 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2015-08-13 19:07:45,111 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:45,111 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:45,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:45,133 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 19:07:45,133 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2015-08-13 19:07:45,134 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:45,135 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:45,135 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:45,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2015-08-13 19:07:45,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0003
2015-08-13 19:07:45,215 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:45,221 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2015-08-13 19:07:45,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:45,228 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:45,239 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 19:07:45,239 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2015-08-13 19:07:48,233 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2015-08-13 19:07:48,276 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2015-08-13 19:07:48,291 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:48,292 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:48,312 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:48,313 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:07:48,313 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall"]
2015-08-13 19:07:48,314 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:48,314 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:48,314 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:48,316 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2015-08-13 19:07:48,375 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0004
2015-08-13 19:07:48,376 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:48,382 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt
2015-08-13 19:07:48,389 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:48,389 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:48,398 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:07:48,399 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall"]
2015-08-13 19:07:51,405 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2015-08-13 19:07:51,420 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/headerall
2015-08-13 19:07:51,435 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:51,436 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:51,453 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:51,454 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:07:51,454 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2015-08-13 19:07:51,455 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:51,455 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:51,455 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:51,456 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2015-08-13 19:07:51,510 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0005
2015-08-13 19:07:51,511 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:51,516 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt
2015-08-13 19:07:51,522 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:51,523 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:51,532 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:07:51,532 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2015-08-13 19:07:54,528 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2015-08-13 19:07:54,566 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2015-08-13 19:07:54,812 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:54,813 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:54,850 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:54,850 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [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/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2015-08-13 19:07:54,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [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/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2015-08-13 19:07:54,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:54,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:54,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:54,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2015-08-13 19:07:54,900 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0006
2015-08-13 19:07:54,900 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:54,906 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt
2015-08-13 19:07:54,911 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:54,912 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:54,932 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2015-08-13 19:07:54,932 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2015-08-13 19:07:57,916 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2015-08-13 19:07:57,932 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2015-08-13 19:07:57,962 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:07:57,962 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:07:58,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:07:58,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2015-08-13 19:07:58,007 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2015-08-13 19:07:58,008 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:07:58,008 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:07:58,008 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:07:58,010 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...964D142F3938F71A1A20D3B19
2015-08-13 19:07:58,054 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0007
2015-08-13 19:07:58,056 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:07:58,061 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-header.txt
2015-08-13 19:07:58,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:07:58,063 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:07:58,073 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2015-08-13 19:07:58,074 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2015-08-13 19:07:58,075 INFO tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"]
2015-08-13 19:07:58,078 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 19:07:58,079 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-08-13 19:07:58,083 INFO tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]
2015-08-13 19:07:58,085 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(98)) - setting up task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 19:07:58,085 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-08-13 19:07:58,093 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/part-00000
2015-08-13 19:07:58,094 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 19:07:58,098 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1
2015-08-13 19:07:58,099 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/part-00000
2015-08-13 19:07:58,099 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 19:07:58,102 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(172)) - saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2
2015-08-13 19:08:01,112 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/headerfieldsall2
2015-08-13 19:08:01,112 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/headerfieldsall1
2015-08-13 19:08:01,125 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:08:01,125 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:08:01,142 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:08:01,143 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:08:01,143 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header"]
2015-08-13 19:08:01,144 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:08:01,144 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:08:01,144 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:08:01,146 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2015-08-13 19:08:01,190 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0008
2015-08-13 19:08:01,191 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:08:01,196 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt
2015-08-13 19:08:01,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:08:01,202 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:08:01,211 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2015-08-13 19:08:01,212 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header"]
2015-08-13 19:08:04,208 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2015-08-13 19:08:04,222 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/header
2015-08-13 19:08:04,234 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 19:08:04,235 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/2.7.1/e28a477e50cd8946adea60fa2bb90b57eaf07ef3/cascading-hadoop-2.7.1.jar
2015-08-13 19:08:04,250 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 19:08:04,250 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2015-08-13 19:08:04,251 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2015-08-13 19:08:04,251 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 19:08:04,252 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 19:08:04,252 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 19:08:04,252 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2015-08-13 19:08:04,293 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0009
2015-08-13 19:08:04,294 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 19:08:04,298 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
2015-08-13 19:08:04,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 19:08:04,303 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 19:08:04,310 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2015-08-13 19:08:04,311 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2015-08-13 19:08:04,314 ERROR stream.TrapHandler (TrapHandler.java:handleReThrowableException(155)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java: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:404)
at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
... 6 more
2015-08-13 19:08:04,316 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/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java: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:404)
at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
... 6 more
2015-08-13 19:08:04,318 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/8c57748d0461e126/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
at cascading.flow.stream.SourceStage.map(SourceStage.java:76)
at cascading.flow.stream.SourceStage.run(SourceStage.java:58)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:130)
at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java: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:404)
at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
... 6 more
2015-08-13 19:08:04,326 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] hadoop job job_local_0009 state at FAILED
2015-08-13 19:08:04,327 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] failure info: NA
2015-08-13 19:08:04,331 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events identify failed tasks
2015-08-13 19:08:04,332 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events count: 0
2015-08-13 19:08:04,333 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopping all jobs
2015-08-13 19:08:04,333 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2015-08-13 19:08:04,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopped all jobs
2015-08-13 19:08:04,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] shutting down job executor
2015-08-13 19:08:04,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] shutdown complete
2015-08-13 19:08:04,335 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2015-08-13 19:08:04,335 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic