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