2015-08-14 10:03:46,911 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 10:03:46,979 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 10:03:46,979 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tap.hadoop.DistCacheTapPlatformTest
2015-08-14 10:03:47,014 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 10:03:48,209 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-08-14 10:03:49,097 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 10:03:54,402 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-08-14 10:03:54,709 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-08-14 10:03:54,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-08-14 10:03:55,246 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-08-14 10:04:12,394 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 10:04:12,666 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 10:04:12,667 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 10:04:12,678 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: D030CF7B5B1E43ABBBF9E3B70339C71C
2015-08-14 10:04:12,769 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55244/tmp/distcachetap694208295781194849987389065229427/upper_0.txt to distributed cache
2015-08-14 10:04:12,770 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55244/tmp/distcachetap694208295781194849987389065229427/upper_1.txt to distributed cache
2015-08-14 10:04:12,772 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55244/tmp/distcachetap694208295781194849987389065229427/upper_2.txt to distributed cache
2015-08-14 10:04:12,773 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55244/tmp/distcachetap694208295781194849987389065229427/upper_3.txt to distributed cache
2015-08-14 10:04:12,773 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:55244/tmp/distcachetap694208295781194849987389065229427/upper_4.txt to distributed cache
2015-08-14 10:04:12,884 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 10:04:12,886 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 10:04:12,887 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/tmp/distcachetap694208295781194849987389065229427/*"]
2015-08-14 10:04:12,887 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 10:04:12,887 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin"]
2015-08-14 10:04:12,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 10:04:12,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 10:04:12,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 10:04:12,890 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...tform/testGlobSupportjoin
2015-08-14 10:04:13,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439546646891_0001
2015-08-14 10:04:13,990 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:57334/proxy/application_1439546646891_0001/
2015-08-14 10:04:29,704 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0001_01_000002 is : 143
2015-08-14 10:04:29,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0001_01_000003 is : 143
2015-08-14 10:04:30,454 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0001_01_000006 is : 143
2015-08-14 10:04:30,585 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0001_01_000005 is : 143
2015-08-14 10:04:31,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0001_01_000004 is : 143
2015-08-14 10:04:32,945 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin/_temporary
2015-08-14 10:04:33,069 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/distcachetapplatform/testGlobSupportjoin
2015-08-14 10:04:33,155 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 10:04:33,155 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 10:04:33,176 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/distcachetap675537634515290310487409706143334 to distributed cache
2015-08-14 10:04:33,198 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 10:04:33,198 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/tmp/distcachetap675537634515290310487409706143334"]
2015-08-14 10:04:33,199 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 10:04:33,199 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin"]
2015-08-14 10:04:33,199 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 10:04:33,199 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 10:04:33,199 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 10:04:33,200 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...latform/testDirectoryjoin
2015-08-14 10:04:33,427 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439546646891_0002
2015-08-14 10:04:33,428 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:57334/proxy/application_1439546646891_0002/
2015-08-14 10:04:48,743 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0002_01_000002 is : 143
2015-08-14 10:04:49,359 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0002_01_000006 is : 143
2015-08-14 10:04:49,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0002_01_000005 is : 143
2015-08-14 10:04:49,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0002_01_000004 is : 143
2015-08-14 10:04:50,918 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin/_temporary
2015-08-14 10:04:51,013 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/distcachetapplatform/testDirectoryjoin
2015-08-14 10:04:51,091 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 10:04:51,092 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 10:04:51,106 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][2921215063/upper/]
2015-08-14 10:04:51,134 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/hadoop-teamcity/2921215063_upper_38E2F3220CE74905AD39B65E46D21AE3 to distributed cache
2015-08-14 10:04:51,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 10:04:51,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]
2015-08-14 10:04:51,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 10:04:51,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/join"]
2015-08-14 10:04:51,156 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 10:04:51,156 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-14 10:04:51,156 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-14 10:04:51,158 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 10:04:51,354 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439546646891_0003
2015-08-14 10:04:51,354 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:57334/proxy/application_1439546646891_0003/
2015-08-14 10:05:06,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0003_01_000003 is : 143
2015-08-14 10:05:06,522 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0003_01_000002 is : 143
2015-08-14 10:05:07,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0003_01_000005 is : 143
2015-08-14 10:05:07,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0003_01_000006 is : 143
2015-08-14 10:05:07,368 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0003_01_000004 is : 143
2015-08-14 10:05:08,621 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...distcachetapplatform/join
2015-08-14 10:05:08,811 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439546646891_0004
2015-08-14 10:05:08,811 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:57334/proxy/application_1439546646891_0004/
2015-08-14 10:05:24,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0004_01_000006 is : 143
2015-08-14 10:05:25,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0004_01_000003 is : 143
2015-08-14 10:05:25,312 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0004_01_000002 is : 143
2015-08-14 10:05:25,353 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0004_01_000004 is : 143
2015-08-14 10:05:25,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0004_01_000005 is : 143
2015-08-14 10:05:26,697 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/join/_temporary
2015-08-14 10:05:26,779 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/distcachetapplatform/join
2015-08-14 10:05:26,848 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 10:05:26,849 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 10:05:26,865 INFO hadoop.DistCacheTap (DistCacheTap.java:sourceConfInit(74)) - can't use distributed cache. reading '/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt' from hdfs.
2015-08-14 10:05:26,883 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 10:05:26,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]
2015-08-14 10:05:26,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 10:05:26,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin"]
2015-08-14 10:05:26,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 10:05:26,885 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 10:05:26,885 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 10:05:26,886 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapLHSjoin
2015-08-14 10:05:27,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439546646891_0005
2015-08-14 10:05:27,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:57334/proxy/application_1439546646891_0005/
2015-08-14 10:05:43,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0005_01_000006 is : 143
2015-08-14 10:05:43,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0005_01_000002 is : 143
2015-08-14 10:05:43,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0005_01_000005 is : 143
2015-08-14 10:05:43,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0005_01_000004 is : 143
2015-08-14 10:05:44,565 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin/_temporary
2015-08-14 10:05:44,647 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin
2015-08-14 10:05:44,692 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 10:05:44,693 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 10:05:44,707 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt to distributed cache
2015-08-14 10:05:44,720 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 10:05:44,721 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/upper.txt"]
2015-08-14 10:05:44,721 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 10:05:44,721 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin"]
2015-08-14 10:05:44,721 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 10:05:44,721 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 10:05:44,722 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 10:05:44,722 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapRHSjoin
2015-08-14 10:05:44,890 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439546646891_0006
2015-08-14 10:05:44,891 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:57334/proxy/application_1439546646891_0006/
2015-08-14 10:06:00,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0006_01_000003 is : 143
2015-08-14 10:06:00,424 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0006_01_000002 is : 143
2015-08-14 10:06:00,861 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0006_01_000005 is : 143
2015-08-14 10:06:00,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0006_01_000006 is : 143
2015-08-14 10:06:00,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439546646891_0006_01_000004 is : 143
2015-08-14 10:06:02,193 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin/_temporary
2015-08-14 10:06:02,271 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin