Class cascading.FieldedPipesPlatformTest

all > cascading > FieldedPipesPlatformTest

tests

failures

ignored

17m6.64s

duration

100%

successful

Tests
Standard output
Standard error

Tests

Test	Duration	Result
testChainEndingWithEach	29.665s	passed
testConcatenation	28.808s	passed
testCopy	18.108s	passed
testFilter	20.218s	passed
testFilterAll	53.124s	passed
testFilterComplex	52.754s	passed
testGeneratorAggregator	27.312s	passed
testGroupByInsensitive	35.207s	passed
testGroupGroup	54.332s	passed
testLogicFilter	17.583s	passed
testNoGroup	18.421s	passed
testNone	28.360s	passed
testReplace	18.334s	passed
testSameSourceMergeThreeChainGroup	1m3.10s	passed
testSimpleChain	28.085s	passed
testSimpleGroup	28.608s	passed
testSimpleMerge	34.737s	passed
testSimpleMergeThree	34.235s	passed
testSplit	33.750s	passed
testSplitComplex	55.223s	passed
testSplitMultiple	1m32.08s	passed
testSplitNonSafe	53.101s	passed
testSplitOut	1m2.10s	passed
testSplitSameSourceMerged	27.675s	passed
testSplitSameSourceMergedSameName	28.875s	passed
testSwap	26.400s	passed
testUnGroup	18.262s	passed
testUnGroupAnon	20.007s	passed
testUnGroupBySize	18.177s	passed

Standard output

2015-07-21 11:10:32,555 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 11:10:32,574 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-mr1
2015-07-21 11:10:32,601 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-07-21 11:10:33,341 WARN  util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-07-21 11:10:33,800 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-21 11:10:37,896 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-21 11:10:38,108 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-21 11:10:38,304 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-21 11:10:38,539 WARN  containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-21 11:10:55,639 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-07-21 11:10:55,752 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:10:55,753 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 11:10:55,822 INFO  property.AppProps (AppProps.java:getAppID(174)) - using app.id: B2227880F1BE4ED4B462BFFC4279295A
2015-07-21 11:10:55,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.116
2015-07-21 11:10:55,985 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:10:55,986 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:10:56,162 INFO  util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 11:10:56,163 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:10:56,164 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:10:56,164 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2015-07-21 11:10:56,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:10:56,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:10:56,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:10:56,166 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2015-07-21 11:10:57,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0001
2015-07-21 11:10:57,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0001/
2015-07-21 11:11:14,242 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000002 is : 143
2015-07-21 11:11:14,331 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000003 is : 143
2015-07-21 11:11:14,400 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000004 is : 143
2015-07-21 11:11:14,430 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000005 is : 143
2015-07-21 11:11:14,481 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000006 is : 143
2015-07-21 11:11:23,544 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000008 is : 143
2015-07-21 11:11:23,669 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000009 is : 143
2015-07-21 11:11:24,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0001_01_000007 is : 143
2015-07-21 11:11:25,294 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2015-07-21 11:11:25,295 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:29.128
2015-07-21 11:11:25,335 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex
2015-07-21 11:11:25,380 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:11:25,380 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 11:11:25,434 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2015-07-21 11:11:25,436 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:11:25,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:11:25,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:11:25,463 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:11:25,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain"]
2015-07-21 11:11:25,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:11:25,464 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:11:25,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:11:25,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2015-07-21 11:11:25,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0002
2015-07-21 11:11:25,636 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0002/
2015-07-21 11:11:42,557 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000005 is : 143
2015-07-21 11:11:42,603 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000003 is : 143
2015-07-21 11:11:42,727 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000006 is : 143
2015-07-21 11:11:42,774 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000002 is : 143
2015-07-21 11:11:42,853 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000004 is : 143
2015-07-21 11:11:51,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000009 is : 143
2015-07-21 11:11:51,675 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000008 is : 143
2015-07-21 11:11:52,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0002_01_000007 is : 143
2015-07-21 11:11:53,383 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2015-07-21 11:11:53,386 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:27.918
2015-07-21 11:11:53,416 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain
2015-07-21 11:11:53,463 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:11:53,464 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 11:11:53,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-07-21 11:11:53,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:11:53,503 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:11:53,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:11:53,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:11:53,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple"]
2015-07-21 11:11:53,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:11:53,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:11:53,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:11:53,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2015-07-21 11:11:53,716 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0003
2015-07-21 11:11:53,717 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0003/
2015-07-21 11:12:10,780 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000002 is : 143
2015-07-21 11:12:10,895 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000003 is : 143
2015-07-21 11:12:10,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000005 is : 143
2015-07-21 11:12:11,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000004 is : 143
2015-07-21 11:12:11,160 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000006 is : 143
2015-07-21 11:12:20,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000008 is : 143
2015-07-21 11:12:20,459 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000009 is : 143
2015-07-21 11:12:20,775 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0003_01_000007 is : 143
2015-07-21 11:12:21,989 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2015-07-21 11:12:21,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:28.470
2015-07-21 11:12:22,030 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple
2015-07-21 11:12:22,096 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:12:22,096 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 11:12:22,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-07-21 11:12:22,154 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:12:22,154 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:12:22,174 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-07-21 11:12:22,175 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:12:22,175 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:12:22,175 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2015-07-21 11:12:22,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2015-07-21 11:12:22,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2015-07-21 11:12:22,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2015-07-21 11:12:22,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2015-07-21 11:12:22,328 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1437502250126_0004
2015-07-21 11:12:22,328 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0004/
2015-07-21 11:12:45,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000007 is : 143
2015-07-21 11:12:46,037 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000004 is : 143
2015-07-21 11:12:46,134 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000006 is : 143
2015-07-21 11:12:46,257 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000002 is : 143
2015-07-21 11:12:46,343 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000009 is : 143
2015-07-21 11:12:46,449 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000003 is : 143
2015-07-21 11:12:46,529 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000005 is : 143
2015-07-21 11:12:46,629 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000008 is : 143
2015-07-21 11:12:54,845 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000010 is : 143
2015-07-21 11:12:55,131 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000012 is : 143
2015-07-21 11:12:55,505 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0004_01_000011 is : 143
2015-07-21 11:12:56,720 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2015-07-21 11:12:56,722 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:34.544
2015-07-21 11:12:56,769 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge
2015-07-21 11:12:56,892 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:12:56,893 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 11:12:56,927 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-07-21 11:12:56,930 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:12:56,930 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:12:56,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:12:56,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:12:56,955 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2015-07-21 11:12:56,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:12:56,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:12:56,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:12:56,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2015-07-21 11:12:57,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0005
2015-07-21 11:12:57,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0005/
2015-07-21 11:13:14,372 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000005 is : 143
2015-07-21 11:13:14,467 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000002 is : 143
2015-07-21 11:13:14,572 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000004 is : 143
2015-07-21 11:13:14,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000003 is : 143
2015-07-21 11:13:14,699 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000006 is : 143
2015-07-21 11:13:24,730 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000008 is : 143
2015-07-21 11:13:24,750 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000007 is : 143
2015-07-21 11:13:25,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0005_01_000009 is : 143
2015-07-21 11:13:26,409 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2015-07-21 11:13:26,412 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:29.451
2015-07-21 11:13:26,433 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach
2015-07-21 11:13:26,465 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:13:26,465 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 11:13:26,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 11:13:26,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:13:26,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:13:26,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:13:26,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:13:26,513 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2015-07-21 11:13:26,514 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:13:26,514 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:13:26,514 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:13:26,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...gator/generatoraggregator
2015-07-21 11:13:26,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0006
2015-07-21 11:13:26,631 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0006/
2015-07-21 11:13:43,303 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000002 is : 143
2015-07-21 11:13:43,510 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000003 is : 143
2015-07-21 11:13:43,573 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000004 is : 143
2015-07-21 11:13:43,601 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000006 is : 143
2015-07-21 11:13:43,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000005 is : 143
2015-07-21 11:13:52,148 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000009 is : 143
2015-07-21 11:13:52,426 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000007 is : 143
2015-07-21 11:13:52,540 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0006_01_000008 is : 143
2015-07-21 11:13:53,723 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2015-07-21 11:13:53,724 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:27.209
2015-07-21 11:13:53,745 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2015-07-21 11:13:53,792 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:13:53,793 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 11:13:53,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2015-07-21 11:13:53,850 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:13:53,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:13:53,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-07-21 11:13:53,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:13:53,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:13:53,875 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-21 11:13:53,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextDelimited[['num', 'first']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2015-07-21 11:13:53,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2015-07-21 11:13:53,877 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2015-07-21 11:13:53,877 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2015-07-21 11:13:53,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2015-07-21 11:13:54,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1437502250126_0007
2015-07-21 11:13:54,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0007/
2015-07-21 11:14:18,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000010 is : 143
2015-07-21 11:14:18,192 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000005 is : 143
2015-07-21 11:14:18,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000002 is : 143
2015-07-21 11:14:18,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000003 is : 143
2015-07-21 11:14:18,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000007 is : 143
2015-07-21 11:14:18,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000009 is : 143
2015-07-21 11:14:18,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000006 is : 143
2015-07-21 11:14:18,520 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000008 is : 143
2015-07-21 11:14:18,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000004 is : 143
2015-07-21 11:14:26,367 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000011 is : 143
2015-07-21 11:14:26,647 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000012 is : 143
2015-07-21 11:14:26,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0007_01_000013 is : 143
2015-07-21 11:14:27,942 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2015-07-21 11:14:27,944 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 00:34.065
2015-07-21 11:14:27,981 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2015-07-21 11:14:28,010 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:14:28,010 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 11:14:28,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-07-21 11:14:28,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-07-21 11:14:28,054 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:14:28,073 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2015-07-21 11:14:28,073 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:14:28,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2015-07-21 11:14:28,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2015-07-21 11:14:28,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2015-07-21 11:14:28,074 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 3
2015-07-21 11:14:28,075 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 3
2015-07-21 11:14:28,076 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2015-07-21 11:14:28,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0008
2015-07-21 11:14:28,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0008/
2015-07-21 11:14:45,302 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0008_01_000002 is : 143
2015-07-21 11:14:45,707 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0008_01_000003 is : 143
2015-07-21 11:14:45,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0008_01_000006 is : 143
2015-07-21 11:14:46,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0008_01_000004 is : 143
2015-07-21 11:14:46,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0008_01_000005 is : 143
2015-07-21 11:14:47,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit2
2015-07-21 11:14:47,426 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit1
2015-07-21 11:14:47,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0009
2015-07-21 11:14:47,674 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0009/
2015-07-21 11:14:47,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0010
2015-07-21 11:14:47,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0010/
2015-07-21 11:15:07,172 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0009_01_000004 is : 143
2015-07-21 11:15:07,567 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0009_01_000003 is : 143
2015-07-21 11:15:07,623 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0009_01_000005 is : 143
2015-07-21 11:15:08,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0009_01_000006 is : 143
2015-07-21 11:15:08,799 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0009_01_000002 is : 143
2015-07-21 11:15:18,699 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0010_01_000006 is : 143
2015-07-21 11:15:18,809 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0010_01_000005 is : 143
2015-07-21 11:15:18,971 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0010_01_000004 is : 143
2015-07-21 11:15:19,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0010_01_000002 is : 143
2015-07-21 11:15:19,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0010_01_000003 is : 143
2015-07-21 11:15:21,030 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2015-07-21 11:15:21,031 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2015-07-21 11:15:21,033 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:52.948
2015-07-21 11:15:21,068 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2015-07-21 11:15:21,083 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2015-07-21 11:15:21,117 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:15:21,117 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 11:15:21,163 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-07-21 11:15:21,164 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-07-21 11:15:21,165 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:15:21,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting
2015-07-21 11:15:21,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:15:21,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2"]
2015-07-21 11:15:21,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1"]
2015-07-21 11:15:21,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  parallel execution of steps is enabled: true
2015-07-21 11:15:21,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  executing total steps: 3
2015-07-21 11:15:21,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  allocating management threads: 3
2015-07-21 11:15:21,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (1/3)
2015-07-21 11:15:21,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1437502250126_0011
2015-07-21 11:15:21,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0011/
2015-07-21 11:15:37,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000006 is : 143
2015-07-21 11:15:37,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000005 is : 143
2015-07-21 11:15:38,035 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000004 is : 143
2015-07-21 11:15:38,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000003 is : 143
2015-07-21 11:15:38,143 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000002 is : 143
2015-07-21 11:15:47,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000008 is : 143
2015-07-21 11:15:47,397 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000007 is : 143
2015-07-21 11:15:47,845 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0011_01_000009 is : 143
2015-07-21 11:15:49,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout1
2015-07-21 11:15:49,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout2
2015-07-21 11:15:49,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1437502250126_0012
2015-07-21 11:15:49,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0012/
2015-07-21 11:15:49,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1437502250126_0013
2015-07-21 11:15:49,224 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0013/
2015-07-21 11:16:04,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0012_01_000002 is : 143
2015-07-21 11:16:04,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0012_01_000003 is : 143
2015-07-21 11:16:04,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0012_01_000004 is : 143
2015-07-21 11:16:12,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0013_01_000002 is : 143
2015-07-21 11:16:12,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0013_01_000004 is : 143
2015-07-21 11:16:12,558 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0013_01_000003 is : 143
2015-07-21 11:16:21,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0013_01_000007 is : 143
2015-07-21 11:16:21,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0013_01_000005 is : 143
2015-07-21 11:16:21,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0013_01_000006 is : 143
2015-07-21 11:16:23,081 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2015-07-21 11:16:23,082 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2015-07-21 11:16:23,084 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  completed in: 01:01.890
2015-07-21 11:16:23,162 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2
2015-07-21 11:16:23,179 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1
2015-07-21 11:16:23,211 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:16:23,212 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 11:16:23,254 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2015-07-21 11:16:23,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-07-21 11:16:23,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:16:23,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2015-07-21 11:16:23,272 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:16:23,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1"]
2015-07-21 11:16:23,273 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2"]
2015-07-21 11:16:23,274 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2015-07-21 11:16:23,274 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 2
2015-07-21 11:16:23,274 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 2
2015-07-21 11:16:23,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/2) ...platform/testSplit/split2
2015-07-21 11:16:23,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/2) ...platform/testSplit/split1
2015-07-21 11:16:23,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0014
2015-07-21 11:16:23,441 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0014/
2015-07-21 11:16:23,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0015
2015-07-21 11:16:23,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0015/
2015-07-21 11:16:42,091 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0014_01_000004 is : 143
2015-07-21 11:16:42,473 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0014_01_000006 is : 143
2015-07-21 11:16:42,487 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0014_01_000002 is : 143
2015-07-21 11:16:42,541 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0014_01_000003 is : 143
2015-07-21 11:16:42,668 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0014_01_000005 is : 143
2015-07-21 11:16:55,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0015_01_000002 is : 143
2015-07-21 11:16:55,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0015_01_000005 is : 143
2015-07-21 11:16:55,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0015_01_000004 is : 143
2015-07-21 11:16:55,547 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0015_01_000003 is : 143
2015-07-21 11:16:55,661 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0015_01_000006 is : 143
2015-07-21 11:16:56,858 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2/_temporary
2015-07-21 11:16:56,859 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1/_temporary
2015-07-21 11:16:56,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:33.585
2015-07-21 11:16:56,917 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split2
2015-07-21 11:16:56,932 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplit/split1
2015-07-21 11:16:56,961 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:16:56,961 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 11:16:56,994 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-07-21 11:16:56,995 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:16:56,996 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:16:57,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2015-07-21 11:16:57,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:16:57,007 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2015-07-21 11:16:57,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2015-07-21 11:16:57,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2015-07-21 11:16:57,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2015-07-21 11:16:57,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2015-07-21 11:16:57,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1437502250126_0016
2015-07-21 11:16:57,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0016/
2015-07-21 11:17:13,789 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000002 is : 143
2015-07-21 11:17:13,875 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000004 is : 143
2015-07-21 11:17:13,971 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000005 is : 143
2015-07-21 11:17:14,051 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000006 is : 143
2015-07-21 11:17:14,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000003 is : 143
2015-07-21 11:17:22,958 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000009 is : 143
2015-07-21 11:17:22,982 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000008 is : 143
2015-07-21 11:17:23,385 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0016_01_000007 is : 143
2015-07-21 11:17:24,577 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2015-07-21 11:17:24,579 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:27.569
2015-07-21 11:17:24,603 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2015-07-21 11:17:24,638 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:17:24,638 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 11:17:24,653 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-07-21 11:17:24,654 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:17:24,655 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:17:24,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:17:24,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:17:24,661 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy"]
2015-07-21 11:17:24,662 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:17:24,662 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:17:24,662 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:17:24,663 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2015-07-21 11:17:24,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0017
2015-07-21 11:17:24,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0017/
2015-07-21 11:17:40,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0017_01_000002 is : 143
2015-07-21 11:17:41,223 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0017_01_000003 is : 143
2015-07-21 11:17:41,269 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0017_01_000006 is : 143
2015-07-21 11:17:41,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0017_01_000005 is : 143
2015-07-21 11:17:41,497 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0017_01_000004 is : 143
2015-07-21 11:17:42,681 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy/_temporary
2015-07-21 11:17:42,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:18.018
2015-07-21 11:17:42,705 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testCopy/copy
2015-07-21 11:17:42,744 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:17:42,744 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 11:17:42,782 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-07-21 11:17:42,783 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:17:42,784 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:17:42,798 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:17:42,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:17:42,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none"]
2015-07-21 11:17:42,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:17:42,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:17:42,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:17:42,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2015-07-21 11:17:42,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0018
2015-07-21 11:17:42,929 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0018/
2015-07-21 11:17:59,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000003 is : 143
2015-07-21 11:17:59,382 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000002 is : 143
2015-07-21 11:17:59,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000004 is : 143
2015-07-21 11:17:59,650 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000006 is : 143
2015-07-21 11:17:59,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000005 is : 143
2015-07-21 11:18:09,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000007 is : 143
2015-07-21 11:18:09,483 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000009 is : 143
2015-07-21 11:18:09,867 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0018_01_000008 is : 143
2015-07-21 11:18:11,051 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none/_temporary
2015-07-21 11:18:11,052 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:28.251
2015-07-21 11:18:11,074 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNone/none
2015-07-21 11:18:11,101 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:18:11,102 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 11:18:11,134 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 11:18:11,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:18:11,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:18:11,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:18:11,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:18:11,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap"]
2015-07-21 11:18:11,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:18:11,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:18:11,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:18:11,149 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2015-07-21 11:18:11,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0019
2015-07-21 11:18:11,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0019/
2015-07-21 11:18:26,898 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000002 is : 143
2015-07-21 11:18:26,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000003 is : 143
2015-07-21 11:18:27,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000005 is : 143
2015-07-21 11:18:27,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000004 is : 143
2015-07-21 11:18:27,192 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000006 is : 143
2015-07-21 11:18:35,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000008 is : 143
2015-07-21 11:18:36,000 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000009 is : 143
2015-07-21 11:18:36,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0019_01_000007 is : 143
2015-07-21 11:18:37,453 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap/_temporary
2015-07-21 11:18:37,454 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:26.304
2015-07-21 11:18:37,474 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSwap/swap
2015-07-21 11:18:37,506 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:18:37,506 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 11:18:37,526 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2015-07-21 11:18:37,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:18:37,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:18:37,537 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:18:37,537 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:18:37,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter"]
2015-07-21 11:18:37,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:18:37,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:18:37,539 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:18:37,542 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2015-07-21 11:18:37,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0020
2015-07-21 11:18:37,671 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0020/
2015-07-21 11:18:53,358 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0020_01_000002 is : 143
2015-07-21 11:18:53,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0020_01_000005 is : 143
2015-07-21 11:18:53,557 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0020_01_000003 is : 143
2015-07-21 11:18:53,625 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0020_01_000004 is : 143
2015-07-21 11:18:53,829 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0020_01_000006 is : 143
2015-07-21 11:18:55,016 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2015-07-21 11:18:55,024 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:17.477
2015-07-21 11:18:55,052 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter
2015-07-21 11:18:55,110 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:18:55,110 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 11:18:55,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-07-21 11:18:55,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:18:55,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:18:55,157 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:18:55,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:18:55,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped"]
2015-07-21 11:18:55,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:18:55,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:18:55,159 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:18:55,161 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2015-07-21 11:18:55,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0021
2015-07-21 11:18:55,292 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0021/
2015-07-21 11:19:11,771 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0021_01_000003 is : 143
2015-07-21 11:19:11,882 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0021_01_000002 is : 143
2015-07-21 11:19:11,916 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0021_01_000005 is : 143
2015-07-21 11:19:11,991 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0021_01_000006 is : 143
2015-07-21 11:19:12,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0021_01_000004 is : 143
2015-07-21 11:19:13,290 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2015-07-21 11:19:13,291 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:18.131
2015-07-21 11:19:13,312 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped
2015-07-21 11:19:13,349 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:19:13,350 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 11:19:13,400 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-07-21 11:19:13,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:19:13,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:19:13,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:19:13,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:19:13,417 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall"]
2015-07-21 11:19:13,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:19:13,418 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2015-07-21 11:19:13,419 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 2
2015-07-21 11:19:13,420 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-07-21 11:19:13,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0022
2015-07-21 11:19:13,535 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0022/
2015-07-21 11:19:29,897 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000002 is : 143
2015-07-21 11:19:30,076 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000003 is : 143
2015-07-21 11:19:30,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000005 is : 143
2015-07-21 11:19:30,220 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000004 is : 143
2015-07-21 11:19:30,282 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000006 is : 143
2015-07-21 11:19:39,232 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000007 is : 143
2015-07-21 11:19:39,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000009 is : 143
2015-07-21 11:19:39,634 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0022_01_000008 is : 143
2015-07-21 11:19:40,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2015-07-21 11:19:40,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0023
2015-07-21 11:19:40,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0023/
2015-07-21 11:19:53,687 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0023_01_000002 is : 143
2015-07-21 11:19:53,866 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0023_01_000003 is : 143
2015-07-21 11:19:54,099 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0023_01_000004 is : 143
2015-07-21 11:20:05,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0023_01_000006 is : 143
2015-07-21 11:20:05,084 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0023_01_000007 is : 143
2015-07-21 11:20:05,213 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0023_01_000005 is : 143
2015-07-21 11:20:06,435 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall/_temporary
2015-07-21 11:20:06,437 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:53.016
2015-07-21 11:20:06,451 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall
2015-07-21 11:20:06,473 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:20:06,474 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 11:20:06,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 11:20:06,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:20:06,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:20:06,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2015-07-21 11:20:06,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:20:06,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2015-07-21 11:20:06,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2015-07-21 11:20:06,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2015-07-21 11:20:06,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2015-07-21 11:20:06,522 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2015-07-21 11:20:06,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1437502250126_0024
2015-07-21 11:20:06,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0024/
2015-07-21 11:20:24,306 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000003 is : 143
2015-07-21 11:20:24,384 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000002 is : 143
2015-07-21 11:20:24,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000006 is : 143
2015-07-21 11:20:24,696 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000005 is : 143
2015-07-21 11:20:24,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000004 is : 143
2015-07-21 11:20:33,772 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000009 is : 143
2015-07-21 11:20:33,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000007 is : 143
2015-07-21 11:20:34,109 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0024_01_000008 is : 143
2015-07-21 11:20:35,298 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2015-07-21 11:20:35,300 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 00:28.777
2015-07-21 11:20:35,319 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2015-07-21 11:20:35,359 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:20:35,359 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 11:20:35,393 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-07-21 11:20:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:20:35,395 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:20:35,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting
2015-07-21 11:20:35,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:20:35,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:20:35,410 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2015-07-21 11:20:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  parallel execution of steps is enabled: true
2015-07-21 11:20:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  executing total steps: 1
2015-07-21 11:20:35,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  allocating management threads: 1
2015-07-21 11:20:35,412 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2015-07-21 11:20:35,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] submitted hadoop job: job_1437502250126_0025
2015-07-21 11:20:35,527 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0025/
2015-07-21 11:20:59,160 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000009 is : 143
2015-07-21 11:20:59,264 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000008 is : 143
2015-07-21 11:20:59,388 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000006 is : 143
2015-07-21 11:20:59,582 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000002 is : 143
2015-07-21 11:20:59,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000007 is : 143
2015-07-21 11:20:59,694 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000005 is : 143
2015-07-21 11:20:59,730 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000004 is : 143
2015-07-21 11:20:59,770 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000003 is : 143
2015-07-21 11:21:08,770 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000011 is : 143
2015-07-21 11:21:09,103 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000010 is : 143
2015-07-21 11:21:09,287 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0025_01_000012 is : 143
2015-07-21 11:21:10,500 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2015-07-21 11:21:10,503 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  completed in: 00:35.088
2015-07-21 11:21:10,524 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2015-07-21 11:21:10,557 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:21:10,558 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 11:21:10,588 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-07-21 11:21:10,589 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:21:10,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:21:10,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:21:10,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:21:10,601 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2015-07-21 11:21:10,602 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:21:10,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:21:10,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:21:10,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2015-07-21 11:21:10,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0026
2015-07-21 11:21:10,731 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0026/
2015-07-21 11:21:28,748 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0026_01_000004 is : 143
2015-07-21 11:21:28,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0026_01_000006 is : 143
2015-07-21 11:21:28,899 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0026_01_000002 is : 143
2015-07-21 11:21:29,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0026_01_000005 is : 143
2015-07-21 11:21:29,198 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0026_01_000003 is : 143
2015-07-21 11:21:30,448 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2015-07-21 11:21:30,450 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:19.846
2015-07-21 11:21:30,490 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2015-07-21 11:21:30,564 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:21:30,565 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 11:21:30,611 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.044
2015-07-21 11:21:30,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:21:30,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:21:30,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:21:30,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:21:30,632 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup"]
2015-07-21 11:21:30,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:21:30,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2015-07-21 11:21:30,633 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 2
2015-07-21 11:21:30,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-07-21 11:21:30,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0027
2015-07-21 11:21:30,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0027/
2015-07-21 11:21:47,730 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000002 is : 143
2015-07-21 11:21:47,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000005 is : 143
2015-07-21 11:21:47,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000003 is : 143
2015-07-21 11:21:47,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000006 is : 143
2015-07-21 11:21:48,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000004 is : 143
2015-07-21 11:21:58,182 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000008 is : 143
2015-07-21 11:21:58,291 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000007 is : 143
2015-07-21 11:21:58,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0027_01_000009 is : 143
2015-07-21 11:21:59,833 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2015-07-21 11:21:59,953 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0028
2015-07-21 11:21:59,954 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0028/
2015-07-21 11:22:13,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0028_01_000002 is : 143
2015-07-21 11:22:13,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0028_01_000003 is : 143
2015-07-21 11:22:13,728 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0028_01_000004 is : 143
2015-07-21 11:22:23,124 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0028_01_000005 is : 143
2015-07-21 11:22:23,547 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0028_01_000006 is : 143
2015-07-21 11:22:23,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0028_01_000007 is : 143
2015-07-21 11:22:24,844 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2015-07-21 11:22:24,846 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:54.209
2015-07-21 11:22:24,865 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup
2015-07-21 11:22:24,896 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:22:24,896 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 11:22:24,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.043
2015-07-21 11:22:24,944 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:22:24,944 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:22:24,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting
2015-07-21 11:22:24,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:22:24,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2015-07-21 11:22:24,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  parallel execution of steps is enabled: true
2015-07-21 11:22:24,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  executing total steps: 2
2015-07-21 11:22:24,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  allocating management threads: 2
2015-07-21 11:22:24,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (1/2)
2015-07-21 11:22:25,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_1437502250126_0029
2015-07-21 11:22:25,092 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0029/
2015-07-21 11:22:45,392 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000003 is : 143
2015-07-21 11:22:45,449 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000004 is : 143
2015-07-21 11:22:45,449 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000008 is : 143
2015-07-21 11:22:45,563 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000002 is : 143
2015-07-21 11:22:45,667 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000007 is : 143
2015-07-21 11:22:45,738 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000006 is : 143
2015-07-21 11:22:45,743 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000005 is : 143
2015-07-21 11:22:53,988 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000009 is : 143
2015-07-21 11:22:54,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000010 is : 143
2015-07-21 11:22:54,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0029_01_000011 is : 143
2015-07-21 11:22:55,647 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2015-07-21 11:22:55,770 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_1437502250126_0030
2015-07-21 11:22:55,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0030/
2015-07-21 11:23:17,207 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000003 is : 143
2015-07-21 11:23:17,522 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000002 is : 143
2015-07-21 11:23:17,673 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000009 is : 143
2015-07-21 11:23:17,743 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000005 is : 143
2015-07-21 11:23:17,776 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000007 is : 143
2015-07-21 11:23:17,817 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000006 is : 143
2015-07-21 11:23:17,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000008 is : 143
2015-07-21 11:23:17,868 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000004 is : 143
2015-07-21 11:23:26,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000012 is : 143
2015-07-21 11:23:26,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000011 is : 143
2015-07-21 11:23:26,769 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0030_01_000010 is : 143
2015-07-21 11:23:27,945 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2015-07-21 11:23:27,948 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  completed in: 01:02.981
2015-07-21 11:23:27,966 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2015-07-21 11:23:27,997 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:23:27,997 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 11:23:28,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2015-07-21 11:23:28,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:23:28,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:23:28,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:23:28,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:23:28,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace"]
2015-07-21 11:23:28,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:23:28,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:23:28,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:23:28,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2015-07-21 11:23:28,151 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0031
2015-07-21 11:23:28,151 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0031/
2015-07-21 11:23:44,579 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0031_01_000002 is : 143
2015-07-21 11:23:44,713 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0031_01_000005 is : 143
2015-07-21 11:23:44,893 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0031_01_000004 is : 143
2015-07-21 11:23:44,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0031_01_000003 is : 143
2015-07-21 11:23:45,050 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0031_01_000006 is : 143
2015-07-21 11:23:46,265 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace/_temporary
2015-07-21 11:23:46,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:18.237
2015-07-21 11:23:46,293 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testReplace/replace
2015-07-21 11:23:46,344 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:23:46,345 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 11:23:46,365 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2015-07-21 11:23:46,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:23:46,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:23:46,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:23:46,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/extra+lower+upper.txt"]
2015-07-21 11:23:46,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2015-07-21 11:23:46,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:23:46,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:23:46,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:23:46,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2015-07-21 11:23:46,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0032
2015-07-21 11:23:46,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0032/
2015-07-21 11:24:02,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0032_01_000002 is : 143
2015-07-21 11:24:02,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0032_01_000003 is : 143
2015-07-21 11:24:03,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0032_01_000005 is : 143
2015-07-21 11:24:03,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0032_01_000004 is : 143
2015-07-21 11:24:03,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0032_01_000006 is : 143
2015-07-21 11:24:04,428 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2015-07-21 11:24:04,429 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:18.053
2015-07-21 11:24:04,456 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2015-07-21 11:24:04,504 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:24:04,504 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 11:24:04,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2015-07-21 11:24:04,522 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:24:04,523 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:24:04,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:24:04,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:24:04,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter"]
2015-07-21 11:24:04,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:24:04,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:24:04,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:24:04,534 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2015-07-21 11:24:04,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0033
2015-07-21 11:24:04,648 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0033/
2015-07-21 11:24:23,043 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0033_01_000002 is : 143
2015-07-21 11:24:23,304 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0033_01_000006 is : 143
2015-07-21 11:24:23,306 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0033_01_000005 is : 143
2015-07-21 11:24:23,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0033_01_000004 is : 143
2015-07-21 11:24:23,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0033_01_000003 is : 143
2015-07-21 11:24:24,667 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter/_temporary
2015-07-21 11:24:24,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:20.131
2015-07-21 11:24:24,687 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testFilter/filter
2015-07-21 11:24:24,724 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:24:24,725 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 11:24:24,814 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2015-07-21 11:24:24,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2015-07-21 11:24:24,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:24:24,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting
2015-07-21 11:24:24,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:24:24,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left"]
2015-07-21 11:24:24,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright"]
2015-07-21 11:24:24,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft"]
2015-07-21 11:24:24,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  parallel execution of steps is enabled: true
2015-07-21 11:24:24,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  executing total steps: 5
2015-07-21 11:24:24,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  allocating management threads: 5
2015-07-21 11:24:24,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (1/5)
2015-07-21 11:24:24,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1437502250126_0034
2015-07-21 11:24:24,997 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0034/
2015-07-21 11:24:42,707 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000003 is : 143
2015-07-21 11:24:42,766 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000002 is : 143
2015-07-21 11:24:42,944 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000005 is : 143
2015-07-21 11:24:42,969 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000004 is : 143
2015-07-21 11:24:43,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000006 is : 143
2015-07-21 11:24:53,857 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000007 is : 143
2015-07-21 11:24:53,935 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000008 is : 143
2015-07-21 11:24:54,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0034_01_000009 is : 143
2015-07-21 11:24:55,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (2/5) ...rm/testSplitMultiple/left
2015-07-21 11:24:55,368 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (3/5)
2015-07-21 11:24:55,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1437502250126_0035
2015-07-21 11:24:55,565 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0035/
2015-07-21 11:24:55,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1437502250126_0036
2015-07-21 11:24:55,566 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0036/
2015-07-21 11:25:11,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0035_01_000004 is : 143
2015-07-21 11:25:11,970 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0035_01_000003 is : 143
2015-07-21 11:25:12,028 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0035_01_000002 is : 143
2015-07-21 11:25:20,308 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0036_01_000004 is : 143
2015-07-21 11:25:20,387 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0036_01_000002 is : 143
2015-07-21 11:25:20,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0036_01_000003 is : 143
2015-07-21 11:25:30,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0036_01_000005 is : 143
2015-07-21 11:25:30,229 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0036_01_000006 is : 143
2015-07-21 11:25:30,394 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0036_01_000007 is : 143
2015-07-21 11:25:31,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (4/5) ...tSplitMultiple/rightright
2015-07-21 11:25:31,604 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (5/5) ...stSplitMultiple/rightleft
2015-07-21 11:25:31,767 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1437502250126_0037
2015-07-21 11:25:31,768 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0037/
2015-07-21 11:25:31,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1437502250126_0038
2015-07-21 11:25:31,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0038/
2015-07-21 11:25:47,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0037_01_000003 is : 143
2015-07-21 11:25:47,299 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0037_01_000004 is : 143
2015-07-21 11:25:47,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0037_01_000002 is : 143
2015-07-21 11:25:55,297 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0038_01_000003 is : 143
2015-07-21 11:25:55,395 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0038_01_000004 is : 143
2015-07-21 11:25:55,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0038_01_000002 is : 143
2015-07-21 11:25:56,701 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left/_temporary
2015-07-21 11:25:56,703 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2015-07-21 11:25:56,703 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2015-07-21 11:25:56,707 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  completed in: 01:31.838
2015-07-21 11:25:56,757 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright
2015-07-21 11:25:56,767 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft
2015-07-21 11:25:56,777 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left
2015-07-21 11:25:56,807 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:25:56,808 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 11:25:56,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2015-07-21 11:25:56,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:25:56,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:25:56,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting
2015-07-21 11:25:56,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]]]
2015-07-21 11:25:56,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat"]
2015-07-21 11:25:56,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  parallel execution of steps is enabled: true
2015-07-21 11:25:56,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  executing total steps: 1
2015-07-21 11:25:56,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  allocating management threads: 1
2015-07-21 11:25:56,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2015-07-21 11:25:56,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] submitted hadoop job: job_1437502250126_0039
2015-07-21 11:25:56,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0039/
2015-07-21 11:26:15,806 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000003 is : 143
2015-07-21 11:26:15,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000005 is : 143
2015-07-21 11:26:15,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000007 is : 143
2015-07-21 11:26:16,001 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000002 is : 143
2015-07-21 11:26:16,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000004 is : 143
2015-07-21 11:26:16,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000006 is : 143
2015-07-21 11:26:24,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000009 is : 143
2015-07-21 11:26:24,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000008 is : 143
2015-07-21 11:26:24,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0039_01_000010 is : 143
2015-07-21 11:26:25,565 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2015-07-21 11:26:25,567 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  completed in: 00:28.716
2015-07-21 11:26:25,584 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat
2015-07-21 11:26:25,617 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:26:25,617 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 11:26:25,656 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-07-21 11:26:25,658 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2015-07-21 11:26:25,658 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:26:25,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2015-07-21 11:26:25,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:26:25,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2015-07-21 11:26:25,679 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2015-07-21 11:26:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2015-07-21 11:26:25,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 3
2015-07-21 11:26:25,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 3
2015-07-21 11:26:25,684 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2015-07-21 11:26:25,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0040
2015-07-21 11:26:25,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0040/
2015-07-21 11:26:44,986 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000002 is : 143
2015-07-21 11:26:45,079 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000005 is : 143
2015-07-21 11:26:45,145 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000004 is : 143
2015-07-21 11:26:45,166 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000006 is : 143
2015-07-21 11:26:45,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000003 is : 143
2015-07-21 11:26:53,775 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000008 is : 143
2015-07-21 11:26:53,784 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000007 is : 143
2015-07-21 11:26:54,314 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0040_01_000009 is : 143
2015-07-21 11:26:55,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp1
2015-07-21 11:26:55,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp2
2015-07-21 11:26:55,625 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0041
2015-07-21 11:26:55,625 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0041/
2015-07-21 11:26:55,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1437502250126_0042
2015-07-21 11:26:55,644 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0042/
2015-07-21 11:27:10,058 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0041_01_000002 is : 143
2015-07-21 11:27:10,162 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0041_01_000004 is : 143
2015-07-21 11:27:10,329 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0041_01_000003 is : 143
2015-07-21 11:27:19,519 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0042_01_000005 is : 143
2015-07-21 11:27:19,559 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0042_01_000004 is : 143
2015-07-21 11:27:19,594 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0042_01_000003 is : 143
2015-07-21 11:27:20,754 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2015-07-21 11:27:20,756 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2015-07-21 11:27:20,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 00:55.072
2015-07-21 11:27:20,800 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1
2015-07-21 11:27:20,811 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2
2015-07-21 11:27:20,835 INFO  util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:27:20,836 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 11:27:20,854 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2015-07-21 11:27:20,854 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:27:20,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:27:20,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-07-21 11:27:20,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-21 11:27:20,866 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup"]
2015-07-21 11:27:20,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-07-21 11:27:20,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-07-21 11:27:20,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-07-21 11:27:20,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2015-07-21 11:27:21,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1437502250126_0043
2015-07-21 11:27:21,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://Marks-MacBook.local:59651/proxy/application_1437502250126_0043/
2015-07-21 11:27:37,587 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0043_01_000003 is : 143
2015-07-21 11:27:37,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0043_01_000002 is : 143
2015-07-21 11:27:37,706 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0043_01_000004 is : 143
2015-07-21 11:27:37,944 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0043_01_000006 is : 143
2015-07-21 11:27:37,984 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437502250126_0043_01_000005 is : 143
2015-07-21 11:27:39,179 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2015-07-21 11:27:39,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:18.311
2015-07-21 11:27:39,222 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup

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]
Jul 21, 2015 11:10:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jul 21, 2015 11:10:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 11:10:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 11:10:50 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 11:10:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:51 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Jul 21, 2015 11:10:51 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 11:10:51 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 11:10:51 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jul 21, 2015 11:10:51 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 11:10:51 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 11:10:51 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:51 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:52 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 11:10:52 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:52 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:52 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 11:10:53 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 11:10:53 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 11:10:53 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 11:10:53 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 11:10:53 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:53 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:53 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:53 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 11:10:54 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 11:10:54 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 11:10:54 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 11:10:54 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 11:10:54 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:54 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:55 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 11:10:55 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.