2015-05-20 17:56:38,360 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 17:56:38,398 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 17:56:38,398 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.stats.hadoop.CascadingStatsPlatformTest
2015-05-20 17:56:38,415 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 17:56:39,135 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:56:39,657 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 17:56:42,965 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:56:43,167 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:56:43,334 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:56:43,501 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:57:00,676 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:57:00,677 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:57:00,683 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 278CF7B2547C4D24B6E7EF622AC52C87
2015-05-20 17:57:00,795 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 17:57:00,796 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:57:00,832 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 17:57:00,833 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting
2015-05-20 17:57:00,835 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] parallel execution is enabled: true
2015-05-20 17:57:00,836 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flows: 2
2015-05-20 17:57:00,836 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] allocating threads: 2
2015-05-20 17:57:00,836 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flow: stats1 test
2015-05-20 17:57:00,836 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flow: stats2 test
2015-05-20 17:57:00,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] at least one sink is marked for delete
2015-05-20 17:57:00,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] at least one sink is marked for delete
2015-05-20 17:57:00,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:57:00,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 17:57:00,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] starting
2015-05-20 17:57:00,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] starting
2015-05-20 17:57:00,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 17:57:00,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/apache.10.txt"]
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats2"]
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats1"]
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] parallel execution is enabled: true
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] starting jobs: 2
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] parallel execution is enabled: true
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] allocating threads: 2
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] starting jobs: 2
2015-05-20 17:57:00,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] allocating threads: 2
2015-05-20 17:57:00,860 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] starting step: (1/2)
2015-05-20 17:57:00,860 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] starting step: (1/2)
2015-05-20 17:57:01,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] submitted hadoop job: job_1432169815085_0001
2015-05-20 17:57:01,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] tracking url: http://Edinburgh.local:53889/proxy/application_1432169815085_0001/
2015-05-20 17:57:01,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] submitted hadoop job: job_1432169815085_0002
2015-05-20 17:57:01,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] tracking url: http://Edinburgh.local:53889/proxy/application_1432169815085_0002/
2015-05-20 17:57:27,605 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0002_01_000004 is : 143
2015-05-20 17:57:27,795 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0001_01_000003 is : 143
2015-05-20 17:57:27,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0001_01_000002 is : 143
2015-05-20 17:57:27,933 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0001_01_000004 is : 143
2015-05-20 17:57:27,969 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0002_01_000002 is : 143
2015-05-20 17:57:28,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0002_01_000005 is : 143
2015-05-20 17:57:28,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0001_01_000005 is : 143
2015-05-20 17:57:28,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0002_01_000003 is : 143
2015-05-20 17:57:35,134 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0002_01_000006 is : 143
2015-05-20 17:57:35,194 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0001_01_000006 is : 143
2015-05-20 17:57:36,439 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] starting step: (2/2) ...gstatsplatform/flowstats2
2015-05-20 17:57:36,469 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] starting step: (2/2) ...gstatsplatform/flowstats1
2015-05-20 17:57:36,646 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] submitted hadoop job: job_1432169815085_0003
2015-05-20 17:57:36,647 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] tracking url: http://Edinburgh.local:53889/proxy/application_1432169815085_0003/
2015-05-20 17:57:36,686 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] submitted hadoop job: job_1432169815085_0004
2015-05-20 17:57:36,686 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] tracking url: http://Edinburgh.local:53889/proxy/application_1432169815085_0004/
2015-05-20 17:57:54,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0003_01_000002 is : 143
2015-05-20 17:57:54,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0004_01_000002 is : 143
2015-05-20 17:58:01,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0004_01_000003 is : 143
2015-05-20 17:58:02,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432169815085_0003_01_000003 is : 143
2015-05-20 17:58:02,921 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats1/_temporary
2015-05-20 17:58:02,922 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] completed flow: stats1 test
2015-05-20 17:58:03,194 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats2/_temporary
2015-05-20 17:58:03,195 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] completed flow: stats2 test
2015-05-20 17:58:10,076 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadingstatsplatform/flowstats2
2015-05-20 17:58:10,083 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/cascadingstatsplatform/flowstats1