2015-08-14 08:04:03,710 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 08:04:03,778 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 08:04:03,778 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tap.hadoop.DistCacheTapPlatformTest
2015-08-14 08:04:03,815 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 08:04:04,784 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 08:04:05,672 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 08:04:06,307 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 08:04:10,288 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 08:04:10,507 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 08:04:10,684 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 08:04:10,870 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 08:04:22,815 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 08:04:24,178 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 08:04:24,179 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(166)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 08:04:27,982 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 08:04:28,338 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:04:28,341 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 08:04:28,353 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: A402F89B27CD445F9F64BF295435DD25
2015-08-14 08:04:28,453 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:52407/tmp/distcachetap774083659526543751280204670854876/upper_0.txt to distributed cache
2015-08-14 08:04:28,454 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:52407/tmp/distcachetap774083659526543751280204670854876/upper_1.txt to distributed cache
2015-08-14 08:04:28,455 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:52407/tmp/distcachetap774083659526543751280204670854876/upper_2.txt to distributed cache
2015-08-14 08:04:28,455 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:52407/tmp/distcachetap774083659526543751280204670854876/upper_3.txt to distributed cache
2015-08-14 08:04:28,456 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:52407/tmp/distcachetap774083659526543751280204670854876/upper_4.txt to distributed cache
2015-08-14 08:04:28,619 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 08:04:28,622 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 08:04:28,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/tmp/distcachetap774083659526543751280204670854876/*"]
2015-08-14 08:04:28,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 08:04:28,623 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin"]
2015-08-14 08:04:28,624 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 08:04:28,625 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 08:04:28,625 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 08:04:28,627 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...tform/testGlobSupportjoin
2015-08-14 08:04:29,699 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439539462480_0001
2015-08-14 08:04:29,700 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:53373/proxy/application_1439539462480_0001/
2015-08-14 08:04:45,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0001_01_000005 is : 143
2015-08-14 08:04:45,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0001_01_000003 is : 143
2015-08-14 08:04:45,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0001_01_000002 is : 143
2015-08-14 08:04:46,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0001_01_000004 is : 143
2015-08-14 08:04:47,821 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin/_temporary
2015-08-14 08:04:47,941 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/distcachetapplatform/testGlobSupportjoin
2015-08-14 08:04:48,027 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:04:48,028 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 08:04:48,048 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/distcachetap619928162743424977880224577410733 to distributed cache
2015-08-14 08:04:48,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 08:04:48,068 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/tmp/distcachetap619928162743424977880224577410733"]
2015-08-14 08:04:48,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 08:04:48,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin"]
2015-08-14 08:04:48,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 08:04:48,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 08:04:48,069 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 08:04:48,070 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...latform/testDirectoryjoin
2015-08-14 08:04:48,313 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439539462480_0002
2015-08-14 08:04:48,313 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:53373/proxy/application_1439539462480_0002/
2015-08-14 08:05:02,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0002_01_000006 is : 143
2015-08-14 08:05:03,062 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0002_01_000004 is : 143
2015-08-14 08:05:03,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0002_01_000005 is : 143
2015-08-14 08:05:03,435 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0002_01_000002 is : 143
2015-08-14 08:05:04,318 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0002_01_000003 is : 143
2015-08-14 08:05:05,628 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin/_temporary
2015-08-14 08:05:05,719 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/distcachetapplatform/testDirectoryjoin
2015-08-14 08:05:05,795 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:05:05,796 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 08:05:05,808 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][2239319522/upper/]
2015-08-14 08:05:05,836 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/hadoop-teamcity/2239319522_upper_287DA104656849E6BB1B2B5708683DCF to distributed cache
2015-08-14 08:05:05,856 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:05:05,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 08:05:05,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 08:05:05,859 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/join"]
2015-08-14 08:05:05,860 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:05:05,860 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-14 08:05:05,860 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-14 08:05:05,862 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 08:05:06,071 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539462480_0003
2015-08-14 08:05:06,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:53373/proxy/application_1439539462480_0003/
2015-08-14 08:05:20,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0003_01_000002 is : 143
2015-08-14 08:05:20,740 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0003_01_000004 is : 143
2015-08-14 08:05:20,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0003_01_000006 is : 143
2015-08-14 08:05:20,915 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0003_01_000005 is : 143
2015-08-14 08:05:21,259 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0003_01_000003 is : 143
2015-08-14 08:05:22,556 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...distcachetapplatform/join
2015-08-14 08:05:22,767 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539462480_0004
2015-08-14 08:05:22,767 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:53373/proxy/application_1439539462480_0004/
2015-08-14 08:05:37,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0004_01_000003 is : 143
2015-08-14 08:05:37,097 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0004_01_000002 is : 143
2015-08-14 08:05:37,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0004_01_000006 is : 143
2015-08-14 08:05:37,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0004_01_000005 is : 143
2015-08-14 08:05:37,643 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0004_01_000004 is : 143
2015-08-14 08:05:38,966 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/join/_temporary
2015-08-14 08:05:39,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/distcachetapplatform/join
2015-08-14 08:05:39,087 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:05:39,088 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 08:05:39,102 INFO hadoop.DistCacheTap (DistCacheTap.java:sourceConfInit(74)) - can't use distributed cache. reading '/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt' from hdfs.
2015-08-14 08:05:39,121 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 08:05:39,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 08:05:39,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 08:05:39,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin"]
2015-08-14 08:05:39,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 08:05:39,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 08:05:39,122 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 08:05:39,123 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapLHSjoin
2015-08-14 08:05:39,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439539462480_0005
2015-08-14 08:05:39,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:53373/proxy/application_1439539462480_0005/
2015-08-14 08:05:53,341 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0005_01_000003 is : 143
2015-08-14 08:05:53,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0005_01_000006 is : 143
2015-08-14 08:05:54,020 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0005_01_000005 is : 143
2015-08-14 08:05:54,163 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0005_01_000004 is : 143
2015-08-14 08:05:54,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0005_01_000002 is : 143
2015-08-14 08:05:55,752 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin/_temporary
2015-08-14 08:05:55,828 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin
2015-08-14 08:05:55,869 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:05:55,870 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 08:05:55,886 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt to distributed cache
2015-08-14 08:05:55,901 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 08:05:55,901 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/upper.txt"]
2015-08-14 08:05:55,901 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/classes/test/data/lower.txt"]
2015-08-14 08:05:55,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin"]
2015-08-14 08:05:55,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 08:05:55,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 08:05:55,902 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 08:05:55,903 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapRHSjoin
2015-08-14 08:05:56,136 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439539462480_0006
2015-08-14 08:05:56,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:53373/proxy/application_1439539462480_0006/
2015-08-14 08:06:09,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0006_01_000006 is : 143
2015-08-14 08:06:10,733 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0006_01_000004 is : 143
2015-08-14 08:06:10,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0006_01_000002 is : 143
2015-08-14 08:06:10,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0006_01_000005 is : 143
2015-08-14 08:06:10,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439539462480_0006_01_000003 is : 143
2015-08-14 08:06:12,156 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin/_temporary
2015-08-14 08:06:12,232 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.5.x/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin