2016-05-17 22:59:10,723 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-17 22:59:10,739 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.scheme.TextDelimitedPlatformTest, with platform: hadoop
2016-05-17 22:59:10,764 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-17 22:59:10,990 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-17 22:59:11,093 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:11,095 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:11,196 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 82F4CC19B668407CAE79E68D1D2D590B
2016-05-17 22:59:11,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-05-17 22:59:11,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:11,325 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:11,492 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-17 22:59:11,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:11,494 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:59:11,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-05-17 22:59:11,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:11,495 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:11,497 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:11,498 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...Char/quoted/speccharfalse
2016-05-17 22:59:11,529 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-17 22:59:11,786 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0001
2016-05-17 22:59:11,787 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:11,850 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2016-05-17 22:59:11,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:11,864 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:11,877 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FD833AD2CBCC42B986874B93FECE3B0A, ordinal: 0
2016-05-17 22:59:11,901 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:59:11,902 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-05-17 22:59:11,903 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD833AD2CBCC42B986874B93FECE3B0A, mem on start (mb), free: 190, total: 223, max: 672
2016-05-17 22:59:11,918 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FD833AD2CBCC42B986874B93FECE3B0A, mem on close (mb), free: 189, total: 223, max: 672
2016-05-17 22:59:14,833 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse/_temporary
2016-05-17 22:59:14,835 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.338
2016-05-17 22:59:14,915 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse
2016-05-17 22:59:14,948 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:14,949 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:15,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2016-05-17 22:59:15,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:15,007 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:15,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:15,026 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:15,027 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-05-17 22:59:15,028 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:15,029 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:15,030 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:15,032 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...xtAll/quoted/normchartrue
2016-05-17 22:59:15,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0002
2016-05-17 22:59:15,128 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:15,134 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-05-17 22:59:15,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:15,139 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:15,150 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ED80912600D346969593EE01D969EA1C, ordinal: 0
2016-05-17 22:59:15,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:15,152 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-05-17 22:59:15,153 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED80912600D346969593EE01D969EA1C, mem on start (mb), free: 178, total: 223, max: 672
2016-05-17 22:59:15,157 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ED80912600D346969593EE01D969EA1C, mem on close (mb), free: 178, total: 223, max: 672
2016-05-17 22:59:18,144 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue/_temporary
2016-05-17 22:59:18,145 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.117
2016-05-17 22:59:18,209 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue
2016-05-17 22:59:18,231 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:18,232 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:18,295 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2016-05-17 22:59:18,298 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:18,299 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:18,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:18,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:59:18,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-05-17 22:59:18,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:18,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:18,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:18,324 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...arAll/quoted/specchartrue
2016-05-17 22:59:18,407 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0003
2016-05-17 22:59:18,408 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:18,414 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2016-05-17 22:59:18,419 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:18,419 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:18,434 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D836939E45F14963AB655A6B22B6404D, ordinal: 0
2016-05-17 22:59:18,435 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-05-17 22:59:18,436 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-05-17 22:59:18,436 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D836939E45F14963AB655A6B22B6404D, mem on start (mb), free: 166, total: 223, max: 672
2016-05-17 22:59:18,439 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D836939E45F14963AB655A6B22B6404D, mem on close (mb), free: 166, total: 223, max: 672
2016-05-17 22:59:21,422 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue/_temporary
2016-05-17 22:59:21,423 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.100
2016-05-17 22:59:21,454 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue
2016-05-17 22:59:21,467 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:21,467 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:21,506 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2016-05-17 22:59:21,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:21,507 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:21,523 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:21,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:21,524 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall"]
2016-05-17 22:59:21,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:21,525 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:21,526 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:21,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...m/testHeaderAll/headerall
2016-05-17 22:59:21,568 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0004
2016-05-17 22:59:21,582 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:21,593 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-05-17 22:59:21,598 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:21,598 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:21,607 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B3D365714CB2401E8DF2026EE3A3F6A7, ordinal: 0
2016-05-17 22:59:21,607 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:21,608 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall"]
2016-05-17 22:59:21,608 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3D365714CB2401E8DF2026EE3A3F6A7, mem on start (mb), free: 214, total: 223, max: 672
2016-05-17 22:59:21,610 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B3D365714CB2401E8DF2026EE3A3F6A7, mem on close (mb), free: 214, total: 223, max: 672
2016-05-17 22:59:24,606 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall/_temporary
2016-05-17 22:59:24,607 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.082
2016-05-17 22:59:24,616 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeaderAll/headerall
2016-05-17 22:59:24,625 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:24,626 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:24,660 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-05-17 22:59:24,661 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:24,661 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:24,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:24,671 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:24,672 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-05-17 22:59:24,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:24,673 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:24,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:24,674 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...Text/quoted/normcharfalse
2016-05-17 22:59:24,709 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0005
2016-05-17 22:59:24,712 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:24,715 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-05-17 22:59:24,720 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:24,720 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:24,729 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D58F6A00360A4A8F996C5719151DA1EC, ordinal: 0
2016-05-17 22:59:24,729 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:24,730 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-05-17 22:59:24,730 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D58F6A00360A4A8F996C5719151DA1EC, mem on start (mb), free: 204, total: 223, max: 672
2016-05-17 22:59:24,733 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D58F6A00360A4A8F996C5719151DA1EC, mem on close (mb), free: 204, total: 223, max: 672
2016-05-17 22:59:27,726 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse/_temporary
2016-05-17 22:59:27,727 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.055
2016-05-17 22:59:27,751 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse
2016-05-17 22:59:27,957 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:27,958 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:28,003 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2016-05-17 22:59:28,005 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:28,006 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:28,039 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:28,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2016-05-17 22:59:28,040 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-05-17 22:59:28,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:28,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:28,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:28,042 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...oercion/testFieldCoercion
2016-05-17 22:59:28,086 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0006
2016-05-17 22:59:28,087 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:28,091 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt
2016-05-17 22:59:28,095 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:28,096 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:28,107 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C279CB6526C74292B56EC7A6E0922E7C, ordinal: 0
2016-05-17 22:59:28,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - 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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2016-05-17 22:59:28,115 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - 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',canonicalType='long'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-05-17 22:59:28,115 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C279CB6526C74292B56EC7A6E0922E7C, mem on start (mb), free: 183, total: 223, max: 672
2016-05-17 22:59:28,199 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C279CB6526C74292B56EC7A6E0922E7C, mem on close (mb), free: 179, total: 223, max: 672
2016-05-17 22:59:31,102 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion/_temporary
2016-05-17 22:59:31,102 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.062
2016-05-17 22:59:31,112 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion
2016-05-17 22:59:31,123 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:31,123 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:31,161 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 22:59:31,162 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:31,163 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:31,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:31,179 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2016-05-17 22:59:31,180 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-05-17 22:59:31,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:31,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:31,181 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:31,183 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...B28D949CA99DEE8D54B24EC5F
2016-05-17 22:59:31,214 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0007
2016-05-17 22:59:31,215 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:31,220 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-header.txt
2016-05-17 22:59:31,222 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:31,222 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:31,233 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B964C645D0184D098575EC5C74A393FD, ordinal: 0
2016-05-17 22:59:31,234 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2016-05-17 22:59:31,235 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-05-17 22:59:31,235 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B964C645D0184D098575EC5C74A393FD, mem on start (mb), free: 169, total: 223, max: 672
2016-05-17 22:59:31,236 INFO tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"]
2016-05-17 22:59:31,238 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2016-05-17 22:59:31,239 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 22:59:31,242 INFO tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]
2016-05-17 22:59:31,243 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2016-05-17 22:59:31,244 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-17 22:59:31,248 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/part-00000
2016-05-17 22:59:31,249 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2016-05-17 22:59:31,251 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-05-17 22:59:31,252 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/part-00000
2016-05-17 22:59:31,252 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2016-05-17 22:59:31,254 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-05-17 22:59:31,255 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B964C645D0184D098575EC5C74A393FD, mem on close (mb), free: 167, total: 223, max: 672
2016-05-17 22:59:34,230 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.050
2016-05-17 22:59:34,257 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-05-17 22:59:34,257 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-05-17 22:59:34,269 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:34,269 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:34,301 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-05-17 22:59:34,303 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:34,303 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:34,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:34,318 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:34,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeader/header"]
2016-05-17 22:59:34,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:34,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:34,319 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:34,320 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...latform/testHeader/header
2016-05-17 22:59:34,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0008
2016-05-17 22:59:34,351 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:34,355 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-05-17 22:59:34,372 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:34,373 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:34,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C814139994F646C7A55558405FA825EA, ordinal: 0
2016-05-17 22:59:34,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-05-17 22:59:34,382 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeader/header"]
2016-05-17 22:59:34,383 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C814139994F646C7A55558405FA825EA, mem on start (mb), free: 214, total: 223, max: 672
2016-05-17 22:59:34,386 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C814139994F646C7A55558405FA825EA, mem on close (mb), free: 214, total: 223, max: 672
2016-05-17 22:59:37,360 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeader/header/_temporary
2016-05-17 22:59:37,361 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:03.042
2016-05-17 22:59:37,369 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeader/header
2016-05-17 22:59:37,377 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-17 22:59:37,377 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(176)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.1.0/86eabf0febb15d07d5285b321b1f6b06e25aa664/cascading-hadoop-3.1.0.jar
2016-05-17 22:59:37,404 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2016-05-17 22:59:37,404 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-17 22:59:37,405 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-05-17 22:59:37,413 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-17 22:59:37,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2016-05-17 22:59:37,414 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-05-17 22:59:37,415 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-17 22:59:37,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-17 22:59:37,416 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-17 22:59:37,417 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...t/strict-nondeterministic
2016-05-17 22:59:37,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local_0009
2016-05-17 22:59:37,452 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-17 22:59:37,456 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
2016-05-17 22:59:37,459 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-17 22:59:37,459 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-17 22:59:37,466 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B674FCDBBCE6403BA3A499537A37BD2F, ordinal: 0
2016-05-17 22:59:37,466 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2016-05-17 22:59:37,466 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-05-17 22:59:37,466 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B674FCDBBCE6403BA3A499537A37BD2F, mem on start (mb), free: 204, total: 223, max: 672
2016-05-17 22:59:37,469 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/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.element.SourceStage.map(SourceStage.java:84)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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
2016-05-17 22:59:37,471 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/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.element.SourceStage.map(SourceStage.java:84)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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
2016-05-17 22:59:37,472 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B674FCDBBCE6403BA3A499537A37BD2F, mem on close (mb), free: 204, total: 223, max: 672
2016-05-17 22:59:37,473 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/ddea2c91addb6250/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.element.SourceStage.map(SourceStage.java:84)
at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
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
2016-05-17 22:59:37,483 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] hadoop job job_local_0009 state at FAILED
2016-05-17 22:59:37,483 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] failure info: NA
2016-05-17 22:59:37,484 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] task completion events identify failed tasks
2016-05-17 22:59:37,484 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] task completion events count: 0
2016-05-17 22:59:37,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopping all jobs
2016-05-17 22:59:37,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopping: (1/1) ...t/strict-nondeterministic
2016-05-17 22:59:37,485 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopped all jobs
2016-05-17 22:59:37,486 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic/_temporary
2016-05-17 22:59:37,486 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.072
2016-05-17 22:59:37,486 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testStrict/strict-nondeterministic