2015-07-21 10:48:17,825 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 10:48:17,850 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.CoGroupFieldedPipesPlatformTest, with platform: hadoop2-mr1
2015-07-21 10:48:17,880 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-07-21 10:48:18,728 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-07-21 10:48:19,292 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-21 10:48:24,776 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-07-21 10:48:25,006 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-07-21 10:48:25,234 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-07-21 10:48:25,436 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-07-21 10:48:42,569 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-07-21 10:48:42,676 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:48:42,677 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:48:42,723 INFO property.AppProps (AppProps.java:getAppID(174)) - using app.id: D04A6C0962DB4CC2B8E2A00EAD8C30B8
2015-07-21 10:48:42,826 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2015-07-21 10:48:42,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:48:42,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:48:42,959 INFO util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 10:48:42,960 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:48:42,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:48:42,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:48:42,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner"]
2015-07-21 10:48:42,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:48:42,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:48:42,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:48:42,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...CoGroupInner/cogroupinner
2015-07-21 10:48:43,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0001
2015-07-21 10:48:43,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0001/
2015-07-21 10:49:01,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0001_01_000002 is : 143
2015-07-21 10:49:01,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0001_01_000003 is : 143
2015-07-21 10:49:01,324 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0001_01_000004 is : 143
2015-07-21 10:49:01,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0001_01_000006 is : 143
2015-07-21 10:49:01,485 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0001_01_000005 is : 143
2015-07-21 10:49:07,636 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0001_01_000007 is : 143
2015-07-21 10:49:08,888 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner/_temporary
2015-07-21 10:49:08,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:25.925
2015-07-21 10:49:08,976 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:49:08,976 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:49:09,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2015-07-21 10:49:09,039 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:49:09,040 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:49:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:49:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:49:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:49:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup"]
2015-07-21 10:49:09,063 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:49:09,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:49:09,064 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:49:09,065 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) .../cogroupinner-resultgroup
2015-07-21 10:49:09,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0002
2015-07-21 10:49:09,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0002/
2015-07-21 10:49:25,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0002_01_000004 is : 143
2015-07-21 10:49:25,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0002_01_000002 is : 143
2015-07-21 10:49:26,021 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0002_01_000003 is : 143
2015-07-21 10:49:26,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0002_01_000006 is : 143
2015-07-21 10:49:26,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0002_01_000005 is : 143
2015-07-21 10:49:32,823 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0002_01_000007 is : 143
2015-07-21 10:49:34,030 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup/_temporary
2015-07-21 10:49:34,031 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.964
2015-07-21 10:49:34,069 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner
2015-07-21 10:49:34,079 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup
2015-07-21 10:49:34,160 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:49:34,160 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:49:34,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.071
2015-07-21 10:49:34,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:49:34,241 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:49:34,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] starting
2015-07-21 10:49:34,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 10:49:34,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:49:34,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-21 10:49:34,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] sink: Hfs["TextDelimited[[0:5]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed"]
2015-07-21 10:49:34,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] parallel execution of steps is enabled: true
2015-07-21 10:49:34,269 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] executing total steps: 1
2015-07-21 10:49:34,269 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] allocating management threads: 1
2015-07-21 10:49:34,270 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] starting step: (1/1) ...CoGroupMixed/cogroupmixed
2015-07-21 10:49:34,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] submitted hadoop job: job_1437500917049_0003
2015-07-21 10:49:34,448 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0003/
2015-07-21 10:49:59,625 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000002 is : 143
2015-07-21 10:49:59,858 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000008 is : 143
2015-07-21 10:50:00,267 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000007 is : 143
2015-07-21 10:50:00,364 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000004 is : 143
2015-07-21 10:50:00,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000005 is : 143
2015-07-21 10:50:00,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000006 is : 143
2015-07-21 10:50:00,566 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000010 is : 143
2015-07-21 10:50:00,636 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000009 is : 143
2015-07-21 10:50:00,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000003 is : 143
2015-07-21 10:50:05,234 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0003_01_000011 is : 143
2015-07-21 10:50:06,496 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed/_temporary
2015-07-21 10:50:06,497 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] completed in: 00:32.226
2015-07-21 10:50:06,540 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed
2015-07-21 10:50:06,594 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:50:06,594 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:50:06,638 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-07-21 10:50:06,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:50:06,640 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter"]
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:50:06,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:50:06,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...CoGroupOuter/cogroupouter
2015-07-21 10:50:06,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0004
2015-07-21 10:50:06,852 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0004/
2015-07-21 10:50:24,712 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0004_01_000003 is : 143
2015-07-21 10:50:24,766 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0004_01_000002 is : 143
2015-07-21 10:50:24,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0004_01_000004 is : 143
2015-07-21 10:50:24,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0004_01_000006 is : 143
2015-07-21 10:50:24,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0004_01_000005 is : 143
2015-07-21 10:50:30,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0004_01_000007 is : 143
2015-07-21 10:50:32,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter/_temporary
2015-07-21 10:50:32,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:25.550
2015-07-21 10:50:32,288 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:50:32,289 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:50:32,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-07-21 10:50:32,327 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:50:32,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:50:32,348 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:50:32,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:50:32,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:50:32,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup"]
2015-07-21 10:50:32,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:50:32,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:50:32,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:50:32,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) .../cogroupouter-resultgroup
2015-07-21 10:50:32,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0005
2015-07-21 10:50:32,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0005/
2015-07-21 10:50:49,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0005_01_000006 is : 143
2015-07-21 10:50:49,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0005_01_000004 is : 143
2015-07-21 10:50:49,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0005_01_000003 is : 143
2015-07-21 10:50:49,544 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0005_01_000002 is : 143
2015-07-21 10:50:49,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0005_01_000005 is : 143
2015-07-21 10:50:55,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0005_01_000007 is : 143
2015-07-21 10:50:56,907 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup/_temporary
2015-07-21 10:50:56,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.557
2015-07-21 10:50:56,940 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter
2015-07-21 10:50:56,951 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup
2015-07-21 10:50:57,009 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:50:57,010 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:50:57,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.060
2015-07-21 10:50:57,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 10:50:57,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:50:57,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting
2015-07-21 10:50:57,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/nums.10.txt"]
2015-07-21 10:50:57,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/nums.10.txt"]
2015-07-21 10:50:57,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-21 10:50:57,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2"]
2015-07-21 10:50:57,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] parallel execution of steps is enabled: true
2015-07-21 10:50:57,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executing total steps: 2
2015-07-21 10:50:57,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] allocating management threads: 2
2015-07-21 10:50:57,118 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (1/2)
2015-07-21 10:50:57,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1437500917049_0006
2015-07-21 10:50:57,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0006/
2015-07-21 10:51:14,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0006_01_000003 is : 143
2015-07-21 10:51:14,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0006_01_000002 is : 143
2015-07-21 10:51:14,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0006_01_000005 is : 143
2015-07-21 10:51:14,852 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0006_01_000004 is : 143
2015-07-21 10:51:14,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0006_01_000006 is : 143
2015-07-21 10:51:20,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0006_01_000007 is : 143
2015-07-21 10:51:21,271 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (2/2) ...pWith/cogroupacogroupopt2
2015-07-21 10:51:21,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1437500917049_0007
2015-07-21 10:51:21,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0007/
2015-07-21 10:51:38,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0007_01_000003 is : 143
2015-07-21 10:51:38,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0007_01_000002 is : 143
2015-07-21 10:51:38,291 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0007_01_000005 is : 143
2015-07-21 10:51:38,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0007_01_000004 is : 143
2015-07-21 10:51:38,429 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0007_01_000006 is : 143
2015-07-21 10:51:44,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0007_01_000007 is : 143
2015-07-21 10:51:45,938 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2/_temporary
2015-07-21 10:51:45,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] completed in: 00:48.826
2015-07-21 10:51:45,973 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2
2015-07-21 10:51:45,999 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:51:46,000 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:51:46,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2015-07-21 10:51:46,059 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 10:51:46,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:51:46,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting
2015-07-21 10:51:46,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/nums.10.txt"]
2015-07-21 10:51:46,086 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/nums.10.txt"]
2015-07-21 10:51:46,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] source: Hfs["TextDelimited[['num']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-21 10:51:46,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1"]
2015-07-21 10:51:46,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] parallel execution of steps is enabled: true
2015-07-21 10:51:46,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executing total steps: 2
2015-07-21 10:51:46,087 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] allocating management threads: 2
2015-07-21 10:51:46,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (1/2)
2015-07-21 10:51:46,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1437500917049_0008
2015-07-21 10:51:46,224 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0008/
2015-07-21 10:52:03,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0008_01_000002 is : 143
2015-07-21 10:52:03,792 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0008_01_000005 is : 143
2015-07-21 10:52:03,905 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0008_01_000003 is : 143
2015-07-21 10:52:03,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0008_01_000004 is : 143
2015-07-21 10:52:04,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0008_01_000006 is : 143
2015-07-21 10:52:10,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0008_01_000007 is : 143
2015-07-21 10:52:11,678 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (2/2) ...thout/cogroupacogroupopt1
2015-07-21 10:52:11,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1437500917049_0009
2015-07-21 10:52:11,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0009/
2015-07-21 10:52:28,205 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0009_01_000002 is : 143
2015-07-21 10:52:28,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0009_01_000005 is : 143
2015-07-21 10:52:28,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0009_01_000004 is : 143
2015-07-21 10:52:28,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0009_01_000003 is : 143
2015-07-21 10:52:28,532 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0009_01_000006 is : 143
2015-07-21 10:52:34,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0009_01_000007 is : 143
2015-07-21 10:52:35,541 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1/_temporary
2015-07-21 10:52:35,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] completed in: 00:49.451
2015-07-21 10:52:35,573 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1
2015-07-21 10:52:35,602 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:52:35,602 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:52:35,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2015-07-21 10:52:35,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 10:52:35,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:52:35,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2015-07-21 10:52:35,679 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:52:35,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 10:52:35,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 10:52:35,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup"]
2015-07-21 10:52:35,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2015-07-21 10:52:35,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executing total steps: 2
2015-07-21 10:52:35,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] allocating management threads: 2
2015-07-21 10:52:35,682 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/2)
2015-07-21 10:52:35,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1437500917049_0010
2015-07-21 10:52:35,806 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0010/
2015-07-21 10:52:54,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000002 is : 143
2015-07-21 10:52:54,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000003 is : 143
2015-07-21 10:52:54,246 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000006 is : 143
2015-07-21 10:52:54,337 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000007 is : 143
2015-07-21 10:52:54,394 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000005 is : 143
2015-07-21 10:52:54,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000004 is : 143
2015-07-21 10:52:59,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0010_01_000008 is : 143
2015-07-21 10:53:00,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/2) ...ndCoGroup/cogroupacogroup
2015-07-21 10:53:00,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1437500917049_0011
2015-07-21 10:53:00,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0011/
2015-07-21 10:53:19,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000005 is : 143
2015-07-21 10:53:19,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000007 is : 143
2015-07-21 10:53:19,196 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000003 is : 143
2015-07-21 10:53:19,321 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000004 is : 143
2015-07-21 10:53:19,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000002 is : 143
2015-07-21 10:53:19,377 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000006 is : 143
2015-07-21 10:53:25,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0011_01_000008 is : 143
2015-07-21 10:53:26,342 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup/_temporary
2015-07-21 10:53:26,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] completed in: 00:50.659
2015-07-21 10:53:26,373 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup
2015-07-21 10:53:26,401 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:53:26,401 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:53:26,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 10:53:26,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:53:26,432 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:53:26,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:53:26,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:53:26,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:53:26,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter"]
2015-07-21 10:53:26,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:53:26,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:53:26,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:53:26,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...erOuter/cogroupinnerouter
2015-07-21 10:53:26,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0012
2015-07-21 10:53:26,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0012/
2015-07-21 10:53:43,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0012_01_000004 is : 143
2015-07-21 10:53:43,427 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0012_01_000003 is : 143
2015-07-21 10:53:43,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0012_01_000002 is : 143
2015-07-21 10:53:43,511 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0012_01_000005 is : 143
2015-07-21 10:53:43,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0012_01_000006 is : 143
2015-07-21 10:53:49,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0012_01_000007 is : 143
2015-07-21 10:53:50,337 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter/_temporary
2015-07-21 10:53:50,339 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.889
2015-07-21 10:53:50,387 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:53:50,387 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:53:50,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 10:53:50,414 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:53:50,415 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:53:50,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:53:50,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:53:50,428 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:53:50,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup"]
2015-07-21 10:53:50,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:53:50,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:53:50,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:53:50,430 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...oupinnerouter-resultgroup
2015-07-21 10:53:50,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0013
2015-07-21 10:53:50,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0013/
2015-07-21 10:54:07,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0013_01_000002 is : 143
2015-07-21 10:54:07,271 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0013_01_000005 is : 143
2015-07-21 10:54:07,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0013_01_000004 is : 143
2015-07-21 10:54:07,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0013_01_000003 is : 143
2015-07-21 10:54:07,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0013_01_000006 is : 143
2015-07-21 10:54:13,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0013_01_000007 is : 143
2015-07-21 10:54:14,631 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup/_temporary
2015-07-21 10:54:14,633 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.200
2015-07-21 10:54:14,680 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter
2015-07-21 10:54:14,693 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup
2015-07-21 10:54:14,742 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:54:14,743 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:54:14,793 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-07-21 10:54:14,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:54:14,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:54:14,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:54:14,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 10:54:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:54:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields"]
2015-07-21 10:54:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:54:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:54:14,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:54:14,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupDiffFields/difffields
2015-07-21 10:54:14,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0014
2015-07-21 10:54:14,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0014/
2015-07-21 10:54:34,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000003 is : 143
2015-07-21 10:54:34,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000002 is : 143
2015-07-21 10:54:34,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000004 is : 143
2015-07-21 10:54:34,735 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000005 is : 143
2015-07-21 10:54:34,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000006 is : 143
2015-07-21 10:54:34,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000007 is : 143
2015-07-21 10:54:40,282 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0014_01_000008 is : 143
2015-07-21 10:54:41,465 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields/_temporary
2015-07-21 10:54:41,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.650
2015-07-21 10:54:41,497 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields
2015-07-21 10:54:41,521 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:54:41,522 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:54:41,551 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 10:54:41,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:54:41,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:54:41,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-07-21 10:54:41,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:54:41,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2"]
2015-07-21 10:54:41,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2015-07-21 10:54:41,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2015-07-21 10:54:41,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2015-07-21 10:54:41,569 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...oGroupSamePipe2/samepipe2
2015-07-21 10:54:41,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1437500917049_0015
2015-07-21 10:54:41,689 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0015/
2015-07-21 10:54:58,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0015_01_000002 is : 143
2015-07-21 10:54:58,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0015_01_000004 is : 143
2015-07-21 10:54:58,694 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0015_01_000005 is : 143
2015-07-21 10:54:58,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0015_01_000006 is : 143
2015-07-21 10:54:58,725 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0015_01_000003 is : 143
2015-07-21 10:55:04,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0015_01_000007 is : 143
2015-07-21 10:55:05,642 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2/_temporary
2015-07-21 10:55:05,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:24.073
2015-07-21 10:55:05,675 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2
2015-07-21 10:55:05,704 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:55:05,705 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:55:05,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-07-21 10:55:05,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:55:05,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:55:05,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2015-07-21 10:55:05,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:55:05,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3"]
2015-07-21 10:55:05,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] parallel execution of steps is enabled: true
2015-07-21 10:55:05,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executing total steps: 1
2015-07-21 10:55:05,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] allocating management threads: 1
2015-07-21 10:55:05,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...oGroupSamePipe3/samepipe3
2015-07-21 10:55:05,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_1437500917049_0016
2015-07-21 10:55:05,880 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0016/
2015-07-21 10:55:22,842 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0016_01_000006 is : 143
2015-07-21 10:55:23,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0016_01_000004 is : 143
2015-07-21 10:55:23,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0016_01_000003 is : 143
2015-07-21 10:55:23,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0016_01_000005 is : 143
2015-07-21 10:55:23,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0016_01_000002 is : 143
2015-07-21 10:55:29,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0016_01_000007 is : 143
2015-07-21 10:55:30,557 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3/_temporary
2015-07-21 10:55:30,559 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] completed in: 00:24.809
2015-07-21 10:55:30,603 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3
2015-07-21 10:55:30,660 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:55:30,660 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:55:30,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-07-21 10:55:30,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:55:30,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:55:30,705 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-07-21 10:55:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 10:55:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 10:55:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross"]
2015-07-21 10:55:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2015-07-21 10:55:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2015-07-21 10:55:30,706 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2015-07-21 10:55:30,707 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2015-07-21 10:55:30,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1437500917049_0017
2015-07-21 10:55:30,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0017/
2015-07-21 10:55:47,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0017_01_000003 is : 143
2015-07-21 10:55:48,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0017_01_000002 is : 143
2015-07-21 10:55:48,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0017_01_000004 is : 143
2015-07-21 10:55:48,221 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0017_01_000005 is : 143
2015-07-21 10:55:48,312 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0017_01_000006 is : 143
2015-07-21 10:55:54,049 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0017_01_000007 is : 143
2015-07-21 10:55:55,227 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross/_temporary
2015-07-21 10:55:55,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:24.520
2015-07-21 10:55:55,258 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross
2015-07-21 10:55:55,283 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:55:55,283 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:55:55,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 10:55:55,312 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:55:55,313 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:55:55,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-07-21 10:55:55,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:55:55,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe"]
2015-07-21 10:55:55,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2015-07-21 10:55:55,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2015-07-21 10:55:55,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2015-07-21 10:55:55,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tCoGroupSamePipe/samepipe
2015-07-21 10:55:55,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1437500917049_0018
2015-07-21 10:55:55,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0018/
2015-07-21 10:56:11,539 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0018_01_000003 is : 143
2015-07-21 10:56:11,680 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0018_01_000006 is : 143
2015-07-21 10:56:11,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0018_01_000002 is : 143
2015-07-21 10:56:11,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0018_01_000005 is : 143
2015-07-21 10:56:11,843 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0018_01_000004 is : 143
2015-07-21 10:56:17,522 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0018_01_000007 is : 143
2015-07-21 10:56:18,700 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe/_temporary
2015-07-21 10:56:18,702 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:23.373
2015-07-21 10:56:18,732 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe
2015-07-21 10:56:18,761 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:56:18,762 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:56:18,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-07-21 10:56:18,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:56:18,811 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:56:18,821 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:56:18,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 10:56:18,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:56:18,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone"]
2015-07-21 10:56:18,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:56:18,822 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:56:18,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:56:18,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2015-07-21 10:56:18,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0019
2015-07-21 10:56:18,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0019/
2015-07-21 10:56:36,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000003 is : 143
2015-07-21 10:56:36,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000002 is : 143
2015-07-21 10:56:36,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000007 is : 143
2015-07-21 10:56:36,977 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000006 is : 143
2015-07-21 10:56:37,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000005 is : 143
2015-07-21 10:56:37,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000004 is : 143
2015-07-21 10:56:42,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0019_01_000008 is : 143
2015-07-21 10:56:43,944 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone/_temporary
2015-07-21 10:56:43,946 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:25.121
2015-07-21 10:56:43,974 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone
2015-07-21 10:56:44,007 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:56:44,007 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:56:44,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2015-07-21 10:56:44,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-07-21 10:56:44,074 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:56:44,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:56:44,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 10:56:44,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:56:44,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery"]
2015-07-21 10:56:44,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:56:44,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2015-07-21 10:56:44,111 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2015-07-21 10:56:44,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-07-21 10:56:44,115 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-07-21 10:56:44,275 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0020
2015-07-21 10:56:44,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0020/
2015-07-21 10:56:44,286 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0021
2015-07-21 10:56:44,286 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0021/
2015-07-21 10:57:02,454 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0020_01_000003 is : 143
2015-07-21 10:57:02,586 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0020_01_000002 is : 143
2015-07-21 10:57:02,757 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0020_01_000004 is : 143
2015-07-21 10:57:02,815 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0020_01_000005 is : 143
2015-07-21 10:57:02,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0020_01_000006 is : 143
2015-07-21 10:57:16,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0020_01_000007 is : 143
2015-07-21 10:57:17,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0021_01_000004 is : 143
2015-07-21 10:57:17,909 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0021_01_000003 is : 143
2015-07-21 10:57:17,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0021_01_000006 is : 143
2015-07-21 10:57:18,017 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0021_01_000007 is : 143
2015-07-21 10:57:18,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0021_01_000005 is : 143
2015-07-21 10:57:23,557 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0021_01_000008 is : 143
2015-07-21 10:57:24,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...roupAfterEvery/afterevery
2015-07-21 10:57:24,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0022
2015-07-21 10:57:24,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0022/
2015-07-21 10:57:35,003 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0022_01_000002 is : 143
2015-07-21 10:57:35,044 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0022_01_000003 is : 143
2015-07-21 10:57:40,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0022_01_000004 is : 143
2015-07-21 10:57:42,138 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery/_temporary
2015-07-21 10:57:42,143 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:58.023
2015-07-21 10:57:42,170 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery
2015-07-21 10:57:42,210 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:57:42,211 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:57:42,316 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.102
2015-07-21 10:57:42,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 10
2015-07-21 10:57:42,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:57:42,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting
2015-07-21 10:57:42,386 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-07-21 10:57:42,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-07-21 10:57:42,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer"]
2015-07-21 10:57:42,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner"]
2015-07-21 10:57:42,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left"]
2015-07-21 10:57:42,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right"]
2015-07-21 10:57:42,387 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] parallel execution of steps is enabled: true
2015-07-21 10:57:42,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executing total steps: 5
2015-07-21 10:57:42,388 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] allocating management threads: 5
2015-07-21 10:57:42,390 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (1/5)
2015-07-21 10:57:42,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0023
2015-07-21 10:57:42,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0023/
2015-07-21 10:57:56,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0023_01_000002 is : 143
2015-07-21 10:57:56,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0023_01_000003 is : 143
2015-07-21 10:57:56,542 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0023_01_000005 is : 143
2015-07-21 10:57:56,593 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0023_01_000004 is : 143
2015-07-21 10:58:01,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0023_01_000006 is : 143
2015-07-21 10:58:02,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (3/5) ...atform/testMultiJoin/left
2015-07-21 10:58:02,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (5/5) ...tform/testMultiJoin/right
2015-07-21 10:58:02,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (4/5) ...tform/testMultiJoin/outer
2015-07-21 10:58:02,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (2/5) ...tform/testMultiJoin/inner
2015-07-21 10:58:03,211 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0024
2015-07-21 10:58:03,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0024/
2015-07-21 10:58:03,216 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0025
2015-07-21 10:58:03,216 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0025/
2015-07-21 10:58:03,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0026
2015-07-21 10:58:03,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0026/
2015-07-21 10:58:03,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0027
2015-07-21 10:58:03,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0027/
2015-07-21 10:58:22,389 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0024_01_000004 is : 143
2015-07-21 10:58:22,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0024_01_000002 is : 143
2015-07-21 10:58:22,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0024_01_000005 is : 143
2015-07-21 10:58:22,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0024_01_000003 is : 143
2015-07-21 10:58:23,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0024_01_000006 is : 143
2015-07-21 10:58:37,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0024_01_000007 is : 143
2015-07-21 10:58:38,068 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0025_01_000004 is : 143
2015-07-21 10:58:38,191 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0025_01_000003 is : 143
2015-07-21 10:58:38,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0025_01_000006 is : 143
2015-07-21 10:58:38,351 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0025_01_000002 is : 143
2015-07-21 10:58:38,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0025_01_000005 is : 143
2015-07-21 10:58:45,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0025_01_000007 is : 143
2015-07-21 10:59:01,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0026_01_000006 is : 143
2015-07-21 10:59:01,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0026_01_000005 is : 143
2015-07-21 10:59:01,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0026_01_000004 is : 143
2015-07-21 10:59:01,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0026_01_000002 is : 143
2015-07-21 10:59:01,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0026_01_000003 is : 143
2015-07-21 10:59:15,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0026_01_000007 is : 143
2015-07-21 10:59:17,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0027_01_000006 is : 143
2015-07-21 10:59:17,417 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0027_01_000005 is : 143
2015-07-21 10:59:17,437 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0027_01_000004 is : 143
2015-07-21 10:59:17,566 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0027_01_000002 is : 143
2015-07-21 10:59:17,633 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0027_01_000003 is : 143
2015-07-21 10:59:23,282 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0027_01_000007 is : 143
2015-07-21 10:59:24,429 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner/_temporary
2015-07-21 10:59:24,430 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left/_temporary
2015-07-21 10:59:24,430 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer/_temporary
2015-07-21 10:59:24,431 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right/_temporary
2015-07-21 10:59:24,435 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] completed in: 01:42.040
2015-07-21 10:59:24,503 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right
2015-07-21 10:59:24,511 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner
2015-07-21 10:59:24,517 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left
2015-07-21 10:59:24,522 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer
2015-07-21 10:59:24,548 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:59:24,548 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:59:24,578 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 10:59:24,579 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:59:24,580 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:59:24,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] starting
2015-07-21 10:59:24,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:59:24,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 10:59:24,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields"]
2015-07-21 10:59:24,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] parallel execution of steps is enabled: true
2015-07-21 10:59:24,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] executing total steps: 1
2015-07-21 10:59:24,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] allocating management threads: 1
2015-07-21 10:59:24,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] starting step: (1/1) ...meFile/samefiledifffields
2015-07-21 10:59:24,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] submitted hadoop job: job_1437500917049_0028
2015-07-21 10:59:24,711 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0028/
2015-07-21 10:59:41,904 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000007 is : 143
2015-07-21 10:59:42,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000006 is : 143
2015-07-21 10:59:42,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000005 is : 143
2015-07-21 10:59:42,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000004 is : 143
2015-07-21 10:59:42,348 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000002 is : 143
2015-07-21 10:59:42,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000003 is : 143
2015-07-21 10:59:47,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0028_01_000008 is : 143
2015-07-21 10:59:48,957 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields/_temporary
2015-07-21 10:59:48,959 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] completed in: 00:24.362
2015-07-21 10:59:48,986 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields
2015-07-21 10:59:49,021 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 10:59:49,021 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 10:59:49,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-07-21 10:59:49,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 10:59:49,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 10:59:49,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 10:59:49,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 10:59:49,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 10:59:49,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner"]
2015-07-21 10:59:49,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 10:59:49,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 10:59:49,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 10:59:49,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...erInner/cogroupouterinner
2015-07-21 10:59:49,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0029
2015-07-21 10:59:49,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0029/
2015-07-21 11:00:04,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0029_01_000002 is : 143
2015-07-21 11:00:04,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0029_01_000005 is : 143
2015-07-21 11:00:04,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0029_01_000003 is : 143
2015-07-21 11:00:05,065 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0029_01_000006 is : 143
2015-07-21 11:00:05,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0029_01_000004 is : 143
2015-07-21 11:00:10,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0029_01_000007 is : 143
2015-07-21 11:00:12,105 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner/_temporary
2015-07-21 11:00:12,107 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.035
2015-07-21 11:00:12,154 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:00:12,155 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:00:12,178 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-07-21 11:00:12,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:00:12,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:00:12,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:00:12,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:00:12,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:00:12,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup"]
2015-07-21 11:00:12,189 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:00:12,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:00:12,190 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:00:12,191 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...oupouterinner-resultgroup
2015-07-21 11:00:12,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0030
2015-07-21 11:00:12,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0030/
2015-07-21 11:00:28,752 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0030_01_000002 is : 143
2015-07-21 11:00:28,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0030_01_000003 is : 143
2015-07-21 11:00:28,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0030_01_000005 is : 143
2015-07-21 11:00:29,024 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0030_01_000006 is : 143
2015-07-21 11:00:29,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0030_01_000004 is : 143
2015-07-21 11:00:34,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0030_01_000007 is : 143
2015-07-21 11:00:35,396 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup/_temporary
2015-07-21 11:00:35,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.205
2015-07-21 11:00:35,432 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup
2015-07-21 11:00:35,440 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner
2015-07-21 11:00:35,467 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:00:35,468 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:00:35,557 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2015-07-21 11:00:35,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 8
2015-07-21 11:00:35,560 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:00:35,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting
2015-07-21 11:00:35,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] source: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-07-21 11:00:35,600 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs"]
2015-07-21 11:00:35,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs"]
2015-07-21 11:00:35,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs"]
2015-07-21 11:00:35,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs"]
2015-07-21 11:00:35,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] parallel execution of steps is enabled: true
2015-07-21 11:00:35,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executing total steps: 4
2015-07-21 11:00:35,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] allocating management threads: 4
2015-07-21 11:00:35,604 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (1/4) ...JoinWithSplits/uniquesLhs
2015-07-21 11:00:35,604 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (3/4) ...JoinWithSplits/uniquesRhs
2015-07-21 11:00:35,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (4/4) ...tiJoinWithSplits/innerRhs
2015-07-21 11:00:35,604 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (2/4) ...tiJoinWithSplits/innerLhs
2015-07-21 11:00:35,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0031
2015-07-21 11:00:35,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0031/
2015-07-21 11:00:35,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0032
2015-07-21 11:00:35,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0032/
2015-07-21 11:00:35,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0033
2015-07-21 11:00:35,883 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0033/
2015-07-21 11:00:35,905 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1437500917049_0034
2015-07-21 11:00:35,905 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0034/
2015-07-21 11:00:54,019 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0031_01_000002 is : 143
2015-07-21 11:00:54,058 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0031_01_000003 is : 143
2015-07-21 11:00:54,195 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0031_01_000005 is : 143
2015-07-21 11:00:54,327 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0031_01_000004 is : 143
2015-07-21 11:01:06,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0032_01_000005 is : 143
2015-07-21 11:01:06,917 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0032_01_000004 is : 143
2015-07-21 11:01:07,077 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0032_01_000002 is : 143
2015-07-21 11:01:07,152 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0032_01_000003 is : 143
2015-07-21 11:01:07,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0031_01_000006 is : 143
2015-07-21 11:01:12,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0032_01_000006 is : 143
2015-07-21 11:01:31,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0033_01_000002 is : 143
2015-07-21 11:01:31,969 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0033_01_000003 is : 143
2015-07-21 11:01:32,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0033_01_000004 is : 143
2015-07-21 11:01:32,332 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0033_01_000005 is : 143
2015-07-21 11:01:45,139 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0033_01_000006 is : 143
2015-07-21 11:01:45,708 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0034_01_000002 is : 143
2015-07-21 11:01:45,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0034_01_000004 is : 143
2015-07-21 11:01:45,779 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0034_01_000003 is : 143
2015-07-21 11:01:45,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0034_01_000005 is : 143
2015-07-21 11:01:51,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0034_01_000006 is : 143
2015-07-21 11:01:53,130 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs/_temporary
2015-07-21 11:01:53,132 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs/_temporary
2015-07-21 11:01:53,133 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs/_temporary
2015-07-21 11:01:53,133 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs/_temporary
2015-07-21 11:01:53,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] completed in: 01:17.529
2015-07-21 11:01:53,240 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs
2015-07-21 11:01:53,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs
2015-07-21 11:01:53,255 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs
2015-07-21 11:01:53,261 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs
2015-07-21 11:01:53,282 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:01:53,282 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:01:53,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 11:01:53,312 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:01:53,313 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:01:53,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:01:53,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:01:53,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:01:53,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull"]
2015-07-21 11:01:53,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:01:53,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:01:53,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:01:53,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ull/cogroupinnerouternull
2015-07-21 11:01:53,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0035
2015-07-21 11:01:53,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0035/
2015-07-21 11:02:09,482 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0035_01_000004 is : 143
2015-07-21 11:02:09,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0035_01_000003 is : 143
2015-07-21 11:02:09,544 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0035_01_000002 is : 143
2015-07-21 11:02:09,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0035_01_000005 is : 143
2015-07-21 11:02:09,726 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0035_01_000006 is : 143
2015-07-21 11:02:15,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0035_01_000007 is : 143
2015-07-21 11:02:16,327 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull/_temporary
2015-07-21 11:02:16,328 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.002
2015-07-21 11:02:16,377 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:02:16,377 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:02:16,401 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-07-21 11:02:16,402 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:02:16,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:02:16,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:02:16,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:02:16,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:02:16,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup"]
2015-07-21 11:02:16,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:02:16,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:02:16,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:02:16,423 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nnerouternull-resultgroup
2015-07-21 11:02:16,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0036
2015-07-21 11:02:16,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0036/
2015-07-21 11:02:31,916 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0036_01_000002 is : 143
2015-07-21 11:02:31,991 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0036_01_000003 is : 143
2015-07-21 11:02:32,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0036_01_000005 is : 143
2015-07-21 11:02:32,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0036_01_000006 is : 143
2015-07-21 11:02:32,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0036_01_000004 is : 143
2015-07-21 11:02:37,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0036_01_000007 is : 143
2015-07-21 11:02:39,041 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup/_temporary
2015-07-21 11:02:39,043 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:22.620
2015-07-21 11:02:39,074 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup
2015-07-21 11:02:39,081 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull
2015-07-21 11:02:39,108 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:02:39,108 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:02:39,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 11:02:39,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:02:39,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:02:39,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:02:39,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:02:39,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:02:39,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull"]
2015-07-21 11:02:39,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:02:39,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:02:39,146 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:02:39,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...uterNull/cogroupouternull
2015-07-21 11:02:39,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0037
2015-07-21 11:02:39,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0037/
2015-07-21 11:02:55,627 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0037_01_000006 is : 143
2015-07-21 11:02:55,684 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0037_01_000002 is : 143
2015-07-21 11:02:55,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0037_01_000003 is : 143
2015-07-21 11:02:55,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0037_01_000005 is : 143
2015-07-21 11:02:55,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0037_01_000004 is : 143
2015-07-21 11:03:01,327 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0037_01_000007 is : 143
2015-07-21 11:03:02,497 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull/_temporary
2015-07-21 11:03:02,499 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.350
2015-07-21 11:03:02,540 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:03:02,541 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:03:02,565 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-07-21 11:03:02,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:03:02,566 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:03:02,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:03:02,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:03:02,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:03:02,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup"]
2015-07-21 11:03:02,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:03:02,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:03:02,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:03:02,577 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupouternull-resultgroup
2015-07-21 11:03:02,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0038
2015-07-21 11:03:02,693 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0038/
2015-07-21 11:03:18,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0038_01_000002 is : 143
2015-07-21 11:03:19,133 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0038_01_000005 is : 143
2015-07-21 11:03:19,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0038_01_000003 is : 143
2015-07-21 11:03:19,219 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0038_01_000004 is : 143
2015-07-21 11:03:19,274 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0038_01_000006 is : 143
2015-07-21 11:03:25,296 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0038_01_000007 is : 143
2015-07-21 11:03:26,464 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup/_temporary
2015-07-21 11:03:26,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.887
2015-07-21 11:03:26,493 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup
2015-07-21 11:03:26,500 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull
2015-07-21 11:03:26,520 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:03:26,521 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:03:26,561 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2015-07-21 11:03:26,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:03:26,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:03:26,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2015-07-21 11:03:26,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:03:26,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:03:26,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:03:26,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:03:26,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs"]
2015-07-21 11:03:26,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs"]
2015-07-21 11:03:26,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] parallel execution of steps is enabled: true
2015-07-21 11:03:26,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executing total steps: 2
2015-07-21 11:03:26,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] allocating management threads: 2
2015-07-21 11:03:26,587 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/2) ...Self/splitcogroupself/lhs
2015-07-21 11:03:26,588 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/2) ...Self/splitcogroupself/rhs
2015-07-21 11:03:26,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1437500917049_0039
2015-07-21 11:03:26,739 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0039/
2015-07-21 11:03:26,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1437500917049_0040
2015-07-21 11:03:26,762 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0040/
2015-07-21 11:03:45,544 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0039_01_000005 is : 143
2015-07-21 11:03:45,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0039_01_000003 is : 143
2015-07-21 11:03:45,833 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0039_01_000004 is : 143
2015-07-21 11:03:45,954 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0039_01_000006 is : 143
2015-07-21 11:03:46,011 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0039_01_000002 is : 143
2015-07-21 11:04:00,426 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0039_01_000007 is : 143
2015-07-21 11:04:00,649 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0040_01_000003 is : 143
2015-07-21 11:04:00,713 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0040_01_000002 is : 143
2015-07-21 11:04:00,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0040_01_000005 is : 143
2015-07-21 11:04:00,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0040_01_000004 is : 143
2015-07-21 11:04:00,993 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0040_01_000006 is : 143
2015-07-21 11:04:06,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0040_01_000007 is : 143
2015-07-21 11:04:08,179 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs/_temporary
2015-07-21 11:04:08,180 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs/_temporary
2015-07-21 11:04:08,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] completed in: 00:41.593
2015-07-21 11:04:08,216 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs
2015-07-21 11:04:08,224 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs
2015-07-21 11:04:08,248 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:04:08,249 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:04:08,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 11:04:08,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:04:08,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:04:08,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2015-07-21 11:04:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:04:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:04:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes"]
2015-07-21 11:04:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] parallel execution of steps is enabled: true
2015-07-21 11:04:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executing total steps: 1
2015-07-21 11:04:08,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] allocating management threads: 1
2015-07-21 11:04:08,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2015-07-21 11:04:08,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_1437500917049_0041
2015-07-21 11:04:08,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0041/
2015-07-21 11:04:27,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000007 is : 143
2015-07-21 11:04:27,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000002 is : 143
2015-07-21 11:04:27,666 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000006 is : 143
2015-07-21 11:04:27,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000003 is : 143
2015-07-21 11:04:27,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000005 is : 143
2015-07-21 11:04:27,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000004 is : 143
2015-07-21 11:04:33,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0041_01_000008 is : 143
2015-07-21 11:04:34,772 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes/_temporary
2015-07-21 11:04:34,774 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] completed in: 00:26.480
2015-07-21 11:04:34,802 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes
2015-07-21 11:04:34,827 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:04:34,828 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:04:34,872 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-07-21 11:04:34,873 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:04:34,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:04:34,895 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:04:34,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:04:34,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:04:34,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch"]
2015-07-21 11:04:34,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:04:34,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-07-21 11:04:34,896 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-07-21 11:04:34,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-07-21 11:04:35,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0042
2015-07-21 11:04:35,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0042/
2015-07-21 11:04:53,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0042_01_000005 is : 143
2015-07-21 11:04:53,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0042_01_000003 is : 143
2015-07-21 11:04:53,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0042_01_000002 is : 143
2015-07-21 11:04:53,359 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0042_01_000004 is : 143
2015-07-21 11:04:53,434 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0042_01_000006 is : 143
2015-07-21 11:04:59,234 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0042_01_000007 is : 143
2015-07-21 11:05:00,400 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...nch/cogroupfilteredbranch
2015-07-21 11:05:00,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0043
2015-07-21 11:05:00,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0043/
2015-07-21 11:05:17,770 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000002 is : 143
2015-07-21 11:05:17,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000007 is : 143
2015-07-21 11:05:18,008 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000005 is : 143
2015-07-21 11:05:18,135 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000003 is : 143
2015-07-21 11:05:18,161 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000004 is : 143
2015-07-21 11:05:18,273 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000006 is : 143
2015-07-21 11:05:23,895 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0043_01_000008 is : 143
2015-07-21 11:05:25,073 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch/_temporary
2015-07-21 11:05:25,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:50.175
2015-07-21 11:05:25,107 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch
2015-07-21 11:05:25,130 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:05:25,131 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:05:25,159 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 11:05:25,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:05:25,161 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup"]
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:05:25,172 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:05:25,174 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tform/testCoGroup/cogroup
2015-07-21 11:05:25,286 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0044
2015-07-21 11:05:25,286 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0044/
2015-07-21 11:05:43,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000003 is : 143
2015-07-21 11:05:43,740 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000006 is : 143
2015-07-21 11:05:43,910 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000007 is : 143
2015-07-21 11:05:43,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000004 is : 143
2015-07-21 11:05:43,985 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000002 is : 143
2015-07-21 11:05:44,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000005 is : 143
2015-07-21 11:05:50,336 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0044_01_000008 is : 143
2015-07-21 11:05:51,484 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup/_temporary
2015-07-21 11:05:51,486 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.310
2015-07-21 11:05:51,513 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup
2015-07-21 11:05:51,541 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:05:51,541 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:05:51,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-07-21 11:05:51,573 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:05:51,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:05:51,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:05:51,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:05:51,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:05:51,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown"]
2015-07-21 11:05:51,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:05:51,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:05:51,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:05:51,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...GroupWithUnknowns/unknown
2015-07-21 11:05:51,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0045
2015-07-21 11:05:51,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0045/
2015-07-21 11:06:10,190 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000003 is : 143
2015-07-21 11:06:10,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000007 is : 143
2015-07-21 11:06:10,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000005 is : 143
2015-07-21 11:06:10,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000002 is : 143
2015-07-21 11:06:10,487 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000006 is : 143
2015-07-21 11:06:10,525 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000004 is : 143
2015-07-21 11:06:16,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0045_01_000008 is : 143
2015-07-21 11:06:17,976 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown/_temporary
2015-07-21 11:06:17,978 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:26.383
2015-07-21 11:06:18,004 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown
2015-07-21 11:06:18,027 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:06:18,028 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:06:18,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-07-21 11:06:18,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:06:18,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:06:18,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:06:18,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:06:18,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:06:18,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull"]
2015-07-21 11:06:18,067 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:06:18,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:06:18,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:06:18,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ull/cogroupouterinnernull
2015-07-21 11:06:18,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0046
2015-07-21 11:06:18,181 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0046/
2015-07-21 11:06:34,279 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0046_01_000002 is : 143
2015-07-21 11:06:34,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0046_01_000003 is : 143
2015-07-21 11:06:34,485 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0046_01_000004 is : 143
2015-07-21 11:06:34,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0046_01_000006 is : 143
2015-07-21 11:06:34,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0046_01_000005 is : 143
2015-07-21 11:06:39,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0046_01_000007 is : 143
2015-07-21 11:06:40,623 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull/_temporary
2015-07-21 11:06:40,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:22.555
2015-07-21 11:06:40,674 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:06:40,674 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:06:40,695 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2015-07-21 11:06:40,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:06:40,697 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:06:40,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:06:40,708 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:06:40,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:06:40,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup"]
2015-07-21 11:06:40,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:06:40,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:06:40,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:06:40,715 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...uterinnernull-resultgroup
2015-07-21 11:06:40,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0047
2015-07-21 11:06:40,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0047/
2015-07-21 11:06:57,248 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0047_01_000002 is : 143
2015-07-21 11:06:57,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0047_01_000003 is : 143
2015-07-21 11:06:57,482 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0047_01_000004 is : 143
2015-07-21 11:06:57,614 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0047_01_000005 is : 143
2015-07-21 11:06:57,649 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0047_01_000006 is : 143
2015-07-21 11:07:02,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0047_01_000007 is : 143
2015-07-21 11:07:04,098 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup/_temporary
2015-07-21 11:07:04,100 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.389
2015-07-21 11:07:04,135 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup
2015-07-21 11:07:04,141 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull
2015-07-21 11:07:04,163 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:07:04,163 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:07:04,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-07-21 11:07:04,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:07:04,187 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull"]
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:07:04,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:07:04,202 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nnerNull/cogroupinnernull
2015-07-21 11:07:04,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0048
2015-07-21 11:07:04,306 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0048/
2015-07-21 11:07:21,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0048_01_000003 is : 143
2015-07-21 11:07:21,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0048_01_000004 is : 143
2015-07-21 11:07:21,534 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0048_01_000005 is : 143
2015-07-21 11:07:21,597 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0048_01_000002 is : 143
2015-07-21 11:07:21,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0048_01_000006 is : 143
2015-07-21 11:07:26,757 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0048_01_000007 is : 143
2015-07-21 11:07:27,926 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull/_temporary
2015-07-21 11:07:27,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.722
2015-07-21 11:07:27,985 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:07:27,985 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:07:28,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 11:07:28,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:07:28,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:07:28,023 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:07:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-21 11:07:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-21 11:07:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup"]
2015-07-21 11:07:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:07:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:07:28,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:07:28,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupinnernull-resultgroup
2015-07-21 11:07:28,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0049
2015-07-21 11:07:28,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0049/
2015-07-21 11:07:44,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0049_01_000002 is : 143
2015-07-21 11:07:44,440 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0049_01_000004 is : 143
2015-07-21 11:07:44,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0049_01_000006 is : 143
2015-07-21 11:07:44,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0049_01_000005 is : 143
2015-07-21 11:07:44,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0049_01_000003 is : 143
2015-07-21 11:07:50,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0049_01_000007 is : 143
2015-07-21 11:07:51,212 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup/_temporary
2015-07-21 11:07:51,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:23.188
2015-07-21 11:07:51,241 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull
2015-07-21 11:07:51,248 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup
2015-07-21 11:07:51,271 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:07:51,272 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:07:51,297 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 11:07:51,298 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:07:51,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:07:51,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:07:51,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:07:51,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-21 11:07:51,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle"]
2015-07-21 11:07:51,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:07:51,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:07:51,309 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:07:51,310 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...eField/cogroupinnersingle
2015-07-21 11:07:51,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0050
2015-07-21 11:07:51,424 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0050/
2015-07-21 11:08:09,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000002 is : 143
2015-07-21 11:08:09,410 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000003 is : 143
2015-07-21 11:08:09,614 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000004 is : 143
2015-07-21 11:08:09,674 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000005 is : 143
2015-07-21 11:08:09,713 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000006 is : 143
2015-07-21 11:08:09,744 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000007 is : 143
2015-07-21 11:08:15,102 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0050_01_000008 is : 143
2015-07-21 11:08:16,267 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle/_temporary
2015-07-21 11:08:16,269 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.957
2015-07-21 11:08:16,302 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle
2015-07-21 11:08:16,329 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:08:16,329 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:08:16,383 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.051
2015-07-21 11:08:16,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-07-21 11:08:16,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:08:16,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:08:16,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:08:16,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:08:16,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared"]
2015-07-21 11:08:16,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:08:16,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2015-07-21 11:08:16,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2015-07-21 11:08:16,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-07-21 11:08:16,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-07-21 11:08:16,590 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0052
2015-07-21 11:08:16,591 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0052/
2015-07-21 11:08:16,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0051
2015-07-21 11:08:16,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0051/
2015-07-21 11:08:35,312 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0052_01_000006 is : 143
2015-07-21 11:08:35,648 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0052_01_000004 is : 143
2015-07-21 11:08:35,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0052_01_000003 is : 143
2015-07-21 11:08:35,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0052_01_000002 is : 143
2015-07-21 11:08:36,031 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0052_01_000005 is : 143
2015-07-21 11:08:51,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0052_01_000007 is : 143
2015-07-21 11:08:51,948 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0051_01_000006 is : 143
2015-07-21 11:08:52,130 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0051_01_000003 is : 143
2015-07-21 11:08:52,268 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0051_01_000005 is : 143
2015-07-21 11:08:52,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0051_01_000004 is : 143
2015-07-21 11:08:52,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0051_01_000002 is : 143
2015-07-21 11:08:58,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0051_01_000007 is : 143
2015-07-21 11:08:59,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...ared/aftereverynodeclared
2015-07-21 11:08:59,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0053
2015-07-21 11:08:59,338 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0053/
2015-07-21 11:09:11,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0053_01_000002 is : 143
2015-07-21 11:09:11,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0053_01_000003 is : 143
2015-07-21 11:09:17,141 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0053_01_000004 is : 143
2015-07-21 11:09:18,318 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared/_temporary
2015-07-21 11:09:18,320 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:01.898
2015-07-21 11:09:18,350 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared
2015-07-21 11:09:18,373 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:09:18,373 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:09:18,398 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.015
2015-07-21 11:09:18,399 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:09:18,400 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:09:18,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:09:18,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:09:18,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:09:18,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself"]
2015-07-21 11:09:18,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:09:18,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:09:18,412 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:09:18,413 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stCoGroupSelf/cogroupself
2015-07-21 11:09:18,512 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0054
2015-07-21 11:09:18,512 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0054/
2015-07-21 11:09:35,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0054_01_000004 is : 143
2015-07-21 11:09:35,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0054_01_000006 is : 143
2015-07-21 11:09:35,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0054_01_000003 is : 143
2015-07-21 11:09:35,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0054_01_000005 is : 143
2015-07-21 11:09:35,550 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0054_01_000002 is : 143
2015-07-21 11:09:41,665 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0054_01_000007 is : 143
2015-07-21 11:09:42,865 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself/_temporary
2015-07-21 11:09:42,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.453
2015-07-21 11:09:42,894 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself
2015-07-21 11:09:42,923 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:09:42,923 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.1/616db6028856ef10fd9ffb4ebd59ea94589475c4/cascading-hadoop2-mr1-3.0.1.jar
2015-07-21 11:09:42,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 11:09:42,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-07-21 11:09:42,954 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:09:42,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:09:42,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-21 11:09:42,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-21 11:09:42,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby"]
2015-07-21 11:09:42,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:09:42,974 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-07-21 11:09:42,975 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-07-21 11:09:42,976 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-07-21 11:09:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0055
2015-07-21 11:09:43,085 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0055/
2015-07-21 11:10:00,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000002 is : 143
2015-07-21 11:10:00,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000003 is : 143
2015-07-21 11:10:00,987 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000007 is : 143
2015-07-21 11:10:01,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000005 is : 143
2015-07-21 11:10:01,156 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000004 is : 143
2015-07-21 11:10:01,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000006 is : 143
2015-07-21 11:10:06,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0055_01_000008 is : 143
2015-07-21 11:10:07,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...oupGroupBy/cogroupgroupby
2015-07-21 11:10:07,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437500917049_0056
2015-07-21 11:10:07,634 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:53824/proxy/application_1437500917049_0056/
2015-07-21 11:10:16,768 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0056_01_000002 is : 143
2015-07-21 11:10:22,784 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437500917049_0056_01_000003 is : 143
2015-07-21 11:10:24,010 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby/_temporary
2015-07-21 11:10:24,012 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:41.033
2015-07-21 11:10:24,039 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby