2015-08-13 23:21:56,331 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-13 23:21:56,378 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop
2015-08-13 23:21:56,379 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.scheme.TextDelimitedPlatformTest
2015-08-13 23:21:56,412 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(112)) - not using cluster
2015-08-13 23:21:56,714 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-13 23:21:56,841 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:56,843 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 23:21:56,856 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 3DF168C981B64EF5B9AA2D485FFE5D63
2015-08-13 23:21:57,067 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-13 23:21:57,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:57,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 23:21:57,070 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2015-08-13 23:21:57,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:57,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:57,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:57,074 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/speccharfalse
2015-08-13 23:21:57,125 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 23:21:57,193 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2015-08-13 23:21:57,446 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0001
2015-08-13 23:21:57,448 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:57,538 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-spec-char.txt
2015-08-13 23:21:57,558 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:57,559 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:57,599 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 23:21:57,600 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse"]
2015-08-13 23:21:57,644 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/speccharfalse/_temporary
2015-08-13 23:21:57,729 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/quoted/speccharfalse
2015-08-13 23:21:57,758 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:57,759 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 23:21:57,783 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:57,784 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:57,784 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2015-08-13 23:21:57,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:57,785 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:57,786 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:57,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/normchartrue
2015-08-13 23:21:57,903 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0002
2015-08-13 23:21:57,904 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:57,910 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt
2015-08-13 23:21:57,918 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:57,918 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:57,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:57,930 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue"]
2015-08-13 23:21:57,955 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/normchartrue/_temporary
2015-08-13 23:21:58,026 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/quoted/normchartrue
2015-08-13 23:21:58,048 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:58,049 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 23:21:58,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:58,071 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 23:21:58,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2015-08-13 23:21:58,072 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:58,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:58,073 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:58,075 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tform/quoted/specchartrue
2015-08-13 23:21:58,142 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0003
2015-08-13 23:21:58,142 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:58,149 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-spec-char.txt
2015-08-13 23:21:58,156 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:58,156 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:58,167 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-spec-char.txt"]
2015-08-13 23:21:58,167 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue"]
2015-08-13 23:21:58,184 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/specchartrue/_temporary
2015-08-13 23:21:58,235 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/quoted/specchartrue
2015-08-13 23:21:58,250 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:58,251 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 23:21:58,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:58,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:58,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2015-08-13 23:21:58,274 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:58,275 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:58,275 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:58,277 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...limitedplatform/headerall
2015-08-13 23:21:58,340 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0004
2015-08-13 23:21:58,340 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:58,345 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt
2015-08-13 23:21:58,352 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:58,352 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:58,363 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:58,363 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerall"]
2015-08-13 23:21:58,382 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerall/_temporary
2015-08-13 23:21:58,397 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/headerall
2015-08-13 23:21:58,412 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:58,413 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 23:21:58,432 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:58,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:58,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2015-08-13 23:21:58,434 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:58,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:58,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:58,436 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...form/quoted/normcharfalse
2015-08-13 23:21:58,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0005
2015-08-13 23:21:58,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:58,497 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt
2015-08-13 23:21:58,505 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:58,505 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:58,515 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:58,515 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse"]
2015-08-13 23:21:58,533 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/quoted/normcharfalse/_temporary
2015-08-13 23:21:58,575 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/quoted/normcharfalse
2015-08-13 23:21:58,846 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:58,847 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 23:21:58,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:58,885 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-1.1.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-13 23:21:58,886 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2015-08-13 23:21:58,887 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:58,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:58,889 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:58,890 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...latform/testFieldCoercion
2015-08-13 23:21:58,941 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0006
2015-08-13 23:21:58,942 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:58,947 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/apache-clean.10.txt
2015-08-13 23:21:58,953 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:58,953 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:58,973 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-1.1.x/build/classes/test/data/apache-clean.10.txt"]
2015-08-13 23:21:58,974 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion"]
2015-08-13 23:21:59,094 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/_temporary
2015-08-13 23:21:59,112 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion
2015-08-13 23:21:59,131 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:59,132 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 23:21:59,178 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:59,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-header.txt"]
2015-08-13 23:21:59,181 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2015-08-13 23:21:59,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:59,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:59,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:59,185 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...C999742F4AAE967C1ED3A8C94
2015-08-13 23:21:59,231 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0007
2015-08-13 23:21:59,231 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:59,235 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-header.txt
2015-08-13 23:21:59,238 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:59,238 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:59,248 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-header.txt"]
2015-08-13 23:21:59,249 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]]]
2015-08-13 23:21:59,250 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1"]
2015-08-13 23:21:59,253 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 23:21:59,254 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-08-13 23:21:59,257 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2"]
2015-08-13 23:21:59,260 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 23:21:59,260 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(112)) - creating path: part-00000
2015-08-13 23:21:59,268 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/part-00000
2015-08-13 23:21:59,268 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 23:21:59,271 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall1
2015-08-13 23:21:59,272 INFO io.TapOutputCollector (TapOutputCollector.java:close(145)) - closing tap collector for: /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/part-00000
2015-08-13 23:21:59,274 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(155)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2015-08-13 23:21:59,276 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-1.1.x/build/test/output/hadoop/textdelimitedplatform/headerfieldsall2
2015-08-13 23:21:59,327 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall2
2015-08-13 23:21:59,328 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/headerfieldsall1
2015-08-13 23:21:59,340 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:59,341 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 23:21:59,357 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:59,358 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:59,358 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/header"]
2015-08-13 23:21:59,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:59,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:59,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:59,360 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...tdelimitedplatform/header
2015-08-13 23:21:59,407 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0008
2015-08-13 23:21:59,407 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:59,412 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt
2015-08-13 23:21:59,418 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:59,419 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:59,428 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited.txt"]
2015-08-13 23:21:59,428 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/header"]
2015-08-13 23:21:59,449 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/header/_temporary
2015-08-13 23:21:59,461 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/header
2015-08-13 23:21:59,473 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-13 23:21:59,473 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 23:21:59,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting
2015-08-13 23:21:59,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-extra-field.txt"]
2015-08-13 23:21:59,489 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2015-08-13 23:21:59,489 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] parallel execution is enabled: false
2015-08-13 23:21:59,489 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] starting jobs: 1
2015-08-13 23:21:59,490 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] allocating threads: 1
2015-08-13 23:21:59,490 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] starting step: (1/1) ...m/strict-nondeterministic
2015-08-13 23:21:59,532 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] submitted hadoop job: job_local_0009
2015-08-13 23:21:59,533 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] tracking url: http://localhost:8080/
2015-08-13 23:21:59,537 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-extra-field.txt
2015-08-13 23:21:59,542 INFO hadoop.FlowMapper (FlowMapper.java:configure(71)) - cascading version: 2.7.1
2015-08-13 23:21:59,543 INFO hadoop.FlowMapper (FlowMapper.java:configure(72)) - child jvm opts: -Xmx200m
2015-08-13 23:21:59,549 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/classes/test/data/delimited-extra-field.txt"]
2015-08-13 23:21:59,550 INFO hadoop.FlowMapper (FlowMapper.java:configure(90)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic"]
2015-08-13 23:21:59,554 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-1.1.x/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:214)
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 23:21:59,555 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-1.1.x/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:214)
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 23:21:59,557 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(300)) - job_local_0009
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/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:214)
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 23:21:59,566 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] hadoop job job_local_0009 state at FAILED
2015-08-13 23:21:59,567 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] failure info: NA
2015-08-13 23:21:59,568 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events identify failed tasks
2015-08-13 23:21:59,569 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [pipe] task completion events count: 0
2015-08-13 23:21:59,569 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopping all jobs
2015-08-13 23:21:59,570 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [pipe] stopping: (1/1) ...m/strict-nondeterministic
2015-08-13 23:21:59,570 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [pipe] stopped all jobs
2015-08-13 23:21:59,571 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output/hadoop/textdelimitedplatform/strict-nondeterministic/_temporary
2015-08-13 23:21:59,571 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-1.1.x/build/test/output//hadoop/textdelimitedplatform/strict-nondeterministic