Class cascading.CoGroupFieldedPipesPlatformTest

31

tests

0

failures

0

ignored

22m6.16s

duration

100%

successful

Tests

Test Duration Result
testCoGroup 26.404s passed
testCoGroupAfterEvery 58.196s passed
testCoGroupAfterEveryNoDeclared 1m2.05s passed
testCoGroupAroundCoGroup 50.799s passed
testCoGroupAroundCoGroupWith 49.022s passed
testCoGroupAroundCoGroupWithout 49.600s passed
testCoGroupDiffFields 26.794s passed
testCoGroupDiffFieldsSameFile 24.464s passed
testCoGroupFilteredBranch 50.304s passed
testCoGroupGroupBy 41.144s passed
testCoGroupInner 1m16.21s passed
testCoGroupInnerNull 47.107s passed
testCoGroupInnerOuter 48.329s passed
testCoGroupInnerOuterNull 45.821s passed
testCoGroupInnerSingleField 25.054s passed
testCoGroupMixed 32.465s passed
testCoGroupOuter 50.403s passed
testCoGroupOuterInner 46.453s passed
testCoGroupOuterInnerNull 46.138s passed
testCoGroupOuterNull 47.420s passed
testCoGroupSamePipe 23.476s passed
testCoGroupSamePipe2 24.178s passed
testCoGroupSamePipe3 24.928s passed
testCoGroupSamePipeName 26.577s passed
testCoGroupSelf 24.543s passed
testCoGroupWithUnknowns 26.492s passed
testCross 24.653s passed
testJoinNone 25.240s passed
testMultiJoin 1m42.35s passed
testMultiJoinWithSplits 1m17.82s passed
testSplitCoGroupSelf 41.724s passed

Standard output

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

Standard error

SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/hadoop/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/castillo/.gradle/caches/modules-2/files-2.1/org.slf4j/slf4j-log4j12/1.7.5/6edffc576ce104ec769d954618764f39f0f0f10d/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
Jul 21, 2015 10:48:37 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Jul 21, 2015 10:48:37 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 10:48:37 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 10:48:37 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 10:48:37 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:37 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Jul 21, 2015 10:48:38 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 10:48:38 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:38 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:39 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 10:48:39 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 10:48:39 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 10:48:39 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 10:48:39 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 10:48:39 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:39 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:39 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:39 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 10:48:40 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 10:48:40 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 10:48:40 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 10:48:40 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 10:48:40 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:40 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:40 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:40 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Jul 21, 2015 10:48:41 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Jul 21, 2015 10:48:41 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Jul 21, 2015 10:48:41 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Jul 21, 2015 10:48:41 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Jul 21, 2015 10:48:41 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:41 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:41 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Jul 21, 2015 10:48:41 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.