Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

0

ignored

26.688s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 3.298s passed
testHeader 3.110s passed
testHeaderAll 3.146s passed
testHeaderFieldsAll 3.137s passed
testQuotedText 3.143s passed
testQuotedTextAll 3.291s passed
testQuotedTextSpecChar 4.175s passed
testQuotedTextSpecCharAll 3.236s passed
testStrict 0.152s passed

Standard output

2016-01-14 17:26:50,145 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2016-01-14 17:26:50,159 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.scheme.TextDelimitedPlatformTest, with platform: hadoop
2016-01-14 17:26:50,184 INFO  hadoop.HadoopPlatform (HadoopPlatform.java:setUp(127)) - not using cluster
2016-01-14 17:26:50,414 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2016-01-14 17:26:50,516 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:26:50,517 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:26:50,615 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 2ED6B28B16554E418A3698B8B4EE71EB
2016-01-14 17:26:50,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2016-01-14 17:26:50,742 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:26:50,742 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 17:26:50,930 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.4
2016-01-14 17:26:50,933 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:26:50,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 17:26:50,935 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-01-14 17:26:50,936 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:26:50,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:26:50,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:26:50,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...Char/quoted/speccharfalse
2016-01-14 17:26:50,972 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(52)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2016-01-14 17:26:51,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0001
2016-01-14 17:26:51,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:26:51,298 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2016-01-14 17:26:51,313 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:26:51,314 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:26:51,327 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: FEDA07510CAA4BCDBCDB46AB927497D2, ordinal: 0
2016-01-14 17:26:51,350 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 17:26:51,351 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2016-01-14 17:26:51,352 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEDA07510CAA4BCDBCDB46AB927497D2, mem on start (mb), free: 191, total: 223, max: 672
2016-01-14 17:26:51,368 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: FEDA07510CAA4BCDBCDB46AB927497D2, mem on close (mb), free: 190, total: 223, max: 672
2016-01-14 17:26:54,284 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse/_temporary
2016-01-14 17:26:54,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.350
2016-01-14 17:26:54,355 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse
2016-01-14 17:26:54,380 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:26:54,381 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:26:54,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2016-01-14 17:26:54,456 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:26:54,456 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 17:26:54,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:26:54,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:26:54,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-01-14 17:26:54,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:26:54,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:26:54,473 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:26:54,475 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...xtAll/quoted/normchartrue
2016-01-14 17:26:54,570 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0002
2016-01-14 17:26:54,571 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:26:54,575 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-01-14 17:26:54,580 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:26:54,580 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:26:54,590 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: CF014CB13FFC4A37B0E374EE713ECCA1, ordinal: 0
2016-01-14 17:26:54,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:26:54,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2016-01-14 17:26:54,592 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF014CB13FFC4A37B0E374EE713ECCA1, mem on start (mb), free: 177, total: 223, max: 672
2016-01-14 17:26:54,596 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: CF014CB13FFC4A37B0E374EE713ECCA1, mem on close (mb), free: 177, total: 223, max: 672
2016-01-14 17:26:57,585 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue/_temporary
2016-01-14 17:26:57,587 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.114
2016-01-14 17:26:57,649 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue
2016-01-14 17:26:57,671 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:26:57,672 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:26:57,738 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2016-01-14 17:26:57,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:26:57,740 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 17:26:57,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:26:57,759 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 17:26:57,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-01-14 17:26:57,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:26:57,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:26:57,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:26:57,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...arAll/quoted/specchartrue
2016-01-14 17:26:57,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0003
2016-01-14 17:26:57,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:26:57,845 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt
2016-01-14 17:26:57,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:26:57,850 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:26:57,863 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: F7D6B76F375D4B4B9FEE8DFAEA8C2CA7, ordinal: 0
2016-01-14 17:26:57,864 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-spec-char.txt"]
2016-01-14 17:26:57,865 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2016-01-14 17:26:57,866 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7D6B76F375D4B4B9FEE8DFAEA8C2CA7, mem on start (mb), free: 166, total: 223, max: 672
2016-01-14 17:26:57,869 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: F7D6B76F375D4B4B9FEE8DFAEA8C2CA7, mem on close (mb), free: 165, total: 223, max: 672
2016-01-14 17:27:00,858 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue/_temporary
2016-01-14 17:27:00,859 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.098
2016-01-14 17:27:00,886 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue
2016-01-14 17:27:00,896 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:00,896 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:27:00,932 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2016-01-14 17:27:00,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:00,935 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 17:27:00,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:27:00,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:27:00,947 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall"]
2016-01-14 17:27:00,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:27:00,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:27:00,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:27:00,949 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...m/testHeaderAll/headerall
2016-01-14 17:27:01,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0004
2016-01-14 17:27:01,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:27:01,013 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-01-14 17:27:01,017 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:27:01,018 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:27:01,026 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B0C4203AD0DB476981674EC12A5C4705, ordinal: 0
2016-01-14 17:27:01,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:27:01,027 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall"]
2016-01-14 17:27:01,027 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0C4203AD0DB476981674EC12A5C4705, mem on start (mb), free: 213, total: 223, max: 672
2016-01-14 17:27:01,029 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0C4203AD0DB476981674EC12A5C4705, mem on close (mb), free: 213, total: 223, max: 672
2016-01-14 17:27:04,017 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderAll/headerall/_temporary
2016-01-14 17:27:04,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.071
2016-01-14 17:27:04,031 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeaderAll/headerall
2016-01-14 17:27:04,046 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:04,046 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:27:04,087 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2016-01-14 17:27:04,090 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:04,091 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 17:27:04,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:27:04,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:27:04,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-01-14 17:27:04,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:27:04,102 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:27:04,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:27:04,103 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...Text/quoted/normcharfalse
2016-01-14 17:27:04,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0005
2016-01-14 17:27:04,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:27:04,147 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-01-14 17:27:04,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:27:04,152 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:27:04,161 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C4279FBA1BF1469ABE470EBFEC538593, ordinal: 0
2016-01-14 17:27:04,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:27:04,162 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2016-01-14 17:27:04,163 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4279FBA1BF1469ABE470EBFEC538593, mem on start (mb), free: 203, total: 223, max: 672
2016-01-14 17:27:04,167 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C4279FBA1BF1469ABE470EBFEC538593, mem on close (mb), free: 203, total: 223, max: 672
2016-01-14 17:27:07,150 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse/_temporary
2016-01-14 17:27:07,151 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.047
2016-01-14 17:27:07,175 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testQuotedText/quoted/normcharfalse
2016-01-14 17:27:07,346 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:07,347 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:27:07,384 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2016-01-14 17:27:07,385 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:07,385 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 17:27:07,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:27:07,411 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/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2016-01-14 17:27:07,411 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/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-01-14 17:27:07,412 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:27:07,413 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:27:07,413 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:27:07,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...oercion/testFieldCoercion
2016-01-14 17:27:07,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0006
2016-01-14 17:27:07,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:27:07,455 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt
2016-01-14 17:27:07,459 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:27:07,459 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:27:07,468 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: E6FDC369283C4702887EE6A16FA5B98C, ordinal: 0
2016-01-14 17:27:07,475 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/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/apache-clean.10.txt"]
2016-01-14 17:27:07,476 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/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2016-01-14 17:27:07,476 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6FDC369283C4702887EE6A16FA5B98C, mem on start (mb), free: 185, total: 223, max: 672
2016-01-14 17:27:07,560 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: E6FDC369283C4702887EE6A16FA5B98C, mem on close (mb), free: 181, total: 223, max: 672
2016-01-14 17:27:10,462 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion/_temporary
2016-01-14 17:27:10,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.051
2016-01-14 17:27:10,473 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testFieldCoercion/testFieldCoercion
2016-01-14 17:27:10,484 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:10,484 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:27:10,524 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2016-01-14 17:27:10,525 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:10,526 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 17:27:10,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:27:10,541 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2016-01-14 17:27:10,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-01-14 17:27:10,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:27:10,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:27:10,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:27:10,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...B2FA24A2BBD9EEF1336A052C3
2016-01-14 17:27:10,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0007
2016-01-14 17:27:10,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:27:10,581 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-header.txt
2016-01-14 17:27:10,583 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:27:10,583 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:27:10,591 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: DEE9C6493DB14183B67F83BE0FC132B1, ordinal: 0
2016-01-14 17:27:10,592 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-header.txt"]
2016-01-14 17:27:10,593 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2016-01-14 17:27:10,593 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DEE9C6493DB14183B67F83BE0FC132B1, mem on start (mb), free: 170, total: 223, max: 672
2016-01-14 17:27:10,595 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"]
2016-01-14 17:27:10,598 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2016-01-14 17:27:10,599 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-01-14 17:27:10,602 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]
2016-01-14 17:27:10,604 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2016-01-14 17:27:10,604 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2016-01-14 17:27:10,610 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/part-00000
2016-01-14 17:27:10,611 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local_0007_m_000000_0
2016-01-14 17:27:10,613 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-01-14 17:27:10,614 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/part-00000
2016-01-14 17:27:10,615 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local_0007_m_000000_0' - file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local_0007_m_000000_0
2016-01-14 17:27:10,617 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local_0007_m_000000_0' to file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-01-14 17:27:10,618 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: DEE9C6493DB14183B67F83BE0FC132B1, mem on close (mb), free: 169, total: 223, max: 672
2016-01-14 17:27:13,584 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.042
2016-01-14 17:27:13,609 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2016-01-14 17:27:13,609 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2016-01-14 17:27:13,619 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:13,619 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:27:13,652 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2016-01-14 17:27:13,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:13,654 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 17:27:13,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:27:13,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:27:13,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeader/header"]
2016-01-14 17:27:13,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:27:13,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:27:13,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:27:13,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...latform/testHeader/header
2016-01-14 17:27:13,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0008
2016-01-14 17:27:13,697 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:27:13,701 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt
2016-01-14 17:27:13,705 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:27:13,705 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:27:13,712 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C6B7EDF638A24695BA13FEC6A3F7CF7B, ordinal: 0
2016-01-14 17:27:13,713 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited.txt"]
2016-01-14 17:27:13,713 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeader/header"]
2016-01-14 17:27:13,713 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6B7EDF638A24695BA13FEC6A3F7CF7B, mem on start (mb), free: 158, total: 223, max: 672
2016-01-14 17:27:13,715 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C6B7EDF638A24695BA13FEC6A3F7CF7B, mem on close (mb), free: 158, total: 223, max: 672
2016-01-14 17:27:16,711 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testHeader/header/_temporary
2016-01-14 17:27:16,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:03.046
2016-01-14 17:27:16,720 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testHeader/header
2016-01-14 17:27:16,743 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2016-01-14 17:27:16,744 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop/3.0.4/ab50b225eb80fe7b8e59368476a4bfb0fa1a0ef5/cascading-hadoop-3.0.4.jar
2016-01-14 17:27:16,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2016-01-14 17:27:16,785 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2016-01-14 17:27:16,785 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 17:27:16,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2016-01-14 17:27:16,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2016-01-14 17:27:16,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-01-14 17:27:16,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2016-01-14 17:27:16,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2016-01-14 17:27:16,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2016-01-14 17:27:16,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...t/strict-nondeterministic
2016-01-14 17:27:16,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local_0009
2016-01-14 17:27:16,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2016-01-14 17:27:16,842 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
2016-01-14 17:27:16,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.4
2016-01-14 17:27:16,848 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2016-01-14 17:27:16,857 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A417FD0B26724521BE91ED2280106D7E, ordinal: 0
2016-01-14 17:27:16,858 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt"]
2016-01-14 17:27:16,858 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic"]
2016-01-14 17:27:16,859 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A417FD0B26724521BE91ED2280106D7E, mem on start (mb), free: 207, total: 223, max: 672
2016-01-14 17:27:16,861 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/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:84)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 6 more
2016-01-14 17:27:16,864 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/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:84)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 6 more
2016-01-14 17:27:16,865 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A417FD0B26724521BE91ED2280106D7E, mem on close (mb), free: 207, total: 223, max: 672
2016-01-14 17:27:16,866 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(298)) - job_local_0009
cascading.tuple.TupleException: unable to read from input identifier: file:/opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/classes/test/data/delimited-extra-field.txt
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:152)
	at cascading.flow.stream.element.SourceStage.map(SourceStage.java:84)
	at cascading.flow.stream.element.SourceStage.run(SourceStage.java:66)
	at cascading.flow.hadoop.FlowMapper.run(FlowMapper.java:142)
	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:436)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:372)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 6 more
2016-01-14 17:27:16,868 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] hadoop job job_local_0009 state at FAILED
2016-01-14 17:27:16,868 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] failure info: NA
2016-01-14 17:27:16,869 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] task completion events identify failed tasks
2016-01-14 17:27:16,870 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] task completion events count: 0
2016-01-14 17:27:16,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopping all jobs
2016-01-14 17:27:16,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopping: (1/1) ...t/strict-nondeterministic
2016-01-14 17:27:16,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopped all jobs
2016-01-14 17:27:16,871 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output/hadoop/textdelimitedplatform/testStrict/strict-nondeterministic/_temporary
2016-01-14 17:27:16,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.077
2016-01-14 17:27:16,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /opt/buildAgent-8.0.3/work/d1e2e77517c04a30/apache-0.20.205.0/build/test/output//hadoop/textdelimitedplatform/testStrict/strict-nondeterministic