2015-07-17 15:32:15,997 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 15:32:16,014 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 15:32:16,015 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.stats.hadoop.CascadingStatsPlatformTest
2015-07-17 15:32:16,037 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 15:32:16,818 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-17 15:32:17,310 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 15:32:20,811 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-17 15:32:21,031 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-17 15:32:21,217 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-17 15:32:21,418 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-17 15:32:38,561 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-07-17 15:32:38,635 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:32:38,636 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:32:38,642 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 60996B000D6E4B12BA911AAA8497BA3A
2015-07-17 15:32:38,752 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 15:32:38,752 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 15:32:38,788 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 15:32:38,788 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting
2015-07-17 15:32:38,791 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] parallel execution is enabled: true
2015-07-17 15:32:38,791 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flows: 2
2015-07-17 15:32:38,791 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] allocating threads: 2
2015-07-17 15:32:38,792 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flow: stats2 test
2015-07-17 15:32:38,792 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flow: stats1 test
2015-07-17 15:32:38,793 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] at least one sink is marked for delete
2015-07-17 15:32:38,793 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] at least one sink is marked for delete
2015-07-17 15:32:38,794 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:32:38,794 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-07-17 15:32:38,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] starting
2015-07-17 15:32:38,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] starting
2015-07-17 15:32:38,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:32:38,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 15:32:38,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats2"]
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats1"]
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] parallel execution is enabled: true
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] parallel execution is enabled: true
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] starting jobs: 2
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] allocating threads: 2
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] starting jobs: 2
2015-07-17 15:32:38,816 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] allocating threads: 2
2015-07-17 15:32:38,818 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] starting step: (1/2)
2015-07-17 15:32:38,818 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] starting step: (1/2)
2015-07-17 15:32:39,747 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] submitted hadoop job: job_1437172353011_0002
2015-07-17 15:32:39,747 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] submitted hadoop job: job_1437172353011_0001
2015-07-17 15:32:39,748 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] tracking url: http://Marks-MacBook.local:62882/proxy/application_1437172353011_0002/
2015-07-17 15:32:39,748 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] tracking url: http://Marks-MacBook.local:62882/proxy/application_1437172353011_0001/
2015-07-17 15:33:04,512 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0002_01_000005 is : 143
2015-07-17 15:33:04,709 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0001_01_000003 is : 143
2015-07-17 15:33:04,852 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0002_01_000004 is : 143
2015-07-17 15:33:04,890 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0002_01_000003 is : 143
2015-07-17 15:33:04,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0002_01_000002 is : 143
2015-07-17 15:33:05,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0001_01_000005 is : 143
2015-07-17 15:33:05,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0001_01_000002 is : 143
2015-07-17 15:33:05,248 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0001_01_000004 is : 143
2015-07-17 15:33:11,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0001_01_000006 is : 143
2015-07-17 15:33:12,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0002_01_000006 is : 143
2015-07-17 15:33:13,153 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] starting step: (2/2) ...gstatsplatform/flowstats1
2015-07-17 15:33:13,338 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] submitted hadoop job: job_1437172353011_0003
2015-07-17 15:33:13,338 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] tracking url: http://Marks-MacBook.local:62882/proxy/application_1437172353011_0003/
2015-07-17 15:33:13,468 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] starting step: (2/2) ...gstatsplatform/flowstats2
2015-07-17 15:33:13,618 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] submitted hadoop job: job_1437172353011_0004
2015-07-17 15:33:13,619 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] tracking url: http://Marks-MacBook.local:62882/proxy/application_1437172353011_0004/
2015-07-17 15:33:30,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0003_01_000002 is : 143
2015-07-17 15:33:31,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0004_01_000002 is : 143
2015-07-17 15:33:37,949 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0003_01_000003 is : 143
2015-07-17 15:33:38,907 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437172353011_0004_01_000003 is : 143
2015-07-17 15:33:39,175 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats1/_temporary
2015-07-17 15:33:39,176 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] completed flow: stats1 test
2015-07-17 15:33:40,114 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats2/_temporary
2015-07-17 15:33:40,115 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] completed flow: stats2 test
2015-07-17 15:33:47,008 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadingstatsplatform/flowstats1
2015-07-17 15:33:47,017 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cascadingstatsplatform/flowstats2