2015-08-14 06:11:27,366 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 06:11:27,429 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 06:11:27,429 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.tap.hadoop.DistCacheTapPlatformTest
2015-08-14 06:11:27,464 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 06:11:28,368 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 06:11:29,235 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 06:11:29,850 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(162)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 06:11:33,747 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 06:11:33,967 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 06:11:34,144 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 06:11:34,337 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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 06:11:51,451 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 06:11:51,772 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:11:51,774 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 06:11:51,786 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: EBC3FCDAA9BF46F198E970646E6D27DC
2015-08-14 06:11:51,886 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:37449/tmp/distcachetap167065745171598410473448137401585/upper_0.txt to distributed cache
2015-08-14 06:11:51,889 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:37449/tmp/distcachetap167065745171598410473448137401585/upper_1.txt to distributed cache
2015-08-14 06:11:51,890 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:37449/tmp/distcachetap167065745171598410473448137401585/upper_2.txt to distributed cache
2015-08-14 06:11:51,891 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:37449/tmp/distcachetap167065745171598410473448137401585/upper_3.txt to distributed cache
2015-08-14 06:11:51,892 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding hdfs://localhost:37449/tmp/distcachetap167065745171598410473448137401585/upper_4.txt to distributed cache
2015-08-14 06:11:52,014 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 06:11:52,015 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 06:11:52,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/tmp/distcachetap167065745171598410473448137401585/*"]
2015-08-14 06:11:52,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/lower.txt"]
2015-08-14 06:11:52,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin"]
2015-08-14 06:11:52,017 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 06:11:52,017 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 06:11:52,017 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 06:11:52,019 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...tform/testGlobSupportjoin
2015-08-14 06:11:53,194 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439532705948_0001
2015-08-14 06:11:53,195 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:55346/proxy/application_1439532705948_0001/
2015-08-14 06:12:12,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0001_01_000003 is : 143
2015-08-14 06:12:12,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0001_01_000005 is : 143
2015-08-14 06:12:12,286 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0001_01_000004 is : 143
2015-08-14 06:12:13,164 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0001_01_000002 is : 143
2015-08-14 06:12:13,182 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0001_01_000006 is : 143
2015-08-14 06:12:14,611 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testGlobSupportjoin/_temporary
2015-08-14 06:12:14,730 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distcachetapplatform/testGlobSupportjoin
2015-08-14 06:12:14,815 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:12:14,816 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 06:12:14,837 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/distcachetap645254497314100991773471367703786 to distributed cache
2015-08-14 06:12:14,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 06:12:14,857 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/tmp/distcachetap645254497314100991773471367703786"]
2015-08-14 06:12:14,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/lower.txt"]
2015-08-14 06:12:14,858 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin"]
2015-08-14 06:12:14,859 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 06:12:14,859 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 06:12:14,859 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 06:12:14,861 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...latform/testDirectoryjoin
2015-08-14 06:12:15,103 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439532705948_0002
2015-08-14 06:12:15,103 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:55346/proxy/application_1439532705948_0002/
2015-08-14 06:12:30,172 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0002_01_000003 is : 143
2015-08-14 06:12:30,285 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0002_01_000004 is : 143
2015-08-14 06:12:30,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0002_01_000002 is : 143
2015-08-14 06:12:30,484 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0002_01_000005 is : 143
2015-08-14 06:12:31,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0002_01_000006 is : 143
2015-08-14 06:12:32,555 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testDirectoryjoin/_temporary
2015-08-14 06:12:32,638 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distcachetapplatform/testDirectoryjoin
2015-08-14 06:12:32,714 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:12:32,715 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 06:12:32,727 INFO planner.FlowPlanner (FlowPlanner.java:decorateTap(686)) - found decorator: cascading.flowconnector.checkpoint_tap.decorator.classname, wrapping tap: TempHfs["null"][1243716664/upper/]
2015-08-14 06:12:32,754 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /tmp/hadoop-teamcity/1243716664_upper_9875411F318B4BF2B1E456AA58993B8D to distributed cache
2015-08-14 06:12:32,773 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 06:12:32,773 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/upper.txt"]
2015-08-14 06:12:32,773 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/lower.txt"]
2015-08-14 06:12:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/join"]
2015-08-14 06:12:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 06:12:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-14 06:12:32,774 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-14 06:12:32,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 06:12:32,981 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439532705948_0003
2015-08-14 06:12:32,981 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55346/proxy/application_1439532705948_0003/
2015-08-14 06:12:46,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0003_01_000003 is : 143
2015-08-14 06:12:47,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0003_01_000002 is : 143
2015-08-14 06:12:47,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0003_01_000004 is : 143
2015-08-14 06:12:47,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0003_01_000006 is : 143
2015-08-14 06:12:47,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0003_01_000005 is : 143
2015-08-14 06:12:49,096 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...distcachetapplatform/join
2015-08-14 06:12:49,314 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439532705948_0004
2015-08-14 06:12:49,314 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55346/proxy/application_1439532705948_0004/
2015-08-14 06:13:03,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0004_01_000006 is : 143
2015-08-14 06:13:04,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0004_01_000003 is : 143
2015-08-14 06:13:04,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0004_01_000004 is : 143
2015-08-14 06:13:04,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0004_01_000002 is : 143
2015-08-14 06:13:04,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0004_01_000005 is : 143
2015-08-14 06:13:05,708 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/join/_temporary
2015-08-14 06:13:05,804 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distcachetapplatform/join
2015-08-14 06:13:05,848 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:13:05,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 06:13:05,866 INFO hadoop.DistCacheTap (DistCacheTap.java:sourceConfInit(74)) - can't use distributed cache. reading '/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/lower.txt' from hdfs.
2015-08-14 06:13:05,882 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 06:13:05,883 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/upper.txt"]
2015-08-14 06:13:05,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.4.x/build/classes/test/data/lower.txt"]
2015-08-14 06:13:05,884 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin"]
2015-08-14 06:13:05,885 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 06:13:05,885 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 06:13:05,886 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 06:13:05,887 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapLHSjoin
2015-08-14 06:13:06,131 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439532705948_0005
2015-08-14 06:13:06,131 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:55346/proxy/application_1439532705948_0005/
2015-08-14 06:13:20,141 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0005_01_000003 is : 143
2015-08-14 06:13:20,299 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0005_01_000002 is : 143
2015-08-14 06:13:20,628 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0005_01_000006 is : 143
2015-08-14 06:13:20,812 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0005_01_000005 is : 143
2015-08-14 06:13:20,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0005_01_000004 is : 143
2015-08-14 06:13:22,260 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin/_temporary
2015-08-14 06:13:22,342 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapLHSjoin
2015-08-14 06:13:22,406 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 06:13:22,407 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 06:13:22,426 INFO hadoop.DistCacheTap (DistCacheTap.java:registerURI(165)) - adding /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/upper.txt to distributed cache
2015-08-14 06:13:22,442 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting
2015-08-14 06:13:22,442 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/upper.txt"]
2015-08-14 06:13:22,442 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/lower.txt"]
2015-08-14 06:13:22,443 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin"]
2015-08-14 06:13:22,443 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] parallel execution is enabled: true
2015-08-14 06:13:22,444 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] starting jobs: 1
2015-08-14 06:13:22,444 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [distcache test] allocating threads: 1
2015-08-14 06:13:22,445 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] starting step: (1/1) ...shJoinDistCacheTapRHSjoin
2015-08-14 06:13:22,650 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] submitted hadoop job: job_1439532705948_0006
2015-08-14 06:13:22,650 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [distcache test] tracking url: http://ip-10-235-34-50:55346/proxy/application_1439532705948_0006/
2015-08-14 06:13:36,605 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0006_01_000002 is : 143
2015-08-14 06:13:36,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0006_01_000003 is : 143
2015-08-14 06:13:37,246 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0006_01_000006 is : 143
2015-08-14 06:13:37,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0006_01_000005 is : 143
2015-08-14 06:13:37,506 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439532705948_0006_01_000004 is : 143
2015-08-14 06:13:38,835 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin/_temporary
2015-08-14 06:13:38,907 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/distcachetapplatform/testHashJoinDistCacheTapRHSjoin