2015-08-12 09:20:40,388 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-12 09:20:40,472 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-12 09:20:40,473 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.JoinFieldedPipesPlatformTest
2015-08-12 09:20:40,546 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-12 09:20:41,633 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-12 09:20:42,347 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-12 09:20:48,251 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-12 09:20:48,457 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-12 09:20:48,635 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-12 09:20:48,820 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-12 09:21:06,004 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-12 09:21:06,225 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:21:06,235 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:21:06,250 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 9C9A6C96700040E4A4719CAD0B9C8A4E
2015-08-12 09:21:06,456 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-12 09:21:06,463 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:21:06,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:21:06,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower-offset.txt"]
2015-08-12 09:21:06,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle"]
2015-08-12 09:21:06,467 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:21:06,467 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:21:06,467 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:21:06,469 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...splatform/joininnersingle
2015-08-12 09:21:07,340 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0001
2015-08-12 09:21:07,341 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0001/
2015-08-12 09:21:37,631 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0001_01_000002 is : 143
2015-08-12 09:21:40,316 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0001_01_000006 is : 143
2015-08-12 09:21:41,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0001_01_000005 is : 143
2015-08-12 09:21:42,759 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle/_temporary
2015-08-12 09:21:42,915 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnersingle
2015-08-12 09:21:43,001 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:21:43,002 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:21:43,079 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting
2015-08-12 09:21:43,081 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:21:43,081 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:21:43,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:21:43,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost"]
2015-08-12 09:21:43,082 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] parallel execution is enabled: true
2015-08-12 09:21:43,083 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting jobs: 2
2015-08-12 09:21:43,083 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] allocating threads: 2
2015-08-12 09:21:43,090 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (2/2)
2015-08-12 09:21:43,615 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1439396460488_0002
2015-08-12 09:21:43,616 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0002/
2015-08-12 09:22:10,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0002_01_000003 is : 143
2015-08-12 09:22:12,734 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0002_01_000005 is : 143
2015-08-12 09:22:12,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0002_01_000004 is : 143
2015-08-12 09:22:14,310 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (1/2) ...rm/joinaroundjoinleftmost
2015-08-12 09:22:14,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1439396460488_0003
2015-08-12 09:22:14,549 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0003/
2015-08-12 09:22:42,733 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0003_01_000002 is : 143
2015-08-12 09:22:45,492 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0003_01_000006 is : 143
2015-08-12 09:22:47,271 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost/_temporary
2015-08-12 09:22:47,376 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost
2015-08-12 09:22:47,435 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:22:47,436 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:22:47,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting
2015-08-12 09:22:47,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:22:47,474 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:22:47,475 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes"]
2015-08-12 09:22:47,476 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] parallel execution is enabled: true
2015-08-12 09:22:47,478 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting jobs: 1
2015-08-12 09:22:47,479 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] allocating threads: 1
2015-08-12 09:22:47,492 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] starting step: (1/1) ...ipesplatform/renamedpipes
2015-08-12 09:22:47,865 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] submitted hadoop job: job_1439396460488_0004
2015-08-12 09:22:47,865 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0004/
2015-08-12 09:23:13,801 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0004_01_000006 is : 143
2015-08-12 09:23:16,796 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0004_01_000003 is : 143
2015-08-12 09:23:18,189 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes/_temporary
2015-08-12 09:23:18,307 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/renamedpipes
2015-08-12 09:23:18,362 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:23:18,363 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:23:18,421 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:23:18,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:23:18,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:23:18,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery"]
2015-08-12 09:23:18,423 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:23:18,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 3
2015-08-12 09:23:18,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 3
2015-08-12 09:23:18,436 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-08-12 09:23:18,439 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-08-12 09:23:18,757 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0005
2015-08-12 09:23:18,757 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0005/
2015-08-12 09:23:18,857 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0006
2015-08-12 09:23:18,858 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0006/
2015-08-12 09:24:03,423 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0005_01_000002 is : 143
2015-08-12 09:24:20,055 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0006_01_000002 is : 143
2015-08-12 09:24:20,794 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0006_01_000003 is : 143
2015-08-12 09:24:22,978 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0006_01_000004 is : 143
2015-08-12 09:24:23,209 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0006_01_000006 is : 143
2015-08-12 09:24:26,114 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0005_01_000007 is : 143
2015-08-12 09:24:30,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0006_01_000007 is : 143
2015-08-12 09:24:32,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...dpipesplatform/afterevery
2015-08-12 09:24:32,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0007
2015-08-12 09:24:32,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0007/
2015-08-12 09:24:46,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0007_01_000002 is : 143
2015-08-12 09:24:47,728 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery/_temporary
2015-08-12 09:24:47,809 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/afterevery
2015-08-12 09:24:47,915 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:24:47,915 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:24:47,988 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-12 09:24:47,989 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:24:47,991 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:24:47,992 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 09:24:47,994 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 09:24:47,995 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin"]
2015-08-12 09:24:47,997 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-12 09:24:47,997 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 1
2015-08-12 09:24:47,999 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 1
2015-08-12 09:24:48,002 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-08-12 09:24:48,286 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439396460488_0008
2015-08-12 09:24:48,286 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0008/
2015-08-12 09:25:13,457 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0008_01_000003 is : 143
2015-08-12 09:25:14,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0008_01_000002 is : 143
2015-08-12 09:25:15,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0008_01_000004 is : 143
2015-08-12 09:25:15,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0008_01_000006 is : 143
2015-08-12 09:25:20,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0008_01_000007 is : 143
2015-08-12 09:25:22,067 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin/_temporary
2015-08-12 09:25:22,130 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin
2015-08-12 09:25:22,185 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:25:22,186 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:25:22,250 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-12 09:25:22,252 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:25:22,253 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:25:22,254 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 09:25:22,255 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 09:25:22,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs"]
2015-08-12 09:25:22,257 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-12 09:25:22,258 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 2
2015-08-12 09:25:22,258 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 2
2015-08-12 09:25:22,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-08-12 09:25:22,467 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439396460488_0009
2015-08-12 09:25:22,468 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0009/
2015-08-12 09:25:51,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0009_01_000002 is : 143
2015-08-12 09:25:53,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0009_01_000006 is : 143
2015-08-12 09:25:53,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0009_01_000005 is : 143
2015-08-12 09:25:55,099 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouplhs
2015-08-12 09:25:55,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439396460488_0010
2015-08-12 09:25:55,312 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0010/
2015-08-12 09:26:21,560 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0010_01_000003 is : 143
2015-08-12 09:26:23,270 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0010_01_000005 is : 143
2015-08-12 09:26:23,361 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0010_01_000004 is : 143
2015-08-12 09:26:30,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0010_01_000007 is : 143
2015-08-12 09:26:31,433 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs/_temporary
2015-08-12 09:26:31,495 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs
2015-08-12 09:26:31,538 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:26:31,540 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:26:31,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-12 09:26:31,599 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:26:31,600 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:26:31,600 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 09:26:31,601 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 09:26:31,601 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs"]
2015-08-12 09:26:31,602 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-12 09:26:31,602 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 2
2015-08-12 09:26:31,603 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 2
2015-08-12 09:26:31,606 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-08-12 09:26:31,787 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439396460488_0011
2015-08-12 09:26:31,788 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0011/
2015-08-12 09:26:37,037 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1439396460488_0010_01_000001
2015-08-12 09:26:57,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0011_01_000003 is : 143
2015-08-12 09:27:00,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0011_01_000006 is : 143
2015-08-12 09:27:00,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0011_01_000005 is : 143
2015-08-12 09:27:00,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0011_01_000004 is : 143
2015-08-12 09:27:01,670 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouprhs
2015-08-12 09:27:01,845 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439396460488_0012
2015-08-12 09:27:01,846 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0012/
2015-08-12 09:27:28,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0012_01_000002 is : 143
2015-08-12 09:27:30,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0012_01_000005 is : 143
2015-08-12 09:27:30,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0012_01_000004 is : 143
2015-08-12 09:27:30,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0012_01_000006 is : 143
2015-08-12 09:27:36,148 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0012_01_000007 is : 143
2015-08-12 09:27:37,433 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs/_temporary
2015-08-12 09:27:37,485 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs
2015-08-12 09:27:37,768 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:27:37,768 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:27:37,798 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:27:37,798 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:27:37,798 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:27:37,799 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher"]
2015-08-12 09:27:37,800 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:27:37,800 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:27:37,801 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:27:37,803 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/joinhasher
2015-08-12 09:27:38,022 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0013
2015-08-12 09:27:38,022 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0013/
2015-08-12 09:28:07,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0013_01_000006 is : 143
2015-08-12 09:28:08,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0013_01_000002 is : 143
2015-08-12 09:28:09,800 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0013_01_000003 is : 143
2015-08-12 09:28:11,081 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher/_temporary
2015-08-12 09:28:11,161 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinhasher
2015-08-12 09:28:11,238 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:28:11,239 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:28:11,277 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting
2015-08-12 09:28:11,277 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:28:11,278 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower+upper.txt"]
2015-08-12 09:28:11,278 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:28:11,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin"]
2015-08-12 09:28:11,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] parallel execution is enabled: true
2015-08-12 09:28:11,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting jobs: 2
2015-08-12 09:28:11,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] allocating threads: 2
2015-08-12 09:28:11,289 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (2/2)
2015-08-12 09:28:11,474 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1439396460488_0014
2015-08-12 09:28:11,474 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0014/
2015-08-12 09:28:39,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0014_01_000002 is : 143
2015-08-12 09:28:39,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0014_01_000006 is : 143
2015-08-12 09:28:46,224 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0014_01_000007 is : 143
2015-08-12 09:28:47,464 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (1/2) ...splatform/joingroupbyjoin
2015-08-12 09:28:47,682 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1439396460488_0015
2015-08-12 09:28:47,690 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0015/
2015-08-12 09:29:01,708 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin/_temporary
2015-08-12 09:29:01,754 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin
2015-08-12 09:29:01,784 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:29:01,787 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:29:01,806 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-12 09:29:01,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 09:29:01,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 09:29:01,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross"]
2015-08-12 09:29:01,807 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-08-12 09:29:01,813 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 1
2015-08-12 09:29:01,813 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 1
2015-08-12 09:29:01,818 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...ieldedpipesplatform/cross
2015-08-12 09:29:01,993 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439396460488_0016
2015-08-12 09:29:01,993 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0016/
2015-08-12 09:29:24,607 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0016_01_000002 is : 143
2015-08-12 09:29:25,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0016_01_000005 is : 143
2015-08-12 09:29:27,112 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross/_temporary
2015-08-12 09:29:27,182 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/cross
2015-08-12 09:29:27,229 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:29:27,233 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:29:27,250 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:29:27,252 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:29:27,254 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:29:27,255 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join"]
2015-08-12 09:29:27,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:29:27,258 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:29:27,259 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:29:27,262 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...fieldedpipesplatform/join
2015-08-12 09:29:27,461 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0017
2015-08-12 09:29:27,462 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0017/
2015-08-12 09:30:00,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0017_01_000002 is : 143
2015-08-12 09:30:01,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0017_01_000005 is : 143
2015-08-12 09:30:02,651 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join/_temporary
2015-08-12 09:30:02,832 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/join
2015-08-12 09:30:02,896 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:30:02,897 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:30:02,939 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting
2015-08-12 09:30:02,940 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:30:02,942 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:30:02,944 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 09:30:02,946 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 09:30:02,948 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby"]
2015-08-12 09:30:02,951 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] parallel execution is enabled: true
2015-08-12 09:30:02,952 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting jobs: 1
2015-08-12 09:30:02,953 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] allocating threads: 1
2015-08-12 09:30:02,959 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] starting step: (1/1) ...platform/joinsintogroupby
2015-08-12 09:30:03,193 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] submitted hadoop job: job_1439396460488_0018
2015-08-12 09:30:03,193 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0018/
2015-08-12 09:30:41,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0018_01_000007 is : 143
2015-08-12 09:30:41,536 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0018_01_000002 is : 143
2015-08-12 09:30:48,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0018_01_000008 is : 143
2015-08-12 09:30:50,083 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby/_temporary
2015-08-12 09:30:50,148 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby
2015-08-12 09:30:50,178 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:30:50,185 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:30:50,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:30:50,206 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:30:50,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:30:50,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown"]
2015-08-12 09:30:50,207 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:30:50,211 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:30:50,211 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:30:50,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ldedpipesplatform/unknown
2015-08-12 09:30:50,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0019
2015-08-12 09:30:50,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0019/
2015-08-12 09:31:31,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0019_01_000002 is : 143
2015-08-12 09:31:33,144 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown/_temporary
2015-08-12 09:31:33,316 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/unknown
2015-08-12 09:31:33,389 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:31:33,391 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:31:33,424 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-08-12 09:31:33,424 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:31:33,425 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:31:33,427 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:31:33,429 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost"]
2015-08-12 09:31:33,429 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] parallel execution is enabled: true
2015-08-12 09:31:33,431 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting jobs: 1
2015-08-12 09:31:33,431 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] allocating threads: 1
2015-08-12 09:31:33,439 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/1) ...m/joinaroundjoinrightmost
2015-08-12 09:31:33,660 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439396460488_0020
2015-08-12 09:31:33,660 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0020/
2015-08-12 09:32:03,308 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0020_01_000003 is : 143
2015-08-12 09:32:04,417 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0020_01_000004 is : 143
2015-08-12 09:32:04,841 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0020_01_000005 is : 143
2015-08-12 09:32:06,169 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost/_temporary
2015-08-12 09:32:06,257 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost
2015-08-12 09:32:06,310 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:32:06,311 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:32:06,328 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:32:06,329 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:32:06,330 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:32:06,331 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone"]
2015-08-12 09:32:06,332 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:32:06,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:32:06,334 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:32:06,337 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dedpipesplatform/joinnone
2015-08-12 09:32:06,499 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0021
2015-08-12 09:32:06,500 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0021/
2015-08-12 09:32:36,845 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0021_01_000002 is : 143
2015-08-12 09:32:37,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0021_01_000005 is : 143
2015-08-12 09:32:38,052 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0021_01_000006 is : 143
2015-08-12 09:32:39,353 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone/_temporary
2015-08-12 09:32:39,452 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinnone
2015-08-12 09:32:39,507 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:32:39,509 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:32:39,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:32:39,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:32:39,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:32:39,564 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself"]
2015-08-12 09:32:39,567 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:32:39,567 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 09:32:39,567 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 09:32:39,571 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-12 09:32:39,675 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-12 09:32:39,676 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-08-12 09:32:39,677 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-08-12 09:32:39,796 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0022
2015-08-12 09:32:39,796 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0022/
2015-08-12 09:33:15,224 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0022_01_000005 is : 143
2015-08-12 09:33:17,721 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...dedpipesplatform/joinself
2015-08-12 09:33:18,022 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0023
2015-08-12 09:33:18,022 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0023/
2015-08-12 09:33:58,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0023_01_000006 is : 143
2015-08-12 09:34:01,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0023_01_000002 is : 143
2015-08-12 09:34:03,592 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself/_temporary
2015-08-12 09:34:03,696 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinself
2015-08-12 09:34:03,763 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:34:03,765 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:34:03,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting
2015-08-12 09:34:03,808 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:34:03,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:34:03,809 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:34:03,810 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped"]
2015-08-12 09:34:03,810 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] parallel execution is enabled: true
2015-08-12 09:34:03,810 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting jobs: 2
2015-08-12 09:34:03,811 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] allocating threads: 2
2015-08-12 09:34:03,814 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (2/2)
2015-08-12 09:34:04,071 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1439396460488_0024
2015-08-12 09:34:04,072 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0024/
2015-08-12 09:34:41,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0024_01_000005 is : 143
2015-08-12 09:34:41,681 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0024_01_000004 is : 143
2015-08-12 09:34:44,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (1/2) ...orm/joinaroundjoinswapped
2015-08-12 09:34:44,336 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1439396460488_0025
2015-08-12 09:34:44,336 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0025/
2015-08-12 09:35:13,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0025_01_000002 is : 143
2015-08-12 09:35:15,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0025_01_000003 is : 143
2015-08-12 09:35:17,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0025_01_000005 is : 143
2015-08-12 09:35:17,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0025_01_000004 is : 143
2015-08-12 09:35:19,907 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped/_temporary
2015-08-12 09:35:20,005 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped
2015-08-12 09:35:20,081 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:35:20,083 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:35:20,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:35:20,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:35:20,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:35:20,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch"]
2015-08-12 09:35:20,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:35:20,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 2
2015-08-12 09:35:20,132 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 2
2015-08-12 09:35:20,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-08-12 09:35:20,349 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0026
2015-08-12 09:35:20,349 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0026/
2015-08-12 09:35:57,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0026_01_000007 is : 143
2015-08-12 09:35:59,214 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...atform/joinfilteredbranch
2015-08-12 09:35:59,386 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0027
2015-08-12 09:35:59,394 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0027/
2015-08-12 09:36:30,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0027_01_000004 is : 143
2015-08-12 09:36:30,451 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0027_01_000003 is : 143
2015-08-12 09:36:31,902 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch/_temporary
2015-08-12 09:36:31,990 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch
2015-08-12 09:36:32,035 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:36:32,044 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:36:32,088 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-08-12 09:36:32,088 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:36:32,089 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:36:32,089 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:36:32,089 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin"]
2015-08-12 09:36:32,090 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] parallel execution is enabled: true
2015-08-12 09:36:32,090 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting jobs: 3
2015-08-12 09:36:32,090 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] allocating threads: 3
2015-08-12 09:36:32,098 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (3/3)
2015-08-12 09:36:32,203 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-12 09:36:32,203 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-08-12 09:36:32,204 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-08-12 09:36:32,286 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439396460488_0028
2015-08-12 09:36:32,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0028/
2015-08-12 09:37:07,763 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0028_01_000003 is : 143
2015-08-12 09:37:09,912 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0028_01_000005 is : 143
2015-08-12 09:37:09,968 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0028_01_000004 is : 143
2015-08-12 09:37:10,467 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0028_01_000006 is : 143
2015-08-12 09:37:11,986 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (2/3)
2015-08-12 09:37:12,221 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439396460488_0029
2015-08-12 09:37:12,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0029/
2015-08-12 09:37:45,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0029_01_000002 is : 143
2015-08-12 09:37:47,436 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0029_01_000006 is : 143
2015-08-12 09:37:47,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0029_01_000004 is : 143
2015-08-12 09:37:49,351 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/3) ...rm/joinsamesourceintojoin
2015-08-12 09:37:49,477 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-12 09:37:49,478 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-08-12 09:37:49,478 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-08-12 09:37:49,589 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1439396460488_0030
2015-08-12 09:37:49,590 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0030/
2015-08-12 09:38:18,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0030_01_000006 is : 143
2015-08-12 09:38:24,874 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin/_temporary
2015-08-12 09:38:24,989 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin
2015-08-12 09:38:25,060 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:38:25,061 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:38:25,109 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-08-12 09:38:25,110 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:38:25,111 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:38:25,111 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs.txt"]
2015-08-12 09:38:25,112 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs.txt"]
2015-08-12 09:38:25,112 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup"]
2015-08-12 09:38:25,112 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] parallel execution is enabled: true
2015-08-12 09:38:25,113 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting jobs: 1
2015-08-12 09:38:25,113 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] allocating threads: 1
2015-08-12 09:38:25,115 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...platform/joinsintocogroup
2015-08-12 09:38:25,334 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1439396460488_0031
2015-08-12 09:38:25,334 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0031/
2015-08-12 09:39:00,081 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0031_01_000002 is : 143
2015-08-12 09:39:02,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0031_01_000006 is : 143
2015-08-12 09:39:02,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0031_01_000007 is : 143
2015-08-12 09:39:03,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0031_01_000004 is : 143
2015-08-12 09:39:03,294 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0031_01_000005 is : 143
2015-08-12 09:39:08,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0031_01_000008 is : 143
2015-08-12 09:39:09,817 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup/_temporary
2015-08-12 09:39:09,869 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup
2015-08-12 09:39:09,936 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:39:09,938 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:39:09,967 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:39:09,968 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-12 09:39:09,969 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-12 09:39:09,970 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner"]
2015-08-12 09:39:09,970 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:39:09,971 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:39:09,971 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:39:09,972 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...edpipesplatform/joininner
2015-08-12 09:39:10,186 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0032
2015-08-12 09:39:10,187 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0032/
2015-08-12 09:39:45,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0032_01_000003 is : 143
2015-08-12 09:39:46,559 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner/_temporary
2015-08-12 09:39:46,657 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininner
2015-08-12 09:39:46,709 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:39:46,710 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:39:46,741 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-12 09:39:46,742 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:39:46,742 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby"]
2015-08-12 09:39:46,743 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-08-12 09:39:46,743 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 2
2015-08-12 09:39:46,743 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 2
2015-08-12 09:39:46,748 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (2/2)
2015-08-12 09:39:46,979 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439396460488_0033
2015-08-12 09:39:46,980 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0033/
2015-08-12 09:40:17,641 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0033_01_000006 is : 143
2015-08-12 09:40:19,756 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0033_01_000002 is : 143
2015-08-12 09:40:19,931 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0033_01_000005 is : 143
2015-08-12 09:40:25,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0033_01_000007 is : 143
2015-08-12 09:40:27,137 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/2) ...orm/samepipearoundgroupby
2015-08-12 09:40:27,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439396460488_0034
2015-08-12 09:40:27,345 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0034/
2015-08-12 09:40:58,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0034_01_000003 is : 143
2015-08-12 09:40:59,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0034_01_000002 is : 143
2015-08-12 09:41:02,818 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby/_temporary
2015-08-12 09:41:02,910 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby
2015-08-12 09:41:03,021 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:41:03,021 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:41:03,053 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-08-12 09:41:03,054 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['id2']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.20.txt"]
2015-08-12 09:41:03,055 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextLine[['id']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/nums.10.txt"]
2015-08-12 09:41:03,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextDelimited[['id2', 'count']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin"]
2015-08-12 09:41:03,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-08-12 09:41:03,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-08-12 09:41:03,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-08-12 09:41:03,059 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2)
2015-08-12 09:41:03,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439396460488_0035
2015-08-12 09:41:03,265 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0035/
2015-08-12 09:41:31,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0035_01_000005 is : 143
2015-08-12 09:41:31,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0035_01_000002 is : 143
2015-08-12 09:41:32,713 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...JoinMergeGroupBy/hashjoin
2015-08-12 09:41:32,939 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439396460488_0036
2015-08-12 09:41:32,939 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0036/
2015-08-12 09:42:14,236 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0036_01_000004 is : 143
2015-08-12 09:42:15,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0036_01_000005 is : 143
2015-08-12 09:42:15,419 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0036_01_000003 is : 143
2015-08-12 09:42:21,548 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin/_temporary
2015-08-12 09:42:21,609 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin
2015-08-12 09:42:21,654 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:42:21,655 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:42:21,692 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-12 09:42:21,693 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:42:21,694 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2"]
2015-08-12 09:42:21,694 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-08-12 09:42:21,694 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-08-12 09:42:21,694 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-08-12 09:42:21,695 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...edpipesplatform/samepipe2
2015-08-12 09:42:21,884 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439396460488_0037
2015-08-12 09:42:21,884 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0037/
2015-08-12 09:42:54,651 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0037_01_000004 is : 143
2015-08-12 09:42:55,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0037_01_000003 is : 143
2015-08-12 09:42:57,652 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2/_temporary
2015-08-12 09:42:57,747 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe2
2015-08-12 09:42:57,796 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:42:57,797 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:42:57,810 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting
2015-08-12 09:42:57,810 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] source: Hfs["TextDelimited[['num', 'char']]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:42:57,812 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3"]
2015-08-12 09:42:57,815 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] parallel execution is enabled: true
2015-08-12 09:42:57,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting jobs: 1
2015-08-12 09:42:57,817 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] allocating threads: 1
2015-08-12 09:42:57,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] starting step: (1/1) ...edpipesplatform/samepipe3
2015-08-12 09:42:58,004 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] submitted hadoop job: job_1439396460488_0038
2015-08-12 09:42:58,004 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0038/
2015-08-12 09:43:29,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0038_01_000003 is : 143
2015-08-12 09:43:31,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0038_01_000006 is : 143
2015-08-12 09:43:33,721 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3/_temporary
2015-08-12 09:43:33,832 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe3
2015-08-12 09:43:33,885 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:43:33,896 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:43:33,918 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:43:33,918 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:43:33,918 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:43:33,922 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby"]
2015-08-12 09:43:33,923 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:43:33,924 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:43:33,925 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:43:33,934 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...pipesplatform/joingroupby
2015-08-12 09:43:34,127 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0039
2015-08-12 09:43:34,128 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0039/
2015-08-12 09:44:18,286 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0039_01_000002 is : 143
2015-08-12 09:44:18,430 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0039_01_000006 is : 143
2015-08-12 09:44:18,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0039_01_000005 is : 143
2015-08-12 09:44:26,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0039_01_000007 is : 143
2015-08-12 09:44:28,077 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby/_temporary
2015-08-12 09:44:28,169 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupby
2015-08-12 09:44:28,214 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:44:28,215 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:44:28,230 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-08-12 09:44:28,231 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:44:28,231 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe"]
2015-08-12 09:44:28,231 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] parallel execution is enabled: true
2015-08-12 09:44:28,232 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting jobs: 1
2015-08-12 09:44:28,232 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] allocating threads: 1
2015-08-12 09:44:28,240 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...dedpipesplatform/samepipe
2015-08-12 09:44:28,515 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1439396460488_0040
2015-08-12 09:44:28,516 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0040/
2015-08-12 09:45:09,034 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0040_01_000005 is : 143
2015-08-12 09:45:09,651 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0040_01_000003 is : 143
2015-08-12 09:45:11,515 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe/_temporary
2015-08-12 09:45:11,608 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe
2015-08-12 09:45:11,670 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:45:11,670 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:45:11,688 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:45:11,689 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/rhs-sparse.txt"]
2015-08-12 09:45:11,691 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lhs-sparse.txt"]
2015-08-12 09:45:11,692 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter"]
2015-08-12 09:45:11,694 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:45:11,696 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:45:11,697 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:45:11,699 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/joininnerouter
2015-08-12 09:45:11,794 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-08-12 09:45:11,794 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-08-12 09:45:11,794 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-08-12 09:45:11,906 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0041
2015-08-12 09:45:11,907 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0041/
2015-08-12 09:45:49,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0041_01_000006 is : 143
2015-08-12 09:45:54,190 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0041_01_000004 is : 143
2015-08-12 09:45:56,557 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0041_01_000003 is : 143
2015-08-12 09:45:58,095 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter/_temporary
2015-08-12 09:45:58,223 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnerouter
2015-08-12 09:45:58,276 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-12 09:45:58,278 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /root/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-12 09:45:58,301 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-08-12 09:45:58,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/upper.txt"]
2015-08-12 09:45:58,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/classes/test/data/lower.txt"]
2015-08-12 09:45:58,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields"]
2015-08-12 09:45:58,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] parallel execution is enabled: true
2015-08-12 09:45:58,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting jobs: 1
2015-08-12 09:45:58,302 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] allocating threads: 1
2015-08-12 09:45:58,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/difffields
2015-08-12 09:45:58,595 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1439396460488_0042
2015-08-12 09:45:58,596 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://node1.bidemo.com:39052/proxy/application_1439396460488_0042/
2015-08-12 09:46:42,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0042_01_000006 is : 143
2015-08-12 09:46:47,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0042_01_000004 is : 143
2015-08-12 09:46:48,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0042_01_000002 is : 143
2015-08-12 09:46:48,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439396460488_0042_01_000003 is : 143
2015-08-12 09:46:50,268 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields/_temporary
2015-08-12 09:46:50,380 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /home/cascading/ryab/cascading.compatibility/biginsights-4.0.x/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/difffields