2015-08-14 08:10:15,282 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 08:10:15,349 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 08:10:15,350 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.JoinFieldedPipesPlatformTest
2015-08-14 08:10:15,395 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 08:10:16,567 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:10:17,441 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 08:10:22,632 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:10:22,935 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:10:23,194 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:10:23,472 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:10:40,789 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:10:40,791 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:10:40,804 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 41FF83D683194D7FA79186747416E597
2015-08-14 08:10:41,004 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 08:10:41,006 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:10:41,006 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 08:10:41,008 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-offset.txt"]
2015-08-14 08:10:41,008 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/joinfieldedpipesplatform/joininnersingle"]
2015-08-14 08:10:41,009 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:10:41,009 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:10:41,009 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:10:41,010 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...splatform/joininnersingle
2015-08-14 08:10:42,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0001
2015-08-14 08:10:42,165 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0001/
2015-08-14 08:10:57,562 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0001_01_000003 is : 143
2015-08-14 08:10:58,235 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0001_01_000004 is : 143
2015-08-14 08:10:58,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0001_01_000005 is : 143
2015-08-14 08:10:59,773 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/joinfieldedpipesplatform/joininnersingle/_temporary
2015-08-14 08:10:59,900 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/joinfieldedpipesplatform/joininnersingle
2015-08-14 08:10:59,990 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:10:59,991 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:11:00,076 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting
2015-08-14 08:11:00,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] 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 08:11:00,077 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] 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 08:11:00,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] 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 08:11:00,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost"]
2015-08-14 08:11:00,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] parallel execution is enabled: true
2015-08-14 08:11:00,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting jobs: 2
2015-08-14 08:11:00,078 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] allocating threads: 2
2015-08-14 08:11:00,079 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (2/2)
2015-08-14 08:11:00,297 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1439539835121_0002
2015-08-14 08:11:00,298 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0002/
2015-08-14 08:11:15,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0002_01_000006 is : 143
2015-08-14 08:11:15,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0002_01_000004 is : 143
2015-08-14 08:11:16,197 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0002_01_000002 is : 143
2015-08-14 08:11:16,266 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0002_01_000003 is : 143
2015-08-14 08:11:16,335 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0002_01_000005 is : 143
2015-08-14 08:11:17,610 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (1/2) ...rm/joinaroundjoinleftmost
2015-08-14 08:11:17,805 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1439539835121_0003
2015-08-14 08:11:17,806 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0003/
2015-08-14 08:11:33,304 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0003_01_000003 is : 143
2015-08-14 08:11:33,386 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0003_01_000002 is : 143
2015-08-14 08:11:33,942 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0003_01_000006 is : 143
2015-08-14 08:11:34,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0003_01_000005 is : 143
2015-08-14 08:11:34,179 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0003_01_000004 is : 143
2015-08-14 08:11:35,444 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/joinfieldedpipesplatform/joinaroundjoinleftmost/_temporary
2015-08-14 08:11:35,531 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/joinfieldedpipesplatform/joinaroundjoinleftmost
2015-08-14 08:11:35,585 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:11:35,586 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:11:35,624 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting
2015-08-14 08:11:35,625 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] 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 08:11:35,626 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] 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 08:11:35,626 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes"]
2015-08-14 08:11:35,627 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] parallel execution is enabled: true
2015-08-14 08:11:35,627 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting jobs: 1
2015-08-14 08:11:35,628 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] allocating threads: 1
2015-08-14 08:11:35,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] starting step: (1/1) ...ipesplatform/renamedpipes
2015-08-14 08:11:35,816 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] submitted hadoop job: job_1439539835121_0004
2015-08-14 08:11:35,816 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0004/
2015-08-14 08:11:51,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0004_01_000003 is : 143
2015-08-14 08:11:51,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0004_01_000002 is : 143
2015-08-14 08:11:51,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0004_01_000006 is : 143
2015-08-14 08:11:51,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0004_01_000004 is : 143
2015-08-14 08:11:51,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0004_01_000005 is : 143
2015-08-14 08:11:53,141 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/joinfieldedpipesplatform/renamedpipes/_temporary
2015-08-14 08:11:53,229 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/joinfieldedpipesplatform/renamedpipes
2015-08-14 08:11:53,283 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:11:53,284 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:11:53,354 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:11:53,354 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 08:11:53,355 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 08:11:53,355 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/joinfieldedpipesplatform/afterevery"]
2015-08-14 08:11:53,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:11:53,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-14 08:11:53,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-14 08:11:53,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-14 08:11:53,358 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-14 08:11:53,636 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0005
2015-08-14 08:11:53,637 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0005/
2015-08-14 08:11:53,637 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0006
2015-08-14 08:11:53,637 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0006/
2015-08-14 08:12:11,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0006_01_000002 is : 143
2015-08-14 08:12:11,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0006_01_000006 is : 143
2015-08-14 08:12:11,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0006_01_000005 is : 143
2015-08-14 08:12:16,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0005_01_000002 is : 143
2015-08-14 08:12:16,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0005_01_000003 is : 143
2015-08-14 08:12:18,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0005_01_000004 is : 143
2015-08-14 08:12:18,112 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0005_01_000005 is : 143
2015-08-14 08:12:18,191 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0005_01_000006 is : 143
2015-08-14 08:12:20,272 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0006_01_000007 is : 143
2015-08-14 08:12:24,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0005_01_000007 is : 143
2015-08-14 08:12:26,164 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...dpipesplatform/afterevery
2015-08-14 08:12:26,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0007
2015-08-14 08:12:26,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0007/
2015-08-14 08:12:41,119 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0007_01_000002 is : 143
2015-08-14 08:12:42,376 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/joinfieldedpipesplatform/afterevery/_temporary
2015-08-14 08:12:42,430 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/joinfieldedpipesplatform/afterevery
2015-08-14 08:12:42,501 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:12:42,502 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:12:42,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 08:12:42,560 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:12:42,561 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:12:42,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs.txt"]
2015-08-14 08:12:42,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs.txt"]
2015-08-14 08:12:42,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin"]
2015-08-14 08:12:42,564 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-14 08:12:42,564 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 1
2015-08-14 08:12:42,565 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 1
2015-08-14 08:12:42,567 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-08-14 08:12:42,733 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439539835121_0008
2015-08-14 08:12:42,733 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0008/
2015-08-14 08:12:57,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0008_01_000002 is : 143
2015-08-14 08:12:58,066 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0008_01_000003 is : 143
2015-08-14 08:12:58,706 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0008_01_000004 is : 143
2015-08-14 08:12:58,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0008_01_000006 is : 143
2015-08-14 08:12:58,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0008_01_000005 is : 143
2015-08-14 08:13:05,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0008_01_000007 is : 143
2015-08-14 08:13:06,948 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/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin/_temporary
2015-08-14 08:13:07,004 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/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin
2015-08-14 08:13:07,042 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:13:07,043 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:13:07,104 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 08:13:07,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:13:07,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:13:07,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs.txt"]
2015-08-14 08:13:07,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs.txt"]
2015-08-14 08:13:07,108 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs"]
2015-08-14 08:13:07,109 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-14 08:13:07,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 2
2015-08-14 08:13:07,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 2
2015-08-14 08:13:07,112 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-08-14 08:13:07,648 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439539835121_0009
2015-08-14 08:13:07,649 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0009/
2015-08-14 08:13:23,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0009_01_000003 is : 143
2015-08-14 08:13:23,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0009_01_000005 is : 143
2015-08-14 08:13:23,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0009_01_000006 is : 143
2015-08-14 08:13:23,520 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0009_01_000002 is : 143
2015-08-14 08:13:23,642 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0009_01_000004 is : 143
2015-08-14 08:13:24,884 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouplhs
2015-08-14 08:13:25,082 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439539835121_0010
2015-08-14 08:13:25,083 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0010/
2015-08-14 08:13:40,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0010_01_000002 is : 143
2015-08-14 08:13:40,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0010_01_000004 is : 143
2015-08-14 08:13:40,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0010_01_000005 is : 143
2015-08-14 08:13:41,009 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0010_01_000006 is : 143
2015-08-14 08:13:47,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0010_01_000007 is : 143
2015-08-14 08:13:49,040 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/joinfieldedpipesplatform/joinsintocogrouplhs/_temporary
2015-08-14 08:13:49,097 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/joinfieldedpipesplatform/joinsintocogrouplhs
2015-08-14 08:13:49,136 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:13:49,137 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:13:49,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 08:13:49,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:13:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:13:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs.txt"]
2015-08-14 08:13:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs.txt"]
2015-08-14 08:13:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs"]
2015-08-14 08:13:49,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-14 08:13:49,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 2
2015-08-14 08:13:49,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 2
2015-08-14 08:13:49,216 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-08-14 08:13:49,372 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439539835121_0011
2015-08-14 08:13:49,372 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0011/
2015-08-14 08:14:05,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0011_01_000005 is : 143
2015-08-14 08:14:05,210 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0011_01_000006 is : 143
2015-08-14 08:14:05,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0011_01_000004 is : 143
2015-08-14 08:14:05,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0011_01_000003 is : 143
2015-08-14 08:14:05,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0011_01_000002 is : 143
2015-08-14 08:14:06,703 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouprhs
2015-08-14 08:14:06,862 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439539835121_0012
2015-08-14 08:14:06,863 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0012/
2015-08-14 08:14:22,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0012_01_000006 is : 143
2015-08-14 08:14:22,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0012_01_000004 is : 143
2015-08-14 08:14:22,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0012_01_000005 is : 143
2015-08-14 08:14:22,884 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0012_01_000003 is : 143
2015-08-14 08:14:22,961 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0012_01_000002 is : 143
2015-08-14 08:14:29,530 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0012_01_000007 is : 143
2015-08-14 08:14:30,764 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/joinfieldedpipesplatform/joinsintocogrouprhs/_temporary
2015-08-14 08:14:30,827 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/joinfieldedpipesplatform/joinsintocogrouprhs
2015-08-14 08:14:30,985 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:14:30,985 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:14:31,018 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:14:31,018 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 08:14:31,019 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 08:14:31,019 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/joinfieldedpipesplatform/joinhasher"]
2015-08-14 08:14:31,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:14:31,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:14:31,019 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:14:31,020 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/joinhasher
2015-08-14 08:14:31,170 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0013
2015-08-14 08:14:31,171 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0013/
2015-08-14 08:14:46,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0013_01_000006 is : 143
2015-08-14 08:14:47,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0013_01_000002 is : 143
2015-08-14 08:14:47,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0013_01_000004 is : 143
2015-08-14 08:14:47,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0013_01_000005 is : 143
2015-08-14 08:14:47,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0013_01_000003 is : 143
2015-08-14 08:14:48,733 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/joinfieldedpipesplatform/joinhasher/_temporary
2015-08-14 08:14:48,806 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/joinfieldedpipesplatform/joinhasher
2015-08-14 08:14:48,864 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:14:48,865 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:14:48,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting
2015-08-14 08:14:48,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] 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 08:14:48,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower+upper.txt"]
2015-08-14 08:14:48,908 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] 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 08:14:48,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin"]
2015-08-14 08:14:48,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] parallel execution is enabled: true
2015-08-14 08:14:48,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting jobs: 2
2015-08-14 08:14:48,909 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] allocating threads: 2
2015-08-14 08:14:48,911 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (2/2)
2015-08-14 08:14:49,067 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1439539835121_0014
2015-08-14 08:14:49,067 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0014/
2015-08-14 08:15:04,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0014_01_000003 is : 143
2015-08-14 08:15:04,319 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0014_01_000002 is : 143
2015-08-14 08:15:04,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0014_01_000005 is : 143
2015-08-14 08:15:04,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0014_01_000004 is : 143
2015-08-14 08:15:05,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0014_01_000006 is : 143
2015-08-14 08:15:11,813 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0014_01_000007 is : 143
2015-08-14 08:15:13,046 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (1/2) ...splatform/joingroupbyjoin
2015-08-14 08:15:13,213 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1439539835121_0015
2015-08-14 08:15:13,213 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0015/
2015-08-14 08:15:27,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0015_01_000002 is : 143
2015-08-14 08:15:28,397 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/joinfieldedpipesplatform/joingroupbyjoin/_temporary
2015-08-14 08:15:28,462 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/joinfieldedpipesplatform/joingroupbyjoin
2015-08-14 08:15:28,492 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:15:28,492 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:15:28,513 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-14 08:15:28,513 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs.txt"]
2015-08-14 08:15:28,513 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs.txt"]
2015-08-14 08:15:28,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross"]
2015-08-14 08:15:28,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-08-14 08:15:28,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 1
2015-08-14 08:15:28,514 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 1
2015-08-14 08:15:28,515 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...ieldedpipesplatform/cross
2015-08-14 08:15:28,674 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439539835121_0016
2015-08-14 08:15:28,675 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0016/
2015-08-14 08:15:44,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0016_01_000003 is : 143
2015-08-14 08:15:44,103 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0016_01_000004 is : 143
2015-08-14 08:15:44,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0016_01_000005 is : 143
2015-08-14 08:15:44,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0016_01_000002 is : 143
2015-08-14 08:15:45,370 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/joinfieldedpipesplatform/cross/_temporary
2015-08-14 08:15:45,440 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/joinfieldedpipesplatform/cross
2015-08-14 08:15:45,478 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:15:45,479 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:15:45,500 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:15:45,500 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 08:15:45,501 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 08:15:45,501 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/joinfieldedpipesplatform/join"]
2015-08-14 08:15:45,501 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:15:45,502 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:15:45,502 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:15:45,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...fieldedpipesplatform/join
2015-08-14 08:15:45,650 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0017
2015-08-14 08:15:45,650 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0017/
2015-08-14 08:16:00,650 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0017_01_000006 is : 143
2015-08-14 08:16:01,526 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0017_01_000003 is : 143
2015-08-14 08:16:01,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0017_01_000004 is : 143
2015-08-14 08:16:01,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0017_01_000002 is : 143
2015-08-14 08:16:01,923 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0017_01_000005 is : 143
2015-08-14 08:16:03,174 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/joinfieldedpipesplatform/join/_temporary
2015-08-14 08:16:03,256 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/joinfieldedpipesplatform/join
2015-08-14 08:16:03,300 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:16:03,301 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:16:03,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting
2015-08-14 08:16:03,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] 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 08:16:03,337 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] 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 08:16:03,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs.txt"]
2015-08-14 08:16:03,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs.txt"]
2015-08-14 08:16:03,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby"]
2015-08-14 08:16:03,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] parallel execution is enabled: true
2015-08-14 08:16:03,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting jobs: 1
2015-08-14 08:16:03,338 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] allocating threads: 1
2015-08-14 08:16:03,339 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] starting step: (1/1) ...platform/joinsintogroupby
2015-08-14 08:16:03,494 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] submitted hadoop job: job_1439539835121_0018
2015-08-14 08:16:03,494 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0018/
2015-08-14 08:16:20,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000005 is : 143
2015-08-14 08:16:20,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000007 is : 143
2015-08-14 08:16:20,456 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000003 is : 143
2015-08-14 08:16:20,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000006 is : 143
2015-08-14 08:16:20,499 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000004 is : 143
2015-08-14 08:16:20,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000002 is : 143
2015-08-14 08:16:27,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0018_01_000008 is : 143
2015-08-14 08:16:29,219 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/joinfieldedpipesplatform/joinsintogroupby/_temporary
2015-08-14 08:16:29,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/joinfieldedpipesplatform/joinsintogroupby
2015-08-14 08:16:29,301 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:16:29,302 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:16:29,335 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:16:29,335 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 08:16:29,336 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 08:16:29,336 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/joinfieldedpipesplatform/unknown"]
2015-08-14 08:16:29,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:16:29,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:16:29,336 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:16:29,339 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ldedpipesplatform/unknown
2015-08-14 08:16:29,491 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0019
2015-08-14 08:16:29,491 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0019/
2015-08-14 08:16:44,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0019_01_000006 is : 143
2015-08-14 08:16:45,163 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0019_01_000002 is : 143
2015-08-14 08:16:45,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0019_01_000005 is : 143
2015-08-14 08:16:45,306 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0019_01_000004 is : 143
2015-08-14 08:16:45,361 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0019_01_000003 is : 143
2015-08-14 08:16:46,613 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/joinfieldedpipesplatform/unknown/_temporary
2015-08-14 08:16:46,681 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/joinfieldedpipesplatform/unknown
2015-08-14 08:16:46,721 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:16:46,722 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:16:46,754 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-08-14 08:16:46,755 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] 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 08:16:46,756 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] 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 08:16:46,757 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] 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 08:16:46,758 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost"]
2015-08-14 08:16:46,758 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] parallel execution is enabled: true
2015-08-14 08:16:46,759 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting jobs: 1
2015-08-14 08:16:46,760 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] allocating threads: 1
2015-08-14 08:16:46,764 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/1) ...m/joinaroundjoinrightmost
2015-08-14 08:16:46,934 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439539835121_0020
2015-08-14 08:16:46,934 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0020/
2015-08-14 08:17:02,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0020_01_000006 is : 143
2015-08-14 08:17:03,176 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0020_01_000005 is : 143
2015-08-14 08:17:03,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0020_01_000002 is : 143
2015-08-14 08:17:03,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0020_01_000003 is : 143
2015-08-14 08:17:03,569 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0020_01_000004 is : 143
2015-08-14 08:17:04,833 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/joinfieldedpipesplatform/joinaroundjoinrightmost/_temporary
2015-08-14 08:17:04,903 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/joinfieldedpipesplatform/joinaroundjoinrightmost
2015-08-14 08:17:04,943 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:17:04,943 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:17:04,964 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:17:04,964 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 08:17:04,964 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 08:17:04,964 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/joinfieldedpipesplatform/joinnone"]
2015-08-14 08:17:04,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:17:04,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:17:04,965 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:17:04,966 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dedpipesplatform/joinnone
2015-08-14 08:17:05,119 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0021
2015-08-14 08:17:05,120 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0021/
2015-08-14 08:17:20,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0021_01_000002 is : 143
2015-08-14 08:17:20,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0021_01_000003 is : 143
2015-08-14 08:17:20,877 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0021_01_000004 is : 143
2015-08-14 08:17:20,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0021_01_000006 is : 143
2015-08-14 08:17:21,223 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0021_01_000005 is : 143
2015-08-14 08:17:22,463 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/joinfieldedpipesplatform/joinnone/_temporary
2015-08-14 08:17:22,533 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/joinfieldedpipesplatform/joinnone
2015-08-14 08:17:22,572 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:17:22,572 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:17:22,601 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:17:22,602 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 08:17:22,602 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 08:17:22,602 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/joinfieldedpipesplatform/joinself"]
2015-08-14 08:17:22,602 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:17:22,602 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-14 08:17:22,603 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-14 08:17:22,604 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 08:17:22,759 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0022
2015-08-14 08:17:22,759 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0022/
2015-08-14 08:17:37,821 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0022_01_000006 is : 143
2015-08-14 08:17:38,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0022_01_000004 is : 143
2015-08-14 08:17:38,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0022_01_000003 is : 143
2015-08-14 08:17:38,878 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0022_01_000002 is : 143
2015-08-14 08:17:38,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0022_01_000005 is : 143
2015-08-14 08:17:40,204 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...dedpipesplatform/joinself
2015-08-14 08:17:40,362 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0023
2015-08-14 08:17:40,363 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0023/
2015-08-14 08:17:56,305 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0023_01_000004 is : 143
2015-08-14 08:17:56,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0023_01_000006 is : 143
2015-08-14 08:17:56,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0023_01_000003 is : 143
2015-08-14 08:17:56,391 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0023_01_000002 is : 143
2015-08-14 08:17:56,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0023_01_000005 is : 143
2015-08-14 08:17:57,667 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/joinfieldedpipesplatform/joinself/_temporary
2015-08-14 08:17:57,734 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/joinfieldedpipesplatform/joinself
2015-08-14 08:17:57,772 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:17:57,773 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:17:57,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting
2015-08-14 08:17:57,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] 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 08:17:57,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] 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 08:17:57,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] 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 08:17:57,813 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped"]
2015-08-14 08:17:57,813 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] parallel execution is enabled: true
2015-08-14 08:17:57,813 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting jobs: 2
2015-08-14 08:17:57,814 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] allocating threads: 2
2015-08-14 08:17:57,816 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (2/2)
2015-08-14 08:17:57,973 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1439539835121_0024
2015-08-14 08:17:57,974 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0024/
2015-08-14 08:18:13,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0024_01_000003 is : 143
2015-08-14 08:18:14,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0024_01_000006 is : 143
2015-08-14 08:18:14,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0024_01_000004 is : 143
2015-08-14 08:18:14,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0024_01_000005 is : 143
2015-08-14 08:18:15,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (1/2) ...orm/joinaroundjoinswapped
2015-08-14 08:18:15,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1439539835121_0025
2015-08-14 08:18:15,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0025/
2015-08-14 08:18:30,878 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0025_01_000006 is : 143
2015-08-14 08:18:31,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0025_01_000002 is : 143
2015-08-14 08:18:31,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0025_01_000004 is : 143
2015-08-14 08:18:32,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0025_01_000003 is : 143
2015-08-14 08:18:33,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0025_01_000005 is : 143
2015-08-14 08:18:34,320 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/joinfieldedpipesplatform/joinaroundjoinswapped/_temporary
2015-08-14 08:18:34,389 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/joinfieldedpipesplatform/joinaroundjoinswapped
2015-08-14 08:18:34,429 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:18:34,429 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:18:34,462 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:18:34,463 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 08:18:34,464 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 08:18:34,465 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/joinfieldedpipesplatform/joinfilteredbranch"]
2015-08-14 08:18:34,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:18:34,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-14 08:18:34,467 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-14 08:18:34,469 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-14 08:18:34,623 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0026
2015-08-14 08:18:34,623 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0026/
2015-08-14 08:18:50,491 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0026_01_000004 is : 143
2015-08-14 08:18:50,610 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0026_01_000005 is : 143
2015-08-14 08:18:50,642 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0026_01_000006 is : 143
2015-08-14 08:18:50,730 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0026_01_000003 is : 143
2015-08-14 08:18:50,766 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0026_01_000002 is : 143
2015-08-14 08:18:58,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0026_01_000007 is : 143
2015-08-14 08:18:59,451 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...atform/joinfilteredbranch
2015-08-14 08:18:59,628 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0027
2015-08-14 08:18:59,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0027/
2015-08-14 08:19:14,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0027_01_000006 is : 143
2015-08-14 08:19:15,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0027_01_000004 is : 143
2015-08-14 08:19:15,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0027_01_000002 is : 143
2015-08-14 08:19:15,539 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0027_01_000003 is : 143
2015-08-14 08:19:15,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0027_01_000005 is : 143
2015-08-14 08:19:16,806 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/joinfieldedpipesplatform/joinfilteredbranch/_temporary
2015-08-14 08:19:16,872 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/joinfieldedpipesplatform/joinfilteredbranch
2015-08-14 08:19:16,909 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:19:16,910 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:19:16,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-08-14 08:19:16,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] 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 08:19:16,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] 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 08:19:16,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] 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 08:19:16,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin"]
2015-08-14 08:19:16,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] parallel execution is enabled: true
2015-08-14 08:19:16,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting jobs: 3
2015-08-14 08:19:16,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] allocating threads: 3
2015-08-14 08:19:16,956 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (3/3)
2015-08-14 08:19:17,110 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439539835121_0028
2015-08-14 08:19:17,112 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0028/
2015-08-14 08:19:33,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0028_01_000004 is : 143
2015-08-14 08:19:33,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0028_01_000006 is : 143
2015-08-14 08:19:33,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0028_01_000005 is : 143
2015-08-14 08:19:33,329 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0028_01_000003 is : 143
2015-08-14 08:19:34,445 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0028_01_000002 is : 143
2015-08-14 08:19:35,678 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (2/3)
2015-08-14 08:19:35,829 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439539835121_0029
2015-08-14 08:19:35,830 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0029/
2015-08-14 08:19:51,106 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0029_01_000003 is : 143
2015-08-14 08:19:51,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0029_01_000006 is : 143
2015-08-14 08:19:51,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0029_01_000005 is : 143
2015-08-14 08:19:51,961 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0029_01_000004 is : 143
2015-08-14 08:19:53,156 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/3) ...rm/joinsamesourceintojoin
2015-08-14 08:19:53,302 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439539835121_0030
2015-08-14 08:19:53,302 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0030/
2015-08-14 08:20:09,228 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0030_01_000006 is : 143
2015-08-14 08:20:09,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0030_01_000004 is : 143
2015-08-14 08:20:09,397 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0030_01_000005 is : 143
2015-08-14 08:20:09,510 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0030_01_000003 is : 143
2015-08-14 08:20:09,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0030_01_000002 is : 143
2015-08-14 08:20:10,804 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/joinfieldedpipesplatform/joinsamesourceintojoin/_temporary
2015-08-14 08:20:10,870 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/joinfieldedpipesplatform/joinsamesourceintojoin
2015-08-14 08:20:10,913 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:20:10,914 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:20:10,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-14 08:20:10,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:20:10,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] 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 08:20:10,954 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs.txt"]
2015-08-14 08:20:10,955 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs.txt"]
2015-08-14 08:20:10,955 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup"]
2015-08-14 08:20:10,956 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-14 08:20:10,956 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 1
2015-08-14 08:20:10,956 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 1
2015-08-14 08:20:10,958 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...platform/joinsintocogroup
2015-08-14 08:20:11,117 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439539835121_0031
2015-08-14 08:20:11,117 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0031/
2015-08-14 08:20:27,876 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000002 is : 143
2015-08-14 08:20:28,080 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000005 is : 143
2015-08-14 08:20:28,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000004 is : 143
2015-08-14 08:20:28,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000003 is : 143
2015-08-14 08:20:28,182 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000006 is : 143
2015-08-14 08:20:28,229 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000007 is : 143
2015-08-14 08:20:35,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0031_01_000008 is : 143
2015-08-14 08:20:36,779 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/joinfieldedpipesplatform/joinsintocogroup/_temporary
2015-08-14 08:20:36,843 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/joinfieldedpipesplatform/joinsintocogroup
2015-08-14 08:20:36,904 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:20:36,905 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:20:36,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:20:36,935 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-14 08:20:36,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-14 08:20:36,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner"]
2015-08-14 08:20:36,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:20:36,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:20:36,936 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:20:36,937 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...edpipesplatform/joininner
2015-08-14 08:20:37,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0032
2015-08-14 08:20:37,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0032/
2015-08-14 08:20:51,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0032_01_000006 is : 143
2015-08-14 08:20:53,256 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0032_01_000002 is : 143
2015-08-14 08:20:53,342 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0032_01_000004 is : 143
2015-08-14 08:20:53,400 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0032_01_000005 is : 143
2015-08-14 08:20:53,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0032_01_000003 is : 143
2015-08-14 08:20:54,675 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/joinfieldedpipesplatform/joininner/_temporary
2015-08-14 08:20:54,740 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/joinfieldedpipesplatform/joininner
2015-08-14 08:20:54,791 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:20:54,792 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:20:54,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-14 08:20:54,823 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] 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 08:20:54,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby"]
2015-08-14 08:20:54,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-08-14 08:20:54,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 2
2015-08-14 08:20:54,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 2
2015-08-14 08:20:54,826 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (2/2)
2015-08-14 08:20:54,964 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439539835121_0033
2015-08-14 08:20:54,965 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0033/
2015-08-14 08:21:10,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0033_01_000006 is : 143
2015-08-14 08:21:10,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0033_01_000002 is : 143
2015-08-14 08:21:10,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0033_01_000005 is : 143
2015-08-14 08:21:11,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0033_01_000004 is : 143
2015-08-14 08:21:17,689 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0033_01_000007 is : 143
2015-08-14 08:21:18,919 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/2) ...orm/samepipearoundgroupby
2015-08-14 08:21:19,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439539835121_0034
2015-08-14 08:21:19,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0034/
2015-08-14 08:21:34,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0034_01_000005 is : 143
2015-08-14 08:21:35,016 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0034_01_000006 is : 143
2015-08-14 08:21:35,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0034_01_000002 is : 143
2015-08-14 08:21:35,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0034_01_000003 is : 143
2015-08-14 08:21:35,142 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0034_01_000004 is : 143
2015-08-14 08:21:36,388 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/joinfieldedpipesplatform/samepipearoundgroupby/_temporary
2015-08-14 08:21:36,453 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/joinfieldedpipesplatform/samepipearoundgroupby
2015-08-14 08:21:36,524 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:21:36,525 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:21:36,576 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-08-14 08:21:36,577 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['id2']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/nums.20.txt"]
2015-08-14 08:21:36,577 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['id']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/nums.10.txt"]
2015-08-14 08:21:36,578 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextDelimited[['id2', 'count']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin"]
2015-08-14 08:21:36,578 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-08-14 08:21:36,578 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-08-14 08:21:36,578 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-08-14 08:21:36,585 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2)
2015-08-14 08:21:36,729 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439539835121_0035
2015-08-14 08:21:36,730 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0035/
2015-08-14 08:21:51,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0035_01_000003 is : 143
2015-08-14 08:21:51,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0035_01_000002 is : 143
2015-08-14 08:21:52,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0035_01_000004 is : 143
2015-08-14 08:21:52,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0035_01_000005 is : 143
2015-08-14 08:21:53,339 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...JoinMergeGroupBy/hashjoin
2015-08-14 08:21:53,510 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439539835121_0036
2015-08-14 08:21:53,510 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0036/
2015-08-14 08:22:15,288 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000002 is : 143
2015-08-14 08:22:15,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000003 is : 143
2015-08-14 08:22:16,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000006 is : 143
2015-08-14 08:22:16,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000007 is : 143
2015-08-14 08:22:16,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000004 is : 143
2015-08-14 08:22:16,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000008 is : 143
2015-08-14 08:22:16,559 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000005 is : 143
2015-08-14 08:22:22,374 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0036_01_000009 is : 143
2015-08-14 08:22:23,609 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/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin/_temporary
2015-08-14 08:22:23,669 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/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin
2015-08-14 08:22:23,695 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:22:23,695 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:22:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-14 08:22:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] 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 08:22:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2"]
2015-08-14 08:22:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-08-14 08:22:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-08-14 08:22:23,710 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-08-14 08:22:23,712 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...edpipesplatform/samepipe2
2015-08-14 08:22:23,853 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439539835121_0037
2015-08-14 08:22:23,854 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0037/
2015-08-14 08:22:39,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0037_01_000006 is : 143
2015-08-14 08:22:40,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0037_01_000003 is : 143
2015-08-14 08:22:40,497 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0037_01_000002 is : 143
2015-08-14 08:22:40,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0037_01_000005 is : 143
2015-08-14 08:22:41,875 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/joinfieldedpipesplatform/samepipe2/_temporary
2015-08-14 08:22:41,940 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/joinfieldedpipesplatform/samepipe2
2015-08-14 08:22:41,975 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:22:41,975 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:22:42,000 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting
2015-08-14 08:22:42,000 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] source: Hfs["TextDelimited[['num', 'char']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lower.txt"]
2015-08-14 08:22:42,000 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3"]
2015-08-14 08:22:42,000 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] parallel execution is enabled: true
2015-08-14 08:22:42,000 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting jobs: 1
2015-08-14 08:22:42,001 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] allocating threads: 1
2015-08-14 08:22:42,002 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] starting step: (1/1) ...edpipesplatform/samepipe3
2015-08-14 08:22:42,155 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] submitted hadoop job: job_1439539835121_0038
2015-08-14 08:22:42,155 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0038/
2015-08-14 08:22:57,011 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0038_01_000003 is : 143
2015-08-14 08:22:57,076 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0038_01_000002 is : 143
2015-08-14 08:22:57,563 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0038_01_000006 is : 143
2015-08-14 08:22:57,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0038_01_000004 is : 143
2015-08-14 08:22:58,049 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0038_01_000005 is : 143
2015-08-14 08:22:59,289 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/joinfieldedpipesplatform/samepipe3/_temporary
2015-08-14 08:22:59,353 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/joinfieldedpipesplatform/samepipe3
2015-08-14 08:22:59,391 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:22:59,391 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:22:59,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:22:59,422 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 08:22:59,422 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 08:22:59,423 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/joinfieldedpipesplatform/joingroupby"]
2015-08-14 08:22:59,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:22:59,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:22:59,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:22:59,424 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...pipesplatform/joingroupby
2015-08-14 08:22:59,565 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0039
2015-08-14 08:22:59,565 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0039/
2015-08-14 08:23:15,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0039_01_000006 is : 143
2015-08-14 08:23:15,650 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0039_01_000004 is : 143
2015-08-14 08:23:15,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0039_01_000002 is : 143
2015-08-14 08:23:15,734 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0039_01_000005 is : 143
2015-08-14 08:23:15,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0039_01_000003 is : 143
2015-08-14 08:23:23,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0039_01_000007 is : 143
2015-08-14 08:23:24,290 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/joinfieldedpipesplatform/joingroupby/_temporary
2015-08-14 08:23:24,339 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/joinfieldedpipesplatform/joingroupby
2015-08-14 08:23:24,367 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:23:24,368 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:23:24,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-14 08:23:24,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] 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 08:23:24,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe"]
2015-08-14 08:23:24,393 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-08-14 08:23:24,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-08-14 08:23:24,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-08-14 08:23:24,396 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...dedpipesplatform/samepipe
2015-08-14 08:23:24,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439539835121_0040
2015-08-14 08:23:24,540 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0040/
2015-08-14 08:23:29,632 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439539835121_0039_01_000001
2015-08-14 08:23:40,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0040_01_000004 is : 143
2015-08-14 08:23:40,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0040_01_000002 is : 143
2015-08-14 08:23:40,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0040_01_000003 is : 143
2015-08-14 08:23:40,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0040_01_000005 is : 143
2015-08-14 08:23:40,810 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0040_01_000006 is : 143
2015-08-14 08:23:42,059 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/joinfieldedpipesplatform/samepipe/_temporary
2015-08-14 08:23:42,125 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/joinfieldedpipesplatform/samepipe
2015-08-14 08:23:42,162 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:23:42,163 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:23:42,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:23:42,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-14 08:23:42,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-14 08:23:42,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter"]
2015-08-14 08:23:42,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:23:42,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:23:42,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:23:42,189 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/joininnerouter
2015-08-14 08:23:42,346 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0041
2015-08-14 08:23:42,346 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0041/
2015-08-14 08:23:57,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0041_01_000003 is : 143
2015-08-14 08:23:57,589 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0041_01_000002 is : 143
2015-08-14 08:23:58,145 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0041_01_000006 is : 143
2015-08-14 08:23:58,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0041_01_000004 is : 143
2015-08-14 08:23:58,566 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0041_01_000005 is : 143
2015-08-14 08:23:59,805 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/joinfieldedpipesplatform/joininnerouter/_temporary
2015-08-14 08:23:59,883 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/joinfieldedpipesplatform/joininnerouter
2015-08-14 08:23:59,923 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 08:23:59,923 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:23:59,949 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-14 08:23:59,949 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 08:23:59,950 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 08:23:59,950 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/joinfieldedpipesplatform/difffields"]
2015-08-14 08:23:59,950 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-14 08:23:59,950 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-14 08:23:59,950 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-14 08:23:59,951 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/difffields
2015-08-14 08:24:00,093 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439539835121_0042
2015-08-14 08:24:00,093 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://ip-10-235-34-50:55226/proxy/application_1439539835121_0042/
2015-08-14 08:24:15,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0042_01_000002 is : 143
2015-08-14 08:24:16,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0042_01_000006 is : 143
2015-08-14 08:24:16,040 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0042_01_000005 is : 143
2015-08-14 08:24:16,087 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439539835121_0042_01_000004 is : 143
2015-08-14 08:24:17,301 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/joinfieldedpipesplatform/difffields/_temporary
2015-08-14 08:24:17,368 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/joinfieldedpipesplatform/difffields