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