Class cascading.scheme.TextDelimitedPlatformTest

9

tests

0

failures

0

ignored

5.322s

duration

100%

successful

Tests

Test Duration Result
testFieldCoercion 0.470s passed
testHeader 0.337s passed
testHeaderAll 0.397s passed
testHeaderFieldsAll 0.383s passed
testQuotedText 0.419s passed
testQuotedTextAll 0.431s passed
testQuotedTextSpecChar 2.093s passed
testQuotedTextSpecCharAll 0.550s passed
testStrict 0.242s passed

Standard output

2015-07-21 12:30:24,460 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 12:30:24,485 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.scheme.TextDelimitedPlatformTest, with platform: hadoop2-mr1
2015-07-21 12:30:24,511 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(119)) - not using cluster
2015-07-21 12:30:25,105 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
2015-07-21 12:30:25,228 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-07-21 12:30:25,355 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:25,356 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:25,447 INFO  property.AppProps (AppProps.java:getAppID(174)) - using app.id: 6901226449BF497BAB08FA4200615D0A
2015-07-21 12:30:25,560 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.057
2015-07-21 12:30:25,562 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:25,562 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'
2015-07-21 12:30:25,700 INFO  util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 12:30:25,701 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:25,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-21 12:30:25,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2015-07-21 12:30:25,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:25,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:25,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:25,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...Char/quoted/speccharfalse
2015-07-21 12:30:26,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local1342993144_0001
2015-07-21 12:30:26,298 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:26,364 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt
2015-07-21 12:30:26,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:26,402 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:26,410 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: EF9C423FD3EB4A4B89E378BF4F3E1070, ordinal: 0
2015-07-21 12:30:26,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-21 12:30:26,434 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse"]
2015-07-21 12:30:26,435 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF9C423FD3EB4A4B89E378BF4F3E1070, mem on start (mb), free: 231, total: 245, max: 672
2015-07-21 12:30:26,449 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: EF9C423FD3EB4A4B89E378BF4F3E1070, mem on close (mb), free: 230, total: 245, max: 672
2015-07-21 12:30:26,495 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse/_temporary
2015-07-21 12:30:26,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.791
2015-07-21 12:30:26,602 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecChar/quoted/speccharfalse
2015-07-21 12:30:26,624 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:26,626 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:26,665 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-07-21 12:30:26,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:26,666 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'
2015-07-21 12:30:26,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:26,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:26,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2015-07-21 12:30:26,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:26,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:26,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:26,685 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...xtAll/quoted/normchartrue
2015-07-21 12:30:26,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local2036191793_0002
2015-07-21 12:30:26,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:26,882 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-21 12:30:26,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:26,896 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:26,902 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A05EDA32D8C54570806E21E55041610D, ordinal: 0
2015-07-21 12:30:26,902 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:26,903 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue"]
2015-07-21 12:30:26,903 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A05EDA32D8C54570806E21E55041610D, mem on start (mb), free: 292, total: 310, max: 672
2015-07-21 12:30:26,905 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A05EDA32D8C54570806E21E55041610D, mem on close (mb), free: 292, total: 310, max: 672
2015-07-21 12:30:26,934 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue/_temporary
2015-07-21 12:30:26,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.249
2015-07-21 12:30:27,035 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextAll/quoted/normchartrue
2015-07-21 12:30:27,058 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:27,060 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:27,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-07-21 12:30:27,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:27,113 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'
2015-07-21 12:30:27,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:27,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-21 12:30:27,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2015-07-21 12:30:27,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:27,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:27,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:27,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...arAll/quoted/specchartrue
2015-07-21 12:30:27,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local506481893_0003
2015-07-21 12:30:27,419 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:27,422 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt
2015-07-21 12:30:27,440 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:27,440 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:27,448 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: ABAF9B80B1764A31A0CE2BAE46294523, ordinal: 0
2015-07-21 12:30:27,449 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-spec-char.txt"]
2015-07-21 12:30:27,449 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue"]
2015-07-21 12:30:27,450 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABAF9B80B1764A31A0CE2BAE46294523, mem on start (mb), free: 220, total: 310, max: 672
2015-07-21 12:30:27,452 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: ABAF9B80B1764A31A0CE2BAE46294523, mem on close (mb), free: 220, total: 310, max: 672
2015-07-21 12:30:27,478 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue/_temporary
2015-07-21 12:30:27,479 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.344
2015-07-21 12:30:27,585 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedTextSpecCharAll/quoted/specchartrue
2015-07-21 12:30:27,611 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:27,612 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:27,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-07-21 12:30:27,645 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:27,646 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'
2015-07-21 12:30:27,662 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:27,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:27,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall"]
2015-07-21 12:30:27,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:27,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:27,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:27,664 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...m/testHeaderAll/headerall
2015-07-21 12:30:27,895 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local92502736_0004
2015-07-21 12:30:27,895 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:27,899 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-21 12:30:27,910 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:27,910 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:27,917 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: C8F794A9CB0747A0BA79B7E78330D3B5, ordinal: 0
2015-07-21 12:30:27,917 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:27,917 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall"]
2015-07-21 12:30:27,918 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8F794A9CB0747A0BA79B7E78330D3B5, mem on start (mb), free: 279, total: 310, max: 672
2015-07-21 12:30:27,920 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: C8F794A9CB0747A0BA79B7E78330D3B5, mem on close (mb), free: 279, total: 310, max: 672
2015-07-21 12:30:27,950 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall/_temporary
2015-07-21 12:30:27,950 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.287
2015-07-21 12:30:27,982 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderAll/headerall
2015-07-21 12:30:28,002 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:28,003 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:28,034 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-07-21 12:30:28,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:28,036 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'
2015-07-21 12:30:28,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:28,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:28,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2015-07-21 12:30:28,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:28,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:28,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:28,055 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...Text/quoted/normcharfalse
2015-07-21 12:30:28,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local462989026_0005
2015-07-21 12:30:28,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:28,236 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-21 12:30:28,250 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:28,251 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:28,259 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B519FB1FB5A84E59B2EA90D4AD160913, ordinal: 0
2015-07-21 12:30:28,261 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:28,261 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse"]
2015-07-21 12:30:28,261 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B519FB1FB5A84E59B2EA90D4AD160913, mem on start (mb), free: 220, total: 310, max: 672
2015-07-21 12:30:28,264 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B519FB1FB5A84E59B2EA90D4AD160913, mem on close (mb), free: 220, total: 310, max: 672
2015-07-21 12:30:28,309 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse/_temporary
2015-07-21 12:30:28,310 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.256
2015-07-21 12:30:28,401 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testQuotedText/quoted/normcharfalse
2015-07-21 12:30:28,515 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:28,515 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:28,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-07-21 12:30:28,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:28,544 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'
2015-07-21 12:30:28,572 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:28,573 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]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache-clean.10.txt"]
2015-07-21 12:30:28,573 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]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2015-07-21 12:30:28,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:28,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:28,573 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:28,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...oercion/testFieldCoercion
2015-07-21 12:30:28,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local712839350_0006
2015-07-21 12:30:28,725 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:28,731 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache-clean.10.txt
2015-07-21 12:30:28,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:28,740 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:28,748 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B0286DC9D22740EB95E95FDA1CA5F34D, ordinal: 0
2015-07-21 12:30:28,753 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]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache-clean.10.txt"]
2015-07-21 12:30:28,753 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]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion"]
2015-07-21 12:30:28,753 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0286DC9D22740EB95E95FDA1CA5F34D, mem on start (mb), free: 362, total: 411, max: 672
2015-07-21 12:30:28,815 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B0286DC9D22740EB95E95FDA1CA5F34D, mem on close (mb), free: 356, total: 411, max: 672
2015-07-21 12:30:28,840 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion/_temporary
2015-07-21 12:30:28,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.268
2015-07-21 12:30:28,872 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testFieldCoercion/testFieldCoercion
2015-07-21 12:30:28,888 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:28,888 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:28,925 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-07-21 12:30:28,926 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:28,926 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'
2015-07-21 12:30:28,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-header.txt"]
2015-07-21 12:30:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2015-07-21 12:30:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:28,943 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:28,944 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...05802487C80E361E6B1B4572B
2015-07-21 12:30:29,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local430473161_0007
2015-07-21 12:30:29,077 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:29,083 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-header.txt
2015-07-21 12:30:29,084 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:29,084 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:29,090 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: A57307CE28514003BE80390DD0D0F650, ordinal: 0
2015-07-21 12:30:29,090 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-header.txt"]
2015-07-21 12:30:29,091 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: MultiSinkTap[[Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"], Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]]]
2015-07-21 12:30:29,091 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A57307CE28514003BE80390DD0D0F650, mem on start (mb), free: 280, total: 411, max: 672
2015-07-21 12:30:29,092 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1"]
2015-07-21 12:30:29,096 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local430473161_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local430473161_0007_m_000000_0
2015-07-21 12:30:29,097 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-07-21 12:30:29,105 INFO  tap.MultiSinkTap (MultiSinkTap.java:<init>(80)) - opening for write: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2"]
2015-07-21 12:30:29,106 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_local430473161_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local430473161_0007_m_000000_0
2015-07-21 12:30:29,107 INFO  io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-07-21 12:30:29,119 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/part-00000
2015-07-21 12:30:29,120 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local430473161_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1/_temporary/_attempt_local430473161_0007_m_000000_0
2015-07-21 12:30:29,124 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local430473161_0007_m_000000_0' to file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2015-07-21 12:30:29,124 INFO  io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/part-00000
2015-07-21 12:30:29,125 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_local430473161_0007_m_000000_0' - file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2/_temporary/_attempt_local430473161_0007_m_000000_0
2015-07-21 12:30:29,130 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_local430473161_0007_m_000000_0' to file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2015-07-21 12:30:29,131 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: A57307CE28514003BE80390DD0D0F650, mem on close (mb), free: 275, total: 411, max: 672
2015-07-21 12:30:29,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.215
2015-07-21 12:30:29,254 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall2
2015-07-21 12:30:29,255 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeaderFieldsAll/headerfieldsall1
2015-07-21 12:30:29,278 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:29,279 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:29,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 12:30:29,308 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:29,308 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'
2015-07-21 12:30:29,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:29,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:29,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header"]
2015-07-21 12:30:29,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:29,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:29,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:29,332 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...latform/testHeader/header
2015-07-21 12:30:29,510 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local748371386_0008
2015-07-21 12:30:29,511 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:29,516 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt
2015-07-21 12:30:29,526 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:29,527 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:29,534 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: D34FCE57314F4E9580BD42A15D90B3F3, ordinal: 0
2015-07-21 12:30:29,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited.txt"]
2015-07-21 12:30:29,535 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header"]
2015-07-21 12:30:29,535 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D34FCE57314F4E9580BD42A15D90B3F3, mem on start (mb), free: 194, total: 411, max: 672
2015-07-21 12:30:29,537 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: D34FCE57314F4E9580BD42A15D90B3F3, mem on close (mb), free: 193, total: 411, max: 672
2015-07-21 12:30:29,561 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testHeader/header/_temporary
2015-07-21 12:30:29,562 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.230
2015-07-21 12:30:29,592 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testHeader/header
2015-07-21 12:30:29,610 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 12:30:29,610 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 12:30:29,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2015-07-21 12:30:29,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 12:30:29,633 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'
2015-07-21 12:30:29,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting
2015-07-21 12:30:29,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt"]
2015-07-21 12:30:29,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic"]
2015-07-21 12:30:29,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  parallel execution of steps is enabled: false
2015-07-21 12:30:29,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  executing total steps: 1
2015-07-21 12:30:29,642 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  allocating management threads: 1
2015-07-21 12:30:29,657 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] starting step: (1/1) ...t/strict-nondeterministic
2015-07-21 12:30:29,792 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] submitted hadoop job: job_local487701257_0009
2015-07-21 12:30:29,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] tracking url: http://localhost:8080/
2015-07-21 12:30:29,798 INFO  io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt
2015-07-21 12:30:29,807 INFO  hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.1
2015-07-21 12:30:29,807 INFO  hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx200m
2015-07-21 12:30:29,811 INFO  hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: BE040843B2374B179A78D7CECF2DF56E, ordinal: 0
2015-07-21 12:30:29,812 INFO  hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt"]
2015-07-21 12:30:29,812 INFO  hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextDelimited[['first', 'second', 'third', 'fourth', 'fifth']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic"]
2015-07-21 12:30:29,813 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE040843B2374B179A78D7CECF2DF56E, mem on start (mb), free: 351, total: 411, max: 672
2015-07-21 12:30:29,817 ERROR element.TrapHandler (TrapHandler.java:handleReThrowableException(115)) - caught Throwable, no trap available, rethrowing
cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 11 more
2015-07-21 12:30:29,818 ERROR element.SourceStage (SourceStage.java:map(118)) - caught throwable
cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 11 more
2015-07-21 12:30:29,819 INFO  hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: BE040843B2374B179A78D7CECF2DF56E, mem on close (mb), free: 351, total: 411, max: 672
2015-07-21 12:30:29,821 WARN  mapred.LocalJobRunner (LocalJobRunner.java:run(560)) - job_local487701257_0009
java.lang.Exception: cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/delimited-extra-field.txt
	at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: cascading.tuple.TupleException: unable to read from input identifier: file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/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:450)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:343)
	at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
	at java.util.concurrent.FutureTask.run(FutureTask.java:262)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
	at java.lang.Thread.run(Thread.java:745)
Caused by: cascading.tap.TapException: did not parse correct number of values from input data, expected: 5, got: 6:,,,,7,extra-data
	at cascading.scheme.util.DelimitedParser.onlyParseLine(DelimitedParser.java:404)
	at cascading.scheme.util.DelimitedParser.parseLine(DelimitedParser.java:341)
	at cascading.scheme.hadoop.TextDelimited.source(TextDelimited.java:1015)
	at cascading.tuple.TupleEntrySchemeIterator.getNext(TupleEntrySchemeIterator.java:166)
	at cascading.tuple.TupleEntrySchemeIterator.hasNext(TupleEntrySchemeIterator.java:139)
	... 11 more
2015-07-21 12:30:29,828 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] hadoop job job_local487701257_0009 state at FAILED
2015-07-21 12:30:29,829 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] failure info: NA
2015-07-21 12:30:29,831 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] task completion events identify failed tasks
2015-07-21 12:30:29,831 WARN  flow.Flow (BaseFlow.java:logWarn(1445)) - [pipe] task completion events count: 0
2015-07-21 12:30:29,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopping all jobs
2015-07-21 12:30:29,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopping: (1/1) ...t/strict-nondeterministic
2015-07-21 12:30:29,832 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe] stopped all jobs
2015-07-21 12:30:29,833 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic/_temporary
2015-07-21 12:30:29,833 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [pipe]  completed in: 00:00.191
2015-07-21 12:30:29,834 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/textdelimitedplatform/testStrict/strict-nondeterministic

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]