2015-05-20 15:56:12,823 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 15:56:12,854 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 15:56:12,854 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.stats.hadoop.CascadingStatsPlatformTest
2015-05-20 15:56:12,869 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 15:56:13,452 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 15:56:13,984 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 15:56:17,116 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 15:56:17,382 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 15:56:17,590 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 15:56:17,776 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 15:56:17,963 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 15:56:35,123 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:56:35,124 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 15:56:35,130 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 1BB8041ADF49444AB466F97A9D57A5BA
2015-05-20 15:56:35,240 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 15:56:35,240 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 15:56:35,276 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 15:56:35,276 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting
2015-05-20 15:56:35,279 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] parallel execution is enabled: true
2015-05-20 15:56:35,279 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flows: 2
2015-05-20 15:56:35,280 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] allocating threads: 2
2015-05-20 15:56:35,280 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flow: stats1 test
2015-05-20 15:56:35,280 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] starting flow: stats2 test
2015-05-20 15:56:35,281 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] at least one sink is marked for delete
2015-05-20 15:56:35,282 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] at least one sink is marked for delete
2015-05-20 15:56:35,282 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:56:35,282 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] sink oldest modified date: Wed Dec 31 15:59:59 PST 1969
2015-05-20 15:56:35,300 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] starting
2015-05-20 15:56:35,300 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] starting
2015-05-20 15:56:35,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:56:35,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-05-20 15:56:35,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats1"]
2015-05-20 15:56:35,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats2"]
2015-05-20 15:56:35,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] parallel execution is enabled: true
2015-05-20 15:56:35,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] parallel execution is enabled: true
2015-05-20 15:56:35,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] starting jobs: 2
2015-05-20 15:56:35,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] starting jobs: 2
2015-05-20 15:56:35,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats2 test] allocating threads: 2
2015-05-20 15:56:35,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [stats1 test] allocating threads: 2
2015-05-20 15:56:35,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] starting step: (1/2)
2015-05-20 15:56:35,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] starting step: (1/2)
2015-05-20 15:56:36,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] submitted hadoop job: job_1432162589530_0001
2015-05-20 15:56:36,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] tracking url: http://Edinburgh.local:53151/proxy/application_1432162589530_0001/
2015-05-20 15:56:36,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] submitted hadoop job: job_1432162589530_0002
2015-05-20 15:56:36,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] tracking url: http://Edinburgh.local:53151/proxy/application_1432162589530_0002/
2015-05-20 15:56:47,545 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432162589530_0001_01_000006
2015-05-20 15:56:48,351 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432162589530_0002_01_000008
2015-05-20 15:57:01,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0001_01_000003 is : 143
2015-05-20 15:57:01,385 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0002_01_000003 is : 143
2015-05-20 15:57:01,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0001_01_000004 is : 143
2015-05-20 15:57:01,739 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0001_01_000005 is : 143
2015-05-20 15:57:01,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0001_01_000002 is : 143
2015-05-20 15:57:01,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0002_01_000005 is : 143
2015-05-20 15:57:01,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0002_01_000002 is : 143
2015-05-20 15:57:01,972 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0002_01_000004 is : 143
2015-05-20 15:57:08,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0001_01_000007 is : 143
2015-05-20 15:57:08,913 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0002_01_000009 is : 143
2015-05-20 15:57:09,611 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] starting step: (2/2) ...gstatsplatform/flowstats1
2015-05-20 15:57:09,785 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] submitted hadoop job: job_1432162589530_0003
2015-05-20 15:57:09,785 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats1 test] tracking url: http://Edinburgh.local:53151/proxy/application_1432162589530_0003/
2015-05-20 15:57:10,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] starting step: (2/2) ...gstatsplatform/flowstats2
2015-05-20 15:57:10,353 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] submitted hadoop job: job_1432162589530_0004
2015-05-20 15:57:10,353 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [stats2 test] tracking url: http://Edinburgh.local:53151/proxy/application_1432162589530_0004/
2015-05-20 15:57:16,001 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1061)) - Event EventType: FINISH_APPLICATION sent to absent application application_1432162589530_0001
2015-05-20 15:57:21,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0003_01_000002 is : 143
2015-05-20 15:57:22,684 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0004_01_000003 is : 143
2015-05-20 15:57:28,171 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0003_01_000003 is : 143
2015-05-20 15:57:29,423 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats1/_temporary
2015-05-20 15:57:29,424 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] completed flow: stats1 test
2015-05-20 15:57:29,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162589530_0004_01_000004 is : 143
2015-05-20 15:57:30,757 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cascadingstatsplatform/flowstats2/_temporary
2015-05-20 15:57:30,758 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [stats1 test+stats2 test] completed flow: stats2 test
2015-05-20 15:57:37,680 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cascadingstatsplatform/flowstats2
2015-05-20 15:57:37,686 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cascadingstatsplatform/flowstats1