2015-05-20 16:02:01,516 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 16:02:01,547 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 16:02:01,547 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tap.hadoop.DistCacheTapPlatformTest
2015-05-20 16:02:01,561 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 16:02:02,193 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 16:02:02,740 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 16:02:05,991 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-05-20 16:02:06,257 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 16:02:06,461 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 16:02:06,647 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 16:02:06,830 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 16:02:24,108 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 16:02:24,109 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 16:02:24,115 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: DF4DE6CED3C54B7A9C53926BB5E45F8B
2015-05-20 16:02:24,159 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:54944/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap74705368696721812061432162943958116000/upper_0.txt to distributed cache
2015-05-20 16:02:24,159 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:54944/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap74705368696721812061432162943958116000/upper_1.txt to distributed cache
2015-05-20 16:02:24,160 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:54944/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap74705368696721812061432162943958116000/upper_2.txt to distributed cache
2015-05-20 16:02:24,161 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:54944/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap74705368696721812061432162943958116000/upper_3.txt to distributed cache
2015-05-20 16:02:24,161 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:54944/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap74705368696721812061432162943958116000/upper_4.txt to distributed cache
2015-05-20 16:02:24,219 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 16:02:24,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 16:02:24,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap74705368696721812061432162943958116000/*"]
2015-05-20 16:02:24,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 16:02:24,220 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin"]
2015-05-20 16:02:24,221 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 16:02:24,221 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 16:02:24,221 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 16:02:24,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...tform/testGlobSupportjoin
2015-05-20 16:02:24,946 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432162938396_0001
2015-05-20 16:02:24,946 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:54973/proxy/application_1432162938396_0001/
2015-05-20 16:02:35,153 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432162938396_0001_01_000008
2015-05-20 16:02:43,433 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0001_01_000002 is : 143
2015-05-20 16:02:43,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0001_01_000006 is : 143
2015-05-20 16:02:44,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0001_01_000004 is : 143
2015-05-20 16:02:44,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0001_01_000005 is : 143
2015-05-20 16:02:44,237 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0001_01_000003 is : 143
2015-05-20 16:02:45,482 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin/_temporary
2015-05-20 16:02:45,562 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/distcachetapplatform/testGlobSupportjoin
2015-05-20 16:02:45,618 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 16:02:45,618 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 16:02:45,630 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap51505552744751302101432162965583360000 to distributed cache
2015-05-20 16:02:45,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 16:02:45,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap51505552744751302101432162965583360000"]
2015-05-20 16:02:45,642 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 16:02:45,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin"]
2015-05-20 16:02:45,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 16:02:45,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 16:02:45,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 16:02:45,644 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...latform/testDirectoryjoin
2015-05-20 16:02:45,817 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432162938396_0002
2015-05-20 16:02:45,817 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:54973/proxy/application_1432162938396_0002/
2015-05-20 16:02:55,251 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1045)) - Event EventType: KILL_CONTAINER sent to absent container container_1432162938396_0002_01_000008
2015-05-20 16:03:02,306 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0002_01_000002 is : 143
2015-05-20 16:03:02,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0002_01_000005 is : 143
2015-05-20 16:03:02,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0002_01_000004 is : 143
2015-05-20 16:03:02,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0002_01_000003 is : 143
2015-05-20 16:03:03,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0002_01_000006 is : 143
2015-05-20 16:03:04,202 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin/_temporary
2015-05-20 16:03:04,254 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/distcachetapplatform/testDirectoryjoin
2015-05-20 16:03:04,303 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 16:03:04,304 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 16:03:04,310 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][7017125577/upper/]
2015-05-20 16:03:04,325 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/hadoop-soberoi/7017125577_upper_DF5AEACED1C54294A9151994E9255D2F to distributed cache
2015-05-20 16:03:04,335 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 16:03:04,335 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 16:03:04,335 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 16:03:04,335 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/join"]
2015-05-20 16:03:04,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 16:03:04,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-05-20 16:03:04,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-05-20 16:03:04,337 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-05-20 16:03:04,461 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432162938396_0003
2015-05-20 16:03:04,461 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:54973/proxy/application_1432162938396_0003/
2015-05-20 16:03:20,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0003_01_000002 is : 143
2015-05-20 16:03:21,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0003_01_000004 is : 143
2015-05-20 16:03:21,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0003_01_000006 is : 143
2015-05-20 16:03:21,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0003_01_000003 is : 143
2015-05-20 16:03:22,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0003_01_000005 is : 143
2015-05-20 16:03:23,441 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...distcachetapplatform/join
2015-05-20 16:03:23,564 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432162938396_0004
2015-05-20 16:03:23,564 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:54973/proxy/application_1432162938396_0004/
2015-05-20 16:03:39,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0004_01_000003 is : 143
2015-05-20 16:03:40,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0004_01_000002 is : 143
2015-05-20 16:03:40,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0004_01_000006 is : 143
2015-05-20 16:03:40,649 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0004_01_000004 is : 143
2015-05-20 16:03:40,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0004_01_000005 is : 143
2015-05-20 16:03:41,866 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/join/_temporary
2015-05-20 16:03:41,915 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/distcachetapplatform/join
2015-05-20 16:03:41,946 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 16:03:41,946 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 16:03:41,954 INFO hadoop.DistCacheTap (DistCacheTap.java:sourceConfInit(74)) - can't use distributed cache. reading '/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt' from hdfs.
2015-05-20 16:03:41,962 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 16:03:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 16:03:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 16:03:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin"]
2015-05-20 16:03:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 16:03:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 16:03:41,963 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 16:03:41,964 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapLHSjoin
2015-05-20 16:03:42,119 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432162938396_0005
2015-05-20 16:03:42,119 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:54973/proxy/application_1432162938396_0005/
2015-05-20 16:03:58,141 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0005_01_000002 is : 143
2015-05-20 16:03:58,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0005_01_000003 is : 143
2015-05-20 16:03:58,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0005_01_000006 is : 143
2015-05-20 16:03:58,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0005_01_000005 is : 143
2015-05-20 16:03:58,684 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0005_01_000004 is : 143
2015-05-20 16:03:59,860 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin/_temporary
2015-05-20 16:03:59,905 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin
2015-05-20 16:03:59,932 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 16:03:59,933 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 16:03:59,941 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt to distributed cache
2015-05-20 16:03:59,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 16:03:59,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-05-20 16:03:59,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-05-20 16:03:59,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin"]
2015-05-20 16:03:59,949 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 16:03:59,949 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 16:03:59,949 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 16:03:59,950 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapRHSjoin
2015-05-20 16:04:00,077 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432162938396_0006
2015-05-20 16:04:00,077 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:54973/proxy/application_1432162938396_0006/
2015-05-20 16:04:16,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0006_01_000002 is : 143
2015-05-20 16:04:16,518 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0006_01_000003 is : 143
2015-05-20 16:04:16,785 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0006_01_000006 is : 143
2015-05-20 16:04:16,931 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0006_01_000004 is : 143
2015-05-20 16:04:16,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(209)) - Exit code from container container_1432162938396_0006_01_000005 is : 143
2015-05-20 16:04:18,150 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin/_temporary
2015-05-20 16:04:18,196 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin