2015-05-20 17:37:14,742 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 17:37:14,778 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 17:37:14,778 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.hadoop.RiffleCascadePlatformTest
2015-05-20 17:37:14,794 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 17:37:15,541 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-05-20 17:37:16,107 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 17:37:19,579 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-05-20 17:37:19,820 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-05-20 17:37:20,035 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-05-20 17:37:20,238 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-05-20 17:37:37,422 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 8F20AF272AE64DF19447B19960A71CFF
2015-05-20 17:37:37,460 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/children/first
2015-05-20 17:37:37,484 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/stopException/first
2015-05-20 17:37:37,511 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:37:37,512 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:37:37,612 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:37:37,613 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:37:37,645 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:37:37,645 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:37:37,681 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:37:37,681 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:37:37,757 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 17:37:37,758 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:37:37,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:37:37,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first"]
2015-05-20 17:37:37,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:37:37,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:37:37,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:37:37,760 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...eplatform/perpetual/first
2015-05-20 17:37:38,527 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168651833_0001
2015-05-20 17:37:38,527 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0001/
2015-05-20 17:37:54,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0001_01_000005 is : 143
2015-05-20 17:37:54,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0001_01_000003 is : 143
2015-05-20 17:37:54,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0001_01_000002 is : 143
2015-05-20 17:37:54,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0001_01_000004 is : 143
2015-05-20 17:37:55,825 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first/_temporary
2015-05-20 17:37:55,829 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 17:37:55,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first"]
2015-05-20 17:37:55,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second"]
2015-05-20 17:37:55,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 17:37:55,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 17:37:55,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 17:37:55,831 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...platform/perpetual/second
2015-05-20 17:37:55,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432168651833_0002
2015-05-20 17:37:55,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0002/
2015-05-20 17:38:13,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0002_01_000006 is : 143
2015-05-20 17:38:13,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0002_01_000004 is : 143
2015-05-20 17:38:13,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0002_01_000003 is : 143
2015-05-20 17:38:13,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0002_01_000005 is : 143
2015-05-20 17:38:13,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0002_01_000002 is : 143
2015-05-20 17:38:14,767 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second/_temporary
2015-05-20 17:38:14,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-05-20 17:38:14,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second"]
2015-05-20 17:38:14,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third"]
2015-05-20 17:38:14,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-05-20 17:38:14,771 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-05-20 17:38:14,772 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-05-20 17:38:14,772 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...eplatform/perpetual/third
2015-05-20 17:38:14,926 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432168651833_0003
2015-05-20 17:38:14,926 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0003/
2015-05-20 17:38:32,579 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0003_01_000003 is : 143
2015-05-20 17:38:33,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0003_01_000002 is : 143
2015-05-20 17:38:33,266 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0003_01_000007 is : 143
2015-05-20 17:38:33,296 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0003_01_000004 is : 143
2015-05-20 17:38:33,332 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0003_01_000005 is : 143
2015-05-20 17:38:33,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0003_01_000006 is : 143
2015-05-20 17:38:34,605 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third/_temporary
2015-05-20 17:38:34,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-05-20 17:38:34,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third"]
2015-05-20 17:38:34,609 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/fourth"]
2015-05-20 17:38:34,609 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-05-20 17:38:34,609 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-05-20 17:38:34,609 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-05-20 17:38:34,610 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...platform/perpetual/fourth
2015-05-20 17:38:34,744 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1432168651833_0004
2015-05-20 17:38:34,745 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0004/
2015-05-20 17:38:54,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000002 is : 143
2015-05-20 17:38:54,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000005 is : 143
2015-05-20 17:38:54,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000003 is : 143
2015-05-20 17:38:55,101 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000008 is : 143
2015-05-20 17:38:55,123 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000004 is : 143
2015-05-20 17:38:55,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000007 is : 143
2015-05-20 17:38:55,223 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0004_01_000006 is : 143
2015-05-20 17:38:56,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/fourth/_temporary
2015-05-20 17:38:56,456 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/third
2015-05-20 17:38:56,481 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/first
2015-05-20 17:38:56,494 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/second
2015-05-20 17:38:56,508 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/fourth
2015-05-20 17:38:56,558 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:38:56,559 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:38:56,579 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:38:56,579 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:38:56,601 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:38:56,601 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:38:56,624 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:38:56,624 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/soberoi/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-05-20 17:38:56,691 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting
2015-05-20 17:38:56,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] parallel execution is enabled: false
2015-05-20 17:38:56,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flows: 4
2015-05-20 17:38:56,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] allocating threads: 1
2015-05-20 17:38:56,693 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: first
2015-05-20 17:38:56,696 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-05-20 17:38:56,696 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:38:56,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-05-20 17:38:56,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/ips.20.txt"]
2015-05-20 17:38:56,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first"]
2015-05-20 17:38:56,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-05-20 17:38:56,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-05-20 17:38:56,701 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-05-20 17:38:56,702 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...rm/perpetualcascade/first
2015-05-20 17:38:56,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1432168651833_0005
2015-05-20 17:38:56,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0005/
2015-05-20 17:39:11,301 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0005_01_000002 is : 143
2015-05-20 17:39:11,345 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0005_01_000003 is : 143
2015-05-20 17:39:11,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0005_01_000004 is : 143
2015-05-20 17:39:11,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0005_01_000005 is : 143
2015-05-20 17:39:12,698 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first/_temporary
2015-05-20 17:39:12,699 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: first
2015-05-20 17:39:12,699 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: second
2015-05-20 17:39:12,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-05-20 17:39:12,700 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:39:12,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-05-20 17:39:12,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first"]
2015-05-20 17:39:12,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second"]
2015-05-20 17:39:12,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-05-20 17:39:12,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-05-20 17:39:12,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-05-20 17:39:12,705 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...m/perpetualcascade/second
2015-05-20 17:39:12,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1432168651833_0006
2015-05-20 17:39:12,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0006/
2015-05-20 17:39:28,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0006_01_000002 is : 143
2015-05-20 17:39:28,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0006_01_000003 is : 143
2015-05-20 17:39:29,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0006_01_000006 is : 143
2015-05-20 17:39:29,258 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0006_01_000004 is : 143
2015-05-20 17:39:29,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0006_01_000005 is : 143
2015-05-20 17:39:30,530 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second/_temporary
2015-05-20 17:39:30,531 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: second
2015-05-20 17:39:30,531 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: third
2015-05-20 17:39:30,531 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-05-20 17:39:30,531 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:39:30,535 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-05-20 17:39:30,535 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second"]
2015-05-20 17:39:30,536 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third"]
2015-05-20 17:39:30,536 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-05-20 17:39:30,536 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-05-20 17:39:30,536 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-05-20 17:39:30,537 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...rm/perpetualcascade/third
2015-05-20 17:39:30,665 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1432168651833_0007
2015-05-20 17:39:30,666 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0007/
2015-05-20 17:39:48,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0007_01_000002 is : 143
2015-05-20 17:39:48,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0007_01_000003 is : 143
2015-05-20 17:39:48,722 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0007_01_000004 is : 143
2015-05-20 17:39:48,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0007_01_000006 is : 143
2015-05-20 17:39:48,921 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0007_01_000007 is : 143
2015-05-20 17:39:48,994 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0007_01_000005 is : 143
2015-05-20 17:39:50,190 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third/_temporary
2015-05-20 17:39:50,191 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: third
2015-05-20 17:39:50,191 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: fourth
2015-05-20 17:39:50,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-05-20 17:39:50,192 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:39:50,195 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-05-20 17:39:50,195 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third"]
2015-05-20 17:39:50,195 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth"]
2015-05-20 17:39:50,196 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-05-20 17:39:50,196 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-05-20 17:39:50,196 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-05-20 17:39:50,197 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...m/perpetualcascade/fourth
2015-05-20 17:39:50,325 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1432168651833_0008
2015-05-20 17:39:50,325 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://Edinburgh.local:65117/proxy/application_1432168651833_0008/
2015-05-20 17:40:10,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000004 is : 143
2015-05-20 17:40:11,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000003 is : 143
2015-05-20 17:40:11,678 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000007 is : 143
2015-05-20 17:40:11,759 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000002 is : 143
2015-05-20 17:40:11,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000005 is : 143
2015-05-20 17:40:11,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000008 is : 143
2015-05-20 17:40:11,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432168651833_0008_01_000006 is : 143
2015-05-20 17:40:13,145 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth/_temporary
2015-05-20 17:40:13,146 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: fourth
2015-05-20 17:40:13,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second
2015-05-20 17:40:13,187 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third
2015-05-20 17:40:13,207 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first
2015-05-20 17:40:13,218 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth
2015-05-20 17:40:13,254 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/counter/first
2015-05-20 17:40:13,267 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/completeException/first
2015-05-20 17:40:13,283 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/rifflecascadeplatform/startException/first