2015-05-20 18:02:51,610 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-05-20 18:02:51,647 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-05-20 18:02:51,647 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tap.hadoop.DistCacheTapPlatformTest
2015-05-20 18:02:51,661 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-05-20 18:02:52,418 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 18:02:52,917 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-05-20 18:02:56,393 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 18:02:56,607 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 18:02:56,794 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 18:02:56,973 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 18:03:14,268 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:03:14,269 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 18:03:14,275 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: CAA2EC1C89E444C89533132A87D73AE5
2015-05-20 18:03:14,324 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55654/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap19605390374683467581432170194126624000/upper_0.txt to distributed cache
2015-05-20 18:03:14,325 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55654/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap19605390374683467581432170194126624000/upper_1.txt to distributed cache
2015-05-20 18:03:14,325 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55654/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap19605390374683467581432170194126624000/upper_2.txt to distributed cache
2015-05-20 18:03:14,326 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55654/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap19605390374683467581432170194126624000/upper_3.txt to distributed cache
2015-05-20 18:03:14,327 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55654/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap19605390374683467581432170194126624000/upper_4.txt to distributed cache
2015-05-20 18:03:14,398 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-05-20 18:03:14,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 18:03:14,400 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap19605390374683467581432170194126624000/*"]
2015-05-20 18:03:14,400 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:03:14,400 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin"]
2015-05-20 18:03:14,400 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 18:03:14,401 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 18:03:14,401 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 18:03:14,402 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...tform/testGlobSupportjoin
2015-05-20 18:03:15,171 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432170188569_0001
2015-05-20 18:03:15,171 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:55682/proxy/application_1432170188569_0001/
2015-05-20 18:03:32,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0001_01_000006 is : 143
2015-05-20 18:03:32,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0001_01_000004 is : 143
2015-05-20 18:03:33,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0001_01_000005 is : 143
2015-05-20 18:03:33,074 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0001_01_000002 is : 143
2015-05-20 18:03:33,178 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0001_01_000003 is : 143
2015-05-20 18:03:34,442 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin/_temporary
2015-05-20 18:03:34,520 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/distcachetapplatform/testGlobSupportjoin
2015-05-20 18:03:34,576 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:03:34,576 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 18:03:34,590 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap57742615361476786401432170214540886000 to distributed cache
2015-05-20 18:03:34,602 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 18:03:34,602 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/var/folders/_h/41_y71bx1bx0783m72f26_t80000gn/T/distcachetap57742615361476786401432170214540886000"]
2015-05-20 18:03:34,603 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:03:34,603 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin"]
2015-05-20 18:03:34,603 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 18:03:34,603 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 18:03:34,604 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 18:03:34,605 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...latform/testDirectoryjoin
2015-05-20 18:03:34,750 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432170188569_0002
2015-05-20 18:03:34,750 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:55682/proxy/application_1432170188569_0002/
2015-05-20 18:03:51,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0002_01_000004 is : 143
2015-05-20 18:03:51,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0002_01_000002 is : 143
2015-05-20 18:03:51,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0002_01_000003 is : 143
2015-05-20 18:03:51,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0002_01_000006 is : 143
2015-05-20 18:03:52,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0002_01_000005 is : 143
2015-05-20 18:03:53,349 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin/_temporary
2015-05-20 18:03:53,410 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/distcachetapplatform/testDirectoryjoin
2015-05-20 18:03:53,457 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:03:53,458 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 18:03:53,467 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][9259299735/upper/]
2015-05-20 18:03:53,482 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/hadoop-soberoi/9259299735_upper_DF15CAE1A1C14E97AAC84B41B9DE4E03 to distributed cache
2015-05-20 18:03:53,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-05-20 18:03:53,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 18:03:53,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:03:53,491 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/join"]
2015-05-20 18:03:53,492 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-05-20 18:03:53,492 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-05-20 18:03:53,492 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-05-20 18:03:53,494 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-05-20 18:03:53,628 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432170188569_0003
2015-05-20 18:03:53,628 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:55682/proxy/application_1432170188569_0003/
2015-05-20 18:04:11,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0003_01_000002 is : 143
2015-05-20 18:04:11,423 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0003_01_000006 is : 143
2015-05-20 18:04:11,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0003_01_000003 is : 143
2015-05-20 18:04:11,528 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0003_01_000005 is : 143
2015-05-20 18:04:11,656 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0003_01_000004 is : 143
2015-05-20 18:04:12,850 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...distcachetapplatform/join
2015-05-20 18:04:12,995 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1432170188569_0004
2015-05-20 18:04:12,995 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Edinburgh.local:55682/proxy/application_1432170188569_0004/
2015-05-20 18:04:29,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0004_01_000002 is : 143
2015-05-20 18:04:29,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0004_01_000003 is : 143
2015-05-20 18:04:30,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0004_01_000006 is : 143
2015-05-20 18:04:30,251 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0004_01_000004 is : 143
2015-05-20 18:04:30,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0004_01_000005 is : 143
2015-05-20 18:04:31,528 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/join/_temporary
2015-05-20 18:04:31,580 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/distcachetapplatform/join
2015-05-20 18:04:31,612 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:04:31,612 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 18:04:31,624 INFO hadoop.DistCacheTap (DistCacheTap.java:sourceConfInit(74)) - can't use distributed cache. reading '/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt' from hdfs.
2015-05-20 18:04:31,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 18:04:31,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 18:04:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:04:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin"]
2015-05-20 18:04:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 18:04:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 18:04:31,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 18:04:31,637 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapLHSjoin
2015-05-20 18:04:31,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432170188569_0005
2015-05-20 18:04:31,773 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:55682/proxy/application_1432170188569_0005/
2015-05-20 18:04:48,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0005_01_000003 is : 143
2015-05-20 18:04:48,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0005_01_000002 is : 143
2015-05-20 18:04:48,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0005_01_000006 is : 143
2015-05-20 18:04:48,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0005_01_000005 is : 143
2015-05-20 18:04:48,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0005_01_000004 is : 143
2015-05-20 18:04:49,918 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin/_temporary
2015-05-20 18:04:49,975 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin
2015-05-20 18:04:50,010 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-05-20 18:04:50,011 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 18:04:50,023 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt to distributed cache
2015-05-20 18:04:50,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-05-20 18:04:50,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/upper.txt"]
2015-05-20 18:04:50,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/classes/test/data/lower.txt"]
2015-05-20 18:04:50,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin"]
2015-05-20 18:04:50,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-05-20 18:04:50,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-05-20 18:04:50,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-05-20 18:04:50,036 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapRHSjoin
2015-05-20 18:04:50,160 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1432170188569_0006
2015-05-20 18:04:50,161 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://Edinburgh.local:55682/proxy/application_1432170188569_0006/
2015-05-20 18:05:08,826 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0006_01_000002 is : 143
2015-05-20 18:05:08,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0006_01_000003 is : 143
2015-05-20 18:05:09,010 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0006_01_000006 is : 143
2015-05-20 18:05:09,154 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0006_01_000005 is : 143
2015-05-20 18:05:09,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(224)) - Exit code from container container_1432170188569_0006_01_000004 is : 143
2015-05-20 18:05:10,406 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin/_temporary
2015-05-20 18:05:10,456 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/soberoi/src/compatibility/cascading.compatibility/horton/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin