2016-05-18 05:40:53,358 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(197)) - found 1 test platforms from classpath
2016-05-18 05:40:53,374 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(246)) - adding test: cascading.scheme.TextDelimitedPlatformTest, with platform: hadoop
2016-05-18 05:40:53,400 INFO hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-05-18 05:40:53,658 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(75)) - platform property overrides:
2016-05-18 05:40:53,772 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:53,774 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-18 05:40:53,891 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: B39BEC3EED37483EB6304C56BDD15113
2016-05-18 05:40:54,038 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.104
2016-05-18 05:40:54,041 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:54,041 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-18 05:40:54,207 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.1.0
2016-05-18 05:40:54,208 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:54,209 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-18 05:40:54,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-05-18 05:40:54,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:54,210 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:54,212 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:54,213 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...Char/quoted/speccharfalse
2016-05-18 05:40:54,248 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-05-18 05:40:54,309 WARN snappy.LoadSnappy (LoadSnappy.java:<clinit>(46)) - Snappy native library not loaded
2016-05-18 05:40:54,546 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local210092911_0001
2016-05-18 05:40:54,547 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:54,662 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2016-05-18 05:40:54,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:54,676 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:54,687 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CBD2B4E2FB75486DA81BDC8E72933CBB, ordinal: 0
2016-05-18 05:40:54,709 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-18 05:40:54,709 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-05-18 05:40:54,710 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBD2B4E2FB75486DA81BDC8E72933CBB, mem on start (mb), free: 186, total: 223, max: 672
2016-05-18 05:40:54,725 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CBD2B4E2FB75486DA81BDC8E72933CBB, mem on close (mb), free: 185, total: 223, max: 672
2016-05-18 05:40:54,752 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse/_temporary
2016-05-18 05:40:54,754 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.543
2016-05-18 05:40:54,822 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse
2016-05-18 05:40:54,848 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:54,848 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-18 05:40:54,901 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 05:40:54,902 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:54,902 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-18 05:40:54,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:54,922 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:54,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-05-18 05:40:54,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:54,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:54,923 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:54,924 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...xtAll/quoted/normchartrue
2016-05-18 05:40:55,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local511684534_0002
2016-05-18 05:40:55,020 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:55,027 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt
2016-05-18 05:40:55,034 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:55,034 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:55,049 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CC5C3B854A1D49259202BB6DFD269233, ordinal: 0
2016-05-18 05:40:55,050 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:55,050 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-05-18 05:40:55,051 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC5C3B854A1D49259202BB6DFD269233, mem on start (mb), free: 171, total: 223, max: 672
2016-05-18 05:40:55,055 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CC5C3B854A1D49259202BB6DFD269233, mem on close (mb), free: 171, total: 223, max: 672
2016-05-18 05:40:55,073 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue/_temporary
2016-05-18 05:40:55,073 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.150
2016-05-18 05:40:55,150 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue
2016-05-18 05:40:55,172 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:55,172 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-18 05:40:55,242 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2016-05-18 05:40:55,244 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:55,244 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-18 05:40:55,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:55,266 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-18 05:40:55,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-05-18 05:40:55,267 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:55,268 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:55,268 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:55,269 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...arAll/quoted/specchartrue
2016-05-18 05:40:55,340 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1338588772_0003
2016-05-18 05:40:55,341 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:55,348 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt
2016-05-18 05:40:55,356 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:55,356 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:55,374 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AE7CC39AE20047A284BE75B5B92E002D, ordinal: 0
2016-05-18 05:40:55,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-spec-char.txt"]
2016-05-18 05:40:55,375 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-05-18 05:40:55,376 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE7CC39AE20047A284BE75B5B92E002D, mem on start (mb), free: 157, total: 223, max: 672
2016-05-18 05:40:55,379 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AE7CC39AE20047A284BE75B5B92E002D, mem on close (mb), free: 157, total: 223, max: 672
2016-05-18 05:40:55,394 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue/_temporary
2016-05-18 05:40:55,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.127
2016-05-18 05:40:55,458 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue
2016-05-18 05:40:55,468 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:55,469 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-18 05:40:55,508 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 05:40:55,509 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:55,509 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-18 05:40:55,526 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:55,526 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:55,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall"]
2016-05-18 05:40:55,527 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:55,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:55,528 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:55,529 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...m/testHeaderAll/headerall
2016-05-18 05:40:55,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local188252110_0004
2016-05-18 05:40:55,574 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:55,578 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt
2016-05-18 05:40:55,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:55,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:55,590 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF6F33DF41CF423492D66238BE417F00, ordinal: 0
2016-05-18 05:40:55,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:55,591 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall"]
2016-05-18 05:40:55,591 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF6F33DF41CF423492D66238BE417F00, mem on start (mb), free: 202, total: 223, max: 672
2016-05-18 05:40:55,593 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF6F33DF41CF423492D66238BE417F00, mem on close (mb), free: 202, total: 223, max: 672
2016-05-18 05:40:55,606 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall/_temporary
2016-05-18 05:40:55,606 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.080
2016-05-18 05:40:55,619 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testHeaderAll/headerall
2016-05-18 05:40:55,631 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:55,632 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-18 05:40:55,683 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2016-05-18 05:40:55,684 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:55,685 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-18 05:40:55,697 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:55,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:55,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-05-18 05:40:55,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:55,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:55,698 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:55,699 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...Text/quoted/normcharfalse
2016-05-18 05:40:55,742 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local644681204_0005
2016-05-18 05:40:55,743 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:55,746 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt
2016-05-18 05:40:55,750 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:55,751 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:55,763 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F4D9C443026B4147B9DAEDF8DA0ABE9C, ordinal: 0
2016-05-18 05:40:55,765 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:55,765 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-05-18 05:40:55,766 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4D9C443026B4147B9DAEDF8DA0ABE9C, mem on start (mb), free: 191, total: 223, max: 672
2016-05-18 05:40:55,769 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F4D9C443026B4147B9DAEDF8DA0ABE9C, mem on close (mb), free: 191, total: 223, max: 672
2016-05-18 05:40:55,785 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse/_temporary
2016-05-18 05:40:55,785 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.087
2016-05-18 05:40:55,811 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse
2016-05-18 05:40:56,010 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:56,011 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-18 05:40:56,052 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-05-18 05:40:56,053 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:56,053 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-18 05:40:56,076 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:56,076 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-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-18 05:40:56,077 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-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-05-18 05:40:56,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:56,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:56,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:56,077 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...oercion/testFieldCoercion
2016-05-18 05:40:56,111 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1168956804_0006
2016-05-18 05:40:56,112 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:56,116 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/apache-clean.10.txt
2016-05-18 05:40:56,120 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:56,120 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:56,131 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C400ADEEEED54B39938D24126DE066D4, ordinal: 0
2016-05-18 05:40:56,138 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-1.2.x/build/classes/test/data/apache-clean.10.txt"]
2016-05-18 05:40:56,138 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-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-05-18 05:40:56,138 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C400ADEEEED54B39938D24126DE066D4, mem on start (mb), free: 168, total: 223, max: 672
2016-05-18 05:40:56,217 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C400ADEEEED54B39938D24126DE066D4, mem on close (mb), free: 164, total: 223, max: 672
2016-05-18 05:40:56,234 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion/_temporary
2016-05-18 05:40:56,234 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.159
2016-05-18 05:40:56,245 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion
2016-05-18 05:40:56,255 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:56,255 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-18 05:40:56,303 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2016-05-18 05:40:56,305 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:56,305 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-18 05:40:56,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:56,321 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2016-05-18 05:40:56,322 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-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-05-18 05:40:56,322 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:56,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:56,323 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:56,333 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...A70A84745ACD1C6EB0AC646AB
2016-05-18 05:40:56,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local660079692_0007
2016-05-18 05:40:56,394 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:56,397 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-header.txt
2016-05-18 05:40:56,399 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:56,399 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:56,406 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CE12BCE4629346A4AB66AB3077138C2D, ordinal: 0
2016-05-18 05:40:56,407 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-header.txt"]
2016-05-18 05:40:56,407 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-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-05-18 05:40:56,407 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE12BCE4629346A4AB66AB3077138C2D, mem on start (mb), free: 209, total: 223, max: 672
2016-05-18 05:40:56,408 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-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"]
2016-05-18 05:40:56,411 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local660079692_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local660079692_0007_m_000000_0
2016-05-18 05:40:56,411 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-18 05:40:56,414 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-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]
2016-05-18 05:40:56,415 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local660079692_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local660079692_0007_m_000000_0
2016-05-18 05:40:56,415 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-05-18 05:40:56,420 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/part-00000
2016-05-18 05:40:56,420 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local660079692_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local660079692_0007_m_000000_0
2016-05-18 05:40:56,422 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local660079692_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-05-18 05:40:56,422 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/part-00000
2016-05-18 05:40:56,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local660079692_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local660079692_0007_m_000000_0
2016-05-18 05:40:56,425 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local660079692_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-05-18 05:40:56,425 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CE12BCE4629346A4AB66AB3077138C2D, mem on close (mb), free: 207, total: 223, max: 672
2016-05-18 05:40:56,440 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.119
2016-05-18 05:40:56,466 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-05-18 05:40:56,466 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-05-18 05:40:56,474 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:56,474 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-18 05:40:56,500 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2016-05-18 05:40:56,501 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:56,501 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-18 05:40:56,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:56,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:56,512 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeader/header"]
2016-05-18 05:40:56,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:56,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:56,513 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:56,515 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...latform/testHeader/header
2016-05-18 05:40:56,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1211647395_0008
2016-05-18 05:40:56,545 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:56,550 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt
2016-05-18 05:40:56,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:56,554 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:56,562 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FEA1041EF1434382B14B0B1C1C9E9D7A, ordinal: 0
2016-05-18 05:40:56,562 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited.txt"]
2016-05-18 05:40:56,563 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeader/header"]
2016-05-18 05:40:56,563 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEA1041EF1434382B14B0B1C1C9E9D7A, mem on start (mb), free: 194, total: 223, max: 672
2016-05-18 05:40:56,565 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEA1041EF1434382B14B0B1C1C9E9D7A, mem on close (mb), free: 194, total: 223, max: 672
2016-05-18 05:40:56,581 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testHeader/header/_temporary
2016-05-18 05:40:56,581 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.068
2016-05-18 05:40:56,590 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testHeader/header
2016-05-18 05:40:56,599 INFO util.Util (Util.java:findMainClass(1374)) - using default application jar, may cause class not found exceptions on the cluster
2016-05-18 05:40:56,599 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-18 05:40:56,626 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2016-05-18 05:40:56,627 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-05-18 05:40:56,628 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-18 05:40:56,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting
2016-05-18 05:40:56,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2016-05-18 05:40:56,637 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-05-18 05:40:56,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] parallel execution of steps is enabled: false
2016-05-18 05:40:56,638 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] executing total steps: 1
2016-05-18 05:40:56,639 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] allocating management threads: 1
2016-05-18 05:40:56,640 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] starting step: (1/1) ...t/strict-nondeterministic
2016-05-18 05:40:56,667 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] submitted hadoop job: job_local1542266782_0009
2016-05-18 05:40:56,667 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] tracking url: http://localhost:8080/
2016-05-18 05:40:56,672 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
2016-05-18 05:40:56,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.1.0
2016-05-18 05:40:56,675 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-05-18 05:40:56,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B9FACB64F1C74C84A5777BB52DF3A3FA, ordinal: 0
2016-05-18 05:40:56,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt"]
2016-05-18 05:40:56,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-05-18 05:40:56,682 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9FACB64F1C74C84A5777BB52DF3A3FA, mem on start (mb), free: 182, total: 223, max: 672
2016-05-18 05:40:56,685 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-1.2.x/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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
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)
... 11 more
2016-05-18 05:40:56,686 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-1.2.x/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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
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)
... 11 more
2016-05-18 05:40:56,687 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B9FACB64F1C74C84A5777BB52DF3A3FA, mem on close (mb), free: 182, total: 223, max: 672
2016-05-18 05:40:56,688 WARN mapred.LocalJobRunner (LocalJobRunner.java:run(435)) - job_local1542266782_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/classes/test/data/delimited-extra-field.txt
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:354)
Caused by: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/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:430)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:366)
at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:223)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
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)
... 11 more
2016-05-18 05:40:56,691 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] hadoop job job_local1542266782_0009 state at FAILED
2016-05-18 05:40:56,691 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] failure info: NA
2016-05-18 05:40:56,692 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] task completion events identify failed tasks
2016-05-18 05:40:56,692 WARN flow.Flow (BaseFlow.java:logWarn(1516)) - [pipe] task completion events count: 0
2016-05-18 05:40:56,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopping all jobs
2016-05-18 05:40:56,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopping: (1/1) ...t/strict-nondeterministic
2016-05-18 05:40:56,693 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] stopped all jobs
2016-05-18 05:40:56,694 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic/_temporary
2016-05-18 05:40:56,694 INFO flow.Flow (BaseFlow.java:logInfo(1504)) - [pipe] completed in: 00:00.056
2016-05-18 05:40:56,694 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/ddea2c91addb6250/apache-1.2.x/build/test/output//hadoop/textdelimitedplatform/testStrict/strict-nondeterministic