Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

0

ignored

5.266s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.448s passed
testHeader 0.274s passed
testHeaderAll 0.277s passed
testHeaderFieldsAll 0.334s passed
testQuotedText 0.334s passed
testQuotedTextAll 0.441s passed
testQuotedTextSpecChar 2.409s passed
testQuotedTextSpecCharAll 0.496s passed
testStrict 0.253s passed

Standard output

2016-01-14 21:31:43,140 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 21:31:43,169 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.scheme.TextDelimitedPlatformTest, with platform: hadoop2-mr1
2016-01-14 21:31:43,202 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2016-01-14 21:31:43,844 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 21:31:44,025 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 21:31:44,158 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:44,161 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:44,270 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 810DA82C5E0B4C3DB3AE43AEB500390D
2016-01-14 21:31:44,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.120
2016-01-14 21:31:44,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:44,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:44,596 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 21:31:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:44,598 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 21:31:44,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-01-14 21:31:44,599 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:44,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:44,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:44,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...Char/quoted/speccharfalse
2016-01-14 21:31:45,118 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity2071532648/.staging/job_local2071532648_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:45,127 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity2071532648/.staging/job_local2071532648_0001/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:45,300 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2071532648_0001/job_local2071532648_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:45,304 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2071532648_0001/job_local2071532648_0001.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:45,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local2071532648_0001
2016-01-14 21:31:45,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:45,391 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-spec-char.txt
2016-01-14 21:31:45,411 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:45,412 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:45,424 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F65CD6AB20224D678078E8B89C15BB05, ordinal: 0
2016-01-14 21:31:45,445 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 21:31:45,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-01-14 21:31:45,446 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F65CD6AB20224D678078E8B89C15BB05, mem on start (mb), free: 247, total: 281, max: 672
2016-01-14 21:31:45,462 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F65CD6AB20224D678078E8B89C15BB05, mem on close (mb), free: 246, total: 281, max: 672
2016-01-14 21:31:45,502 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse/_temporary
2016-01-14 21:31:45,503 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.904
2016-01-14 21:31:45,608 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse
2016-01-14 21:31:45,633 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:45,634 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:45,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2016-01-14 21:31:45,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:45,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:45,704 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:45,704 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:45,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-01-14 21:31:45,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:45,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:45,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:45,706 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...xtAll/quoted/normchartrue
2016-01-14 21:31:45,783 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1105235139/.staging/job_local1105235139_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:45,784 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1105235139/.staging/job_local1105235139_0002/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:45,857 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1105235139_0002/job_local1105235139_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:45,860 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1105235139_0002/job_local1105235139_0002.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:45,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local1105235139_0002
2016-01-14 21:31:45,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:45,870 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt
2016-01-14 21:31:45,881 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:45,881 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:45,890 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B5129A9F976D46138F69271F9EF61B4C, ordinal: 0
2016-01-14 21:31:45,890 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:45,891 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-01-14 21:31:45,891 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5129A9F976D46138F69271F9EF61B4C, mem on start (mb), free: 193, total: 281, max: 672
2016-01-14 21:31:45,896 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B5129A9F976D46138F69271F9EF61B4C, mem on close (mb), free: 192, total: 281, max: 672
2016-01-14 21:31:45,918 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue/_temporary
2016-01-14 21:31:45,918 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.213
2016-01-14 21:31:46,050 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue
2016-01-14 21:31:46,088 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:46,089 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:46,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2016-01-14 21:31:46,153 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:46,154 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:46,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:46,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 21:31:46,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-01-14 21:31:46,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:46,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:46,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:46,179 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...arAll/quoted/specchartrue
2016-01-14 21:31:46,315 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity2112327084/.staging/job_local2112327084_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:46,319 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity2112327084/.staging/job_local2112327084_0003/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:46,413 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2112327084_0003/job_local2112327084_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:46,415 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local2112327084_0003/job_local2112327084_0003.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:46,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local2112327084_0003
2016-01-14 21:31:46,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:46,424 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-spec-char.txt
2016-01-14 21:31:46,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:46,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:46,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DF7B8BE75F5D473F8270B2A80977E5F5, ordinal: 0
2016-01-14 21:31:46,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 21:31:46,447 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-01-14 21:31:46,447 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF7B8BE75F5D473F8270B2A80977E5F5, mem on start (mb), free: 256, total: 281, max: 672
2016-01-14 21:31:46,450 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DF7B8BE75F5D473F8270B2A80977E5F5, mem on close (mb), free: 256, total: 281, max: 672
2016-01-14 21:31:46,472 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue/_temporary
2016-01-14 21:31:46,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.295
2016-01-14 21:31:46,547 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue
2016-01-14 21:31:46,562 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:46,563 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:46,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 21:31:46,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:46,605 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:46,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:46,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:46,619 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall"]
2016-01-14 21:31:46,620 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:46,620 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:46,620 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:46,620 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...m/testHeaderAll/headerall
2016-01-14 21:31:46,702 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1140793574/.staging/job_local1140793574_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:46,702 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1140793574/.staging/job_local1140793574_0004/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:46,744 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1140793574_0004/job_local1140793574_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:46,745 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1140793574_0004/job_local1140793574_0004.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:46,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local1140793574_0004
2016-01-14 21:31:46,745 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:46,755 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt
2016-01-14 21:31:46,764 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:46,764 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:46,772 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A9F0EA76B3B042D1B56A41AD5D38C431, ordinal: 0
2016-01-14 21:31:46,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:46,773 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall"]
2016-01-14 21:31:46,773 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9F0EA76B3B042D1B56A41AD5D38C431, mem on start (mb), free: 202, total: 281, max: 672
2016-01-14 21:31:46,776 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A9F0EA76B3B042D1B56A41AD5D38C431, mem on close (mb), free: 202, total: 281, max: 672
2016-01-14 21:31:46,794 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall/_temporary
2016-01-14 21:31:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.175
2016-01-14 21:31:46,824 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall
2016-01-14 21:31:46,841 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:46,841 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:46,873 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2016-01-14 21:31:46,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:46,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:46,887 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:46,887 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:46,887 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-01-14 21:31:46,888 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:46,888 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:46,888 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:46,889 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...Text/quoted/normcharfalse
2016-01-14 21:31:46,964 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1132009825/.staging/job_local1132009825_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:46,965 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1132009825/.staging/job_local1132009825_0005/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:47,013 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1132009825_0005/job_local1132009825_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:47,014 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1132009825_0005/job_local1132009825_0005.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:47,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local1132009825_0005
2016-01-14 21:31:47,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:47,021 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt
2016-01-14 21:31:47,030 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:47,030 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:47,042 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A89C702BA8234C17997B5881A4EDC2BA, ordinal: 0
2016-01-14 21:31:47,043 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:47,044 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-01-14 21:31:47,044 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A89C702BA8234C17997B5881A4EDC2BA, mem on start (mb), free: 159, total: 281, max: 672
2016-01-14 21:31:47,048 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A89C702BA8234C17997B5881A4EDC2BA, mem on close (mb), free: 159, total: 281, max: 672
2016-01-14 21:31:47,073 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse/_temporary
2016-01-14 21:31:47,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.187
2016-01-14 21:31:47,158 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse
2016-01-14 21:31:47,282 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:47,282 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:47,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 21:31:47,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:47,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:47,342 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:47,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/apache-clean.10.txt"]
2016-01-14 21:31:47,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['ip', 'client', 'user', 'date', 'request', 'code', 'bytes', 'referrer', 'agent', 'na' | String, String, String, DateType{dateFormatString='dd/MMM/yyyy:HH:mm:ss Z'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-01-14 21:31:47,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:47,343 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:47,344 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:47,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...oercion/testFieldCoercion
2016-01-14 21:31:47,406 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity906510214/.staging/job_local906510214_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:47,407 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity906510214/.staging/job_local906510214_0006/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:47,447 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local906510214_0006/job_local906510214_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:47,449 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local906510214_0006/job_local906510214_0006.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:47,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local906510214_0006
2016-01-14 21:31:47,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:47,461 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/apache-clean.10.txt
2016-01-14 21:31:47,472 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:47,472 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:47,485 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AC70752332D94E4885F17E432396BCE1, ordinal: 0
2016-01-14 21:31:47,492 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'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/apache-clean.10.txt"]
2016-01-14 21:31:47,492 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'}, String, int, long, String, String, String]]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-01-14 21:31:47,492 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC70752332D94E4885F17E432396BCE1, mem on start (mb), free: 320, total: 397, max: 672
2016-01-14 21:31:47,566 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AC70752332D94E4885F17E432396BCE1, mem on close (mb), free: 318, total: 397, max: 672
2016-01-14 21:31:47,582 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion/_temporary
2016-01-14 21:31:47,583 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.240
2016-01-14 21:31:47,608 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion
2016-01-14 21:31:47,624 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:47,625 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:47,673 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2016-01-14 21:31:47,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:47,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:47,696 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:47,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-header.txt"]
2016-01-14 21:31:47,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-01-14 21:31:47,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:47,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:47,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:47,698 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...759D547B8A23E3A3731B54592
2016-01-14 21:31:47,755 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1511926110/.staging/job_local1511926110_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:47,756 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity1511926110/.staging/job_local1511926110_0007/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:47,791 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1511926110_0007/job_local1511926110_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:47,792 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local1511926110_0007/job_local1511926110_0007.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:47,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local1511926110_0007
2016-01-14 21:31:47,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:47,801 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-header.txt
2016-01-14 21:31:47,803 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:47,803 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:47,810 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: AAE83495F9E64D4BBF5BD8FDF612B654, ordinal: 0
2016-01-14 21:31:47,811 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-header.txt"]
2016-01-14 21:31:47,811 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-01-14 21:31:47,811 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAE83495F9E64D4BBF5BD8FDF612B654, mem on start (mb), free: 260, total: 397, max: 672
2016-01-14 21:31:47,812 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"]
2016-01-14 21:31:47,815 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local1511926110_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local1511926110_0007_m_000000_0
2016-01-14 21:31:47,815 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-01-14 21:31:47,821 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]
2016-01-14 21:31:47,824 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local1511926110_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local1511926110_0007_m_000000_0
2016-01-14 21:31:47,824 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-01-14 21:31:47,832 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/part-00000
2016-01-14 21:31:47,832 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local1511926110_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local1511926110_0007_m_000000_0
2016-01-14 21:31:47,835 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local1511926110_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-01-14 21:31:47,836 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/part-00000
2016-01-14 21:31:47,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local1511926110_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local1511926110_0007_m_000000_0
2016-01-14 21:31:47,838 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local1511926110_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-01-14 21:31:47,839 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: AAE83495F9E64D4BBF5BD8FDF612B654, mem on close (mb), free: 255, total: 397, max: 672
2016-01-14 21:31:47,854 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.157
2016-01-14 21:31:47,941 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-01-14 21:31:47,942 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-01-14 21:31:47,962 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:47,963 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:47,995 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 21:31:47,996 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:47,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:48,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:48,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:48,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header"]
2016-01-14 21:31:48,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:48,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:48,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:48,016 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...latform/testHeader/header
2016-01-14 21:31:48,089 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity435720187/.staging/job_local435720187_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:48,090 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity435720187/.staging/job_local435720187_0008/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:48,139 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local435720187_0008/job_local435720187_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:48,140 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local435720187_0008/job_local435720187_0008.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:48,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local435720187_0008
2016-01-14 21:31:48,142 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:48,148 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt
2016-01-14 21:31:48,156 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:48,156 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:48,165 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A0F2C2F2CD9044E09CB4DB990CC92774, ordinal: 0
2016-01-14 21:31:48,165 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited.txt"]
2016-01-14 21:31:48,166 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header"]
2016-01-14 21:31:48,166 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0F2C2F2CD9044E09CB4DB990CC92774, mem on start (mb), free: 189, total: 397, max: 672
2016-01-14 21:31:48,169 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A0F2C2F2CD9044E09CB4DB990CC92774, mem on close (mb), free: 189, total: 397, max: 672
2016-01-14 21:31:48,188 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header/_temporary
2016-01-14 21:31:48,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.174
2016-01-14 21:31:48,217 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeader/header
2016-01-14 21:31:48,242 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 21:31:48,243 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.4/6099926be810c2c62f4bd24f369d52cdd84cf31d/cascading-hadoop2-mr1-3.0.4.jar
2016-01-14 21:31:48,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2016-01-14 21:31:48,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 21:31:48,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2016-01-14 21:31:48,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 21:31:48,288 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-extra-field.txt"]
2016-01-14 21:31:48,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-01-14 21:31:48,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 21:31:48,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 21:31:48,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 21:31:48,290 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...t/strict-nondeterministic
2016-01-14 21:31:48,387 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity196365896/.staging/job_local196365896_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:48,388 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/tmp/cascading/staging/teamcity196365896/.staging/job_local196365896_0009/job.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:48,423 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local196365896_0009/job_local196365896_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.retry.interval;  Ignoring.
2016-01-14 21:31:48,424 WARN  conf.Configuration (Configuration.java:loadProperty(2358)) - file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/tmp/mapred/local/localRunner/teamcity/job_local196365896_0009/job_local196365896_0009.xml:an attempt to override final parameter: mapreduce.job.end-notification.max.attempts;  Ignoring.
2016-01-14 21:31:48,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local196365896_0009
2016-01-14 21:31:48,425 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 21:31:48,430 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-extra-field.txt
2016-01-14 21:31:48,437 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 21:31:48,437 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 21:31:48,445 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A7BF7EF768E140A1A84B9BE3535CDAA9, ordinal: 0
2016-01-14 21:31:48,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-extra-field.txt"]
2016-01-14 21:31:48,446 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-01-14 21:31:48,446 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A7BF7EF768E140A1A84B9BE3535CDAA9, mem on start (mb), free: 366, total: 397, max: 672
2016-01-14 21:31:48,449 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/aa7cf7440ab7c2d9/apache-2.4.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:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	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-01-14 21:31:48,451 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/aa7cf7440ab7c2d9/apache-2.4.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:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	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-01-14 21:31:48,456 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A7BF7EF768E140A1A84B9BE3535CDAA9, mem on close (mb), free: 366, total: 397, max: 672
2016-01-14 21:31:48,457 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local196365896_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/classes/test/data/delimited-extra-field.txt
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.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:342)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	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-01-14 21:31:48,466 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] hadoop job job_local196365896_0009 state at FAILED
2016-01-14 21:31:48,467 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] failure info: NA
2016-01-14 21:31:48,468 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] task completion events identify failed tasks
2016-01-14 21:31:48,468 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] task completion events count: 0
2016-01-14 21:31:48,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopping all jobs
2016-01-14 21:31:48,469 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopping: (1/1) ...t/strict-nondeterministic
2016-01-14 21:31:48,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopped all jobs
2016-01-14 21:31:48,470 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic/_temporary
2016-01-14 21:31:48,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.182
2016-01-14 21:31:48,471 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/aa7cf7440ab7c2d9/apache-2.4.x/build/test/output//hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic