2015-07-21 11:27:40,568 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-07-21 11:27:40,586 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.JoinFieldedPipesPlatformTest, with platform: hadoop2-mr1
2015-07-21 11:27:40,615 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-07-21 11:27:41,410 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 11:27:41,853 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-21 11:27:47,751 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 11:27:47,959 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 11:27:48,154 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 11:27:48,332 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 11:28:05,437 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-07-21 11:28:05,532 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:28:05,533 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:28:05,582 INFO property.AppProps (AppProps.java:getAppID(174)) - using app.id: 78528C43944643A88306B2FFEAC29692
2015-07-21 11:28:05,684 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2015-07-21 11:28:05,687 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:28:05,688 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:28:05,782 INFO util.Version (Version.java:printBanner(81)) - Concurrent, Inc - Cascading 3.0.1
2015-07-21 11:28:05,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:28:05,783 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:28:05,783 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:28:05,784 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/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle"]
2015-07-21 11:28:05,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:28:05,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:28:05,784 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:28:05,785 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ngleField/joininnersingle
2015-07-21 11:28:06,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0001
2015-07-21 11:28:06,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0001/
2015-07-21 11:28:22,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0001_01_000006 is : 143
2015-07-21 11:28:23,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0001_01_000004 is : 143
2015-07-21 11:28:23,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0001_01_000003 is : 143
2015-07-21 11:28:23,414 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0001_01_000002 is : 143
2015-07-21 11:28:23,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0001_01_000005 is : 143
2015-07-21 11:28:24,887 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle/_temporary
2015-07-21 11:28:24,889 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:19.100
2015-07-21 11:28:24,961 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerSingleField/joininnersingle
2015-07-21 11:28:25,007 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:28:25,008 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:28:25,068 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.055
2015-07-21 11:28:25,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-07-21 11:28:25,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:28:25,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2015-07-21 11:28:25,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [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 11:28:25,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [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 11:28:25,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple"]
2015-07-21 11:28:25,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] parallel execution of steps is enabled: true
2015-07-21 11:28:25,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executing total steps: 2
2015-07-21 11:28:25,104 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] allocating management threads: 2
2015-07-21 11:28:25,106 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/2)
2015-07-21 11:28:25,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1437503279917_0002
2015-07-21 11:28:25,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0002/
2015-07-21 11:28:44,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0002_01_000002 is : 143
2015-07-21 11:28:44,690 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0002_01_000003 is : 143
2015-07-21 11:28:44,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0002_01_000006 is : 143
2015-07-21 11:28:45,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0002_01_000004 is : 143
2015-07-21 11:28:45,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0002_01_000005 is : 143
2015-07-21 11:28:46,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/2) ...nsamesourceintojoinsimple
2015-07-21 11:28:46,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1437503279917_0003
2015-07-21 11:28:46,451 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0003/
2015-07-21 11:29:03,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0003_01_000003 is : 143
2015-07-21 11:29:03,634 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0003_01_000002 is : 143
2015-07-21 11:29:03,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0003_01_000004 is : 143
2015-07-21 11:29:03,914 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0003_01_000006 is : 143
2015-07-21 11:29:04,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0003_01_000005 is : 143
2015-07-21 11:29:05,332 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple/_temporary
2015-07-21 11:29:05,334 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] completed in: 00:40.225
2015-07-21 11:29:05,400 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoinSimple/joinsamesourceintojoinsimple
2015-07-21 11:29:05,464 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:29:05,464 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:29:05,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2015-07-21 11:29:05,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-07-21 11:29:05,537 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:29:05,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting
2015-07-21 11:29:05,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*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 11:29:05,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*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 11:29:05,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*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 11:29:05,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost"]
2015-07-21 11:29:05,562 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] parallel execution of steps is enabled: true
2015-07-21 11:29:05,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] executing total steps: 2
2015-07-21 11:29:05,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] allocating management threads: 2
2015-07-21 11:29:05,564 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (1/2)
2015-07-21 11:29:05,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_1437503279917_0004
2015-07-21 11:29:05,703 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0004/
2015-07-21 11:29:22,728 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0004_01_000006 is : 143
2015-07-21 11:29:22,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0004_01_000002 is : 143
2015-07-21 11:29:23,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0004_01_000004 is : 143
2015-07-21 11:29:23,332 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0004_01_000005 is : 143
2015-07-21 11:29:23,371 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0004_01_000003 is : 143
2015-07-21 11:29:24,564 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] starting step: (2/2) ...st/joinaroundjoinleftmost
2015-07-21 11:29:24,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] submitted hadoop job: job_1437503279917_0005
2015-07-21 11:29:24,700 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0005/
2015-07-21 11:29:41,027 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0005_01_000002 is : 143
2015-07-21 11:29:41,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0005_01_000003 is : 143
2015-07-21 11:29:41,189 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0005_01_000006 is : 143
2015-07-21 11:29:41,507 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0005_01_000004 is : 143
2015-07-21 11:29:41,540 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0005_01_000005 is : 143
2015-07-21 11:29:42,739 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost/_temporary
2015-07-21 11:29:42,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2*lower] completed in: 00:37.172
2015-07-21 11:29:42,790 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinLeftMost/joinaroundjoinleftmost
2015-07-21 11:29:42,830 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:29:42,831 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:29:42,882 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-07-21 11:29:42,884 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:29:42,884 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:29:42,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2015-07-21 11:29:42,900 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:29:42,901 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:29:42,901 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/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes"]
2015-07-21 11:29:42,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] parallel execution of steps is enabled: true
2015-07-21 11:29:42,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executing total steps: 1
2015-07-21 11:29:42,901 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] allocating management threads: 1
2015-07-21 11:29:42,902 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2015-07-21 11:29:43,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_1437503279917_0006
2015-07-21 11:29:43,036 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0006/
2015-07-21 11:29:59,595 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0006_01_000002 is : 143
2015-07-21 11:29:59,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0006_01_000003 is : 143
2015-07-21 11:29:59,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0006_01_000005 is : 143
2015-07-21 11:30:00,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0006_01_000006 is : 143
2015-07-21 11:30:00,685 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0006_01_000004 is : 143
2015-07-21 11:30:02,329 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes/_temporary
2015-07-21 11:30:02,331 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] completed in: 00:19.427
2015-07-21 11:30:02,381 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeName/renamedpipes
2015-07-21 11:30:02,434 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:30:02,435 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:30:02,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2015-07-21 11:30:02,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-07-21 11:30:02,511 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:30:02,552 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:30:02,552 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:30:02,552 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:30:02,552 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/joinfieldedpipesplatform/testJoinAfterEvery/afterevery"]
2015-07-21 11:30:02,552 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:30:02,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 3
2015-07-21 11:30:02,553 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 3
2015-07-21 11:30:02,554 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-07-21 11:30:02,554 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-07-21 11:30:02,720 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0007
2015-07-21 11:30:02,720 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0007/
2015-07-21 11:30:02,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0008
2015-07-21 11:30:02,735 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0008/
2015-07-21 11:30:22,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0007_01_000003 is : 143
2015-07-21 11:30:22,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0007_01_000004 is : 143
2015-07-21 11:30:22,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0007_01_000002 is : 143
2015-07-21 11:30:22,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0007_01_000005 is : 143
2015-07-21 11:30:22,334 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0007_01_000006 is : 143
2015-07-21 11:30:36,145 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0008_01_000006 is : 143
2015-07-21 11:30:36,290 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0008_01_000002 is : 143
2015-07-21 11:30:36,397 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0008_01_000005 is : 143
2015-07-21 11:30:36,446 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0008_01_000004 is : 143
2015-07-21 11:30:36,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0008_01_000003 is : 143
2015-07-21 11:30:36,867 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0007_01_000007 is : 143
2015-07-21 11:30:41,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0008_01_000007 is : 143
2015-07-21 11:30:42,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...JoinAfterEvery/afterevery
2015-07-21 11:30:42,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0009
2015-07-21 11:30:42,783 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0009/
2015-07-21 11:30:52,244 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0009_01_000002 is : 143
2015-07-21 11:30:53,444 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery/_temporary
2015-07-21 11:30:53,446 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:50.889
2015-07-21 11:30:53,477 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAfterEvery/afterevery
2015-07-21 11:30:53,524 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:30:53,524 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:30:53,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2015-07-21 11:30:53,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:30:53,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:30:53,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-07-21 11:30:53,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin"]
2015-07-21 11:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2015-07-21 11:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 1
2015-07-21 11:30:53,606 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 1
2015-07-21 11:30:53,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-07-21 11:30:53,715 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1437503279917_0010
2015-07-21 11:30:53,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0010/
2015-07-21 11:31:09,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0010_01_000002 is : 143
2015-07-21 11:31:09,400 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0010_01_000003 is : 143
2015-07-21 11:31:09,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0010_01_000005 is : 143
2015-07-21 11:31:09,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0010_01_000004 is : 143
2015-07-21 11:31:09,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0010_01_000006 is : 143
2015-07-21 11:31:14,874 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0010_01_000007 is : 143
2015-07-21 11:31:16,045 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin/_temporary
2015-07-21 11:31:16,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:22.438
2015-07-21 11:31:16,076 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhsSwappedJoin/joinsintocogrouplhsswappedjoin
2015-07-21 11:31:16,116 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:31:16,116 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:31:16,184 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.065
2015-07-21 11:31:16,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2015-07-21 11:31:16,186 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:31:16,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2015-07-21 11:31:16,223 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/upper.txt"]
2015-07-21 11:31:16,223 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:31:16,223 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+upper.txt"]
2015-07-21 11:31:16,223 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/joinfieldedpipesplatform/testGroupBySplitJoins/rhs"]
2015-07-21 11:31:16,223 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/joinfieldedpipesplatform/testGroupBySplitJoins/lhs"]
2015-07-21 11:31:16,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] parallel execution of steps is enabled: true
2015-07-21 11:31:16,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executing total steps: 3
2015-07-21 11:31:16,223 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] allocating management threads: 3
2015-07-21 11:31:16,227 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/3)
2015-07-21 11:31:16,370 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1437503279917_0011
2015-07-21 11:31:16,371 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0011/
2015-07-21 11:31:31,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0011_01_000003 is : 143
2015-07-21 11:31:31,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0011_01_000002 is : 143
2015-07-21 11:31:32,131 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0011_01_000004 is : 143
2015-07-21 11:31:32,188 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0011_01_000005 is : 143
2015-07-21 11:31:32,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0011_01_000006 is : 143
2015-07-21 11:31:37,811 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0011_01_000007 is : 143
2015-07-21 11:31:38,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/3) ...testGroupBySplitJoins/rhs
2015-07-21 11:31:38,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (3/3) ...testGroupBySplitJoins/lhs
2015-07-21 11:31:39,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1437503279917_0012
2015-07-21 11:31:39,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0012/
2015-07-21 11:31:39,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1437503279917_0013
2015-07-21 11:31:39,114 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0013/
2015-07-21 11:31:50,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0012_01_000002 is : 143
2015-07-21 11:31:56,131 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0013_01_000002 is : 143
2015-07-21 11:31:57,345 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs/_temporary
2015-07-21 11:31:57,347 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs/_temporary
2015-07-21 11:31:57,349 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] completed in: 00:41.119
2015-07-21 11:31:57,410 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/rhs
2015-07-21 11:31:57,417 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testGroupBySplitJoins/lhs
2015-07-21 11:31:57,442 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:31:57,442 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:31:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2015-07-21 11:31:57,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 11:31:57,508 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:31:57,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-07-21 11:31:57,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:31:57,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:31:57,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:31:57,528 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:31:57,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs"]
2015-07-21 11:31:57,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2015-07-21 11:31:57,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 2
2015-07-21 11:31:57,529 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 2
2015-07-21 11:31:57,530 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2015-07-21 11:31:57,632 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1437503279917_0014
2015-07-21 11:31:57,633 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0014/
2015-07-21 11:32:13,452 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0014_01_000002 is : 143
2015-07-21 11:32:13,516 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0014_01_000003 is : 143
2015-07-21 11:32:13,835 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0014_01_000004 is : 143
2015-07-21 11:32:13,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0014_01_000006 is : 143
2015-07-21 11:32:13,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0014_01_000005 is : 143
2015-07-21 11:32:15,130 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upLhs/joinsintocogrouplhs
2015-07-21 11:32:15,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1437503279917_0015
2015-07-21 11:32:15,247 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0015/
2015-07-21 11:32:30,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0015_01_000006 is : 143
2015-07-21 11:32:30,999 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0015_01_000004 is : 143
2015-07-21 11:32:31,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0015_01_000005 is : 143
2015-07-21 11:32:31,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0015_01_000002 is : 143
2015-07-21 11:32:31,338 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0015_01_000003 is : 143
2015-07-21 11:32:36,476 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0015_01_000007 is : 143
2015-07-21 11:32:37,649 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs/_temporary
2015-07-21 11:32:37,651 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:40.118
2015-07-21 11:32:37,683 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupLhs/joinsintocogrouplhs
2015-07-21 11:32:37,724 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:32:37,725 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:32:37,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2015-07-21 11:32:37,790 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 11:32:37,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:32:37,816 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-07-21 11:32:37,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:32:37,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:32:37,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:32:37,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:32:37,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs"]
2015-07-21 11:32:37,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2015-07-21 11:32:37,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 2
2015-07-21 11:32:37,818 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 2
2015-07-21 11:32:37,819 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/2)
2015-07-21 11:32:37,944 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1437503279917_0016
2015-07-21 11:32:37,944 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0016/
2015-07-21 11:32:53,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0016_01_000006 is : 143
2015-07-21 11:32:53,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0016_01_000004 is : 143
2015-07-21 11:32:53,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0016_01_000005 is : 143
2015-07-21 11:32:53,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0016_01_000002 is : 143
2015-07-21 11:32:54,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0016_01_000003 is : 143
2015-07-21 11:32:55,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (2/2) ...upRhs/joinsintocogrouprhs
2015-07-21 11:32:55,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1437503279917_0017
2015-07-21 11:32:55,353 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0017/
2015-07-21 11:33:10,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0017_01_000005 is : 143
2015-07-21 11:33:10,900 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0017_01_000002 is : 143
2015-07-21 11:33:10,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0017_01_000003 is : 143
2015-07-21 11:33:11,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0017_01_000006 is : 143
2015-07-21 11:33:11,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0017_01_000004 is : 143
2015-07-21 11:33:16,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0017_01_000007 is : 143
2015-07-21 11:33:17,759 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs/_temporary
2015-07-21 11:33:17,761 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:39.940
2015-07-21 11:33:17,789 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroupRhs/joinsintocogrouprhs
2015-07-21 11:33:17,911 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:33:17,911 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:33:17,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-07-21 11:33:17,935 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:33:17,935 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:33:17,951 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:33:17,951 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:33:17,951 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:33:17,951 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/joinfieldedpipesplatform/testJoinWithHasher/joinhasher"]
2015-07-21 11:33:17,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:33:17,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:33:17,952 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:33:17,953 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinWithHasher/joinhasher
2015-07-21 11:33:18,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0018
2015-07-21 11:33:18,073 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0018/
2015-07-21 11:33:34,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0018_01_000004 is : 143
2015-07-21 11:33:34,622 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0018_01_000003 is : 143
2015-07-21 11:33:34,721 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0018_01_000006 is : 143
2015-07-21 11:33:34,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0018_01_000005 is : 143
2015-07-21 11:33:34,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0018_01_000002 is : 143
2015-07-21 11:33:36,071 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher/_temporary
2015-07-21 11:33:36,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:18.118
2015-07-21 11:33:36,115 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithHasher/joinhasher
2015-07-21 11:33:36,158 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:33:36,159 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:33:36,212 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2015-07-21 11:33:36,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 11:33:36,214 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:33:36,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting
2015-07-21 11:33:36,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] 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:33:36,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] 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:33:36,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-21 11:33:36,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin"]
2015-07-21 11:33:36,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] parallel execution of steps is enabled: true
2015-07-21 11:33:36,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] executing total steps: 2
2015-07-21 11:33:36,230 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] allocating management threads: 2
2015-07-21 11:33:36,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (1/2)
2015-07-21 11:33:36,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_1437503279917_0019
2015-07-21 11:33:36,352 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0019/
2015-07-21 11:33:52,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0019_01_000003 is : 143
2015-07-21 11:33:52,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0019_01_000002 is : 143
2015-07-21 11:33:53,163 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0019_01_000005 is : 143
2015-07-21 11:33:53,311 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0019_01_000006 is : 143
2015-07-21 11:33:53,351 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0019_01_000004 is : 143
2015-07-21 11:33:59,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0019_01_000007 is : 143
2015-07-21 11:34:00,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] starting step: (2/2) ...oupByJoin/joingroupbyjoin
2015-07-21 11:34:00,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] submitted hadoop job: job_1437503279917_0020
2015-07-21 11:34:00,968 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0020/
2015-07-21 11:34:11,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0020_01_000002 is : 143
2015-07-21 11:34:12,398 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin/_temporary
2015-07-21 11:34:12,404 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper*joined] completed in: 00:36.166
2015-07-21 11:34:12,431 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupByJoin/joingroupbyjoin
2015-07-21 11:34:12,461 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:34:12,461 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:34:12,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2015-07-21 11:34:12,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:34:12,481 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:34:12,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-07-21 11:34:12,489 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 11:34:12,489 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 11:34:12,489 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/joinfieldedpipesplatform/testCross/cross"]
2015-07-21 11:34:12,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2015-07-21 11:34:12,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 1
2015-07-21 11:34:12,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 1
2015-07-21 11:34:12,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2015-07-21 11:34:12,592 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1437503279917_0021
2015-07-21 11:34:12,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0021/
2015-07-21 11:34:26,750 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0021_01_000003 is : 143
2015-07-21 11:34:26,803 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0021_01_000002 is : 143
2015-07-21 11:34:27,001 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0021_01_000004 is : 143
2015-07-21 11:34:27,140 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0021_01_000005 is : 143
2015-07-21 11:34:28,306 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testCross/cross/_temporary
2015-07-21 11:34:28,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:15.817
2015-07-21 11:34:28,348 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testCross/cross
2015-07-21 11:34:28,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:34:28,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:34:28,410 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-07-21 11:34:28,411 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:34:28,411 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:34:28,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:34:28,419 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:34:28,419 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:34:28,419 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/joinfieldedpipesplatform/testJoin/join"]
2015-07-21 11:34:28,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:34:28,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:34:28,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:34:28,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...pesplatform/testJoin/join
2015-07-21 11:34:28,521 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0022
2015-07-21 11:34:28,522 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0022/
2015-07-21 11:34:45,643 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0022_01_000004 is : 143
2015-07-21 11:34:45,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0022_01_000005 is : 143
2015-07-21 11:34:45,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0022_01_000003 is : 143
2015-07-21 11:34:46,019 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0022_01_000006 is : 143
2015-07-21 11:34:46,047 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0022_01_000002 is : 143
2015-07-21 11:34:47,275 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoin/join/_temporary
2015-07-21 11:34:47,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:18.854
2015-07-21 11:34:47,340 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoin/join
2015-07-21 11:34:47,387 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:34:47,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 11:34:47,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.097
2015-07-21 11:34:47,492 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-07-21 11:34:47,492 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:34:47,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-07-21 11:34:47,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:34:47,539 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:34:47,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:34:47,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs"]
2015-07-21 11:34:47,540 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs"]
2015-07-21 11:34:47,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-07-21 11:34:47,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 3
2015-07-21 11:34:47,541 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 3
2015-07-21 11:34:47,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2015-07-21 11:34:47,680 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0023
2015-07-21 11:34:47,681 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0023/
2015-07-21 11:35:04,278 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0023_01_000003 is : 143
2015-07-21 11:35:04,395 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0023_01_000002 is : 143
2015-07-21 11:35:04,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0023_01_000005 is : 143
2015-07-21 11:35:04,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0023_01_000004 is : 143
2015-07-21 11:35:04,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0023_01_000006 is : 143
2015-07-21 11:35:06,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...stJoinSplitBeforeJoin/lhs
2015-07-21 11:35:06,016 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...stJoinSplitBeforeJoin/rhs
2015-07-21 11:35:06,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0024
2015-07-21 11:35:06,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0024/
2015-07-21 11:35:06,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0025
2015-07-21 11:35:06,177 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0025/
2015-07-21 11:35:23,578 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0024_01_000003 is : 143
2015-07-21 11:35:23,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0024_01_000004 is : 143
2015-07-21 11:35:23,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0024_01_000002 is : 143
2015-07-21 11:35:23,903 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0024_01_000005 is : 143
2015-07-21 11:35:38,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0025_01_000005 is : 143
2015-07-21 11:35:38,232 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0025_01_000006 is : 143
2015-07-21 11:35:38,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0025_01_000003 is : 143
2015-07-21 11:35:38,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0025_01_000004 is : 143
2015-07-21 11:35:38,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0025_01_000002 is : 143
2015-07-21 11:35:38,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0024_01_000006 is : 143
2015-07-21 11:35:43,559 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0025_01_000007 is : 143
2015-07-21 11:35:44,729 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs/_temporary
2015-07-21 11:35:44,730 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs/_temporary
2015-07-21 11:35:44,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:57.188
2015-07-21 11:35:44,761 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/rhs
2015-07-21 11:35:44,769 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplitBeforeJoin/lhs
2015-07-21 11:35:44,794 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:35:44,795 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:35:44,839 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-07-21 11:35:44,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:35:44,840 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:35:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting
2015-07-21 11:35:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] 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:35:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] 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:35:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:35:44,863 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:35:44,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby"]
2015-07-21 11:35:44,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] parallel execution of steps is enabled: true
2015-07-21 11:35:44,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] executing total steps: 1
2015-07-21 11:35:44,864 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] allocating management threads: 1
2015-07-21 11:35:44,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] starting step: (1/1) ...oGroupBy/joinsintogroupby
2015-07-21 11:35:45,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] submitted hadoop job: job_1437503279917_0026
2015-07-21 11:35:45,010 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0026/
2015-07-21 11:36:03,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000003 is : 143
2015-07-21 11:36:03,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000007 is : 143
2015-07-21 11:36:03,693 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000005 is : 143
2015-07-21 11:36:03,751 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000002 is : 143
2015-07-21 11:36:03,929 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000006 is : 143
2015-07-21 11:36:04,025 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000004 is : 143
2015-07-21 11:36:09,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0026_01_000008 is : 143
2015-07-21 11:36:10,789 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby/_temporary
2015-07-21 11:36:10,791 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merging] completed in: 00:25.925
2015-07-21 11:36:10,819 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoGroupBy/joinsintogroupby
2015-07-21 11:36:10,839 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:36:10,839 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:36:10,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-07-21 11:36:10,868 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:36:10,869 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:36:10,876 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:36:10,876 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:36:10,876 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:36:10,877 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/joinfieldedpipesplatform/testJoinWithUnknowns/unknown"]
2015-07-21 11:36:10,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:36:10,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:36:10,877 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:36:10,878 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tJoinWithUnknowns/unknown
2015-07-21 11:36:10,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0027
2015-07-21 11:36:10,987 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0027/
2015-07-21 11:36:26,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0027_01_000003 is : 143
2015-07-21 11:36:26,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0027_01_000002 is : 143
2015-07-21 11:36:27,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0027_01_000006 is : 143
2015-07-21 11:36:27,265 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0027_01_000004 is : 143
2015-07-21 11:36:27,300 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0027_01_000005 is : 143
2015-07-21 11:36:28,461 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown/_temporary
2015-07-21 11:36:28,462 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:17.583
2015-07-21 11:36:28,501 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinWithUnknowns/unknown
2015-07-21 11:36:28,535 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:36:28,535 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:36:28,575 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2015-07-21 11:36:28,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:36:28,576 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 11:36:28,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2015-07-21 11:36:28,584 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 11:36:28,584 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 11:36:28,585 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 11:36:28,585 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/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost"]
2015-07-21 11:36:28,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2015-07-21 11:36:28,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executing total steps: 1
2015-07-21 11:36:28,585 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] allocating management threads: 1
2015-07-21 11:36:28,586 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/1) ...t/joinaroundjoinrightmost
2015-07-21 11:36:28,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1437503279917_0028
2015-07-21 11:36:28,692 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0028/
2015-07-21 11:36:45,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0028_01_000003 is : 143
2015-07-21 11:36:45,345 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0028_01_000002 is : 143
2015-07-21 11:36:45,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0028_01_000006 is : 143
2015-07-21 11:36:45,554 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0028_01_000004 is : 143
2015-07-21 11:36:45,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0028_01_000005 is : 143
2015-07-21 11:36:46,928 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost/_temporary
2015-07-21 11:36:46,930 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] completed in: 00:18.340
2015-07-21 11:36:46,972 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMost/joinaroundjoinrightmost
2015-07-21 11:36:47,012 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:36:47,012 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:36:47,033 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.018
2015-07-21 11:36:47,035 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:36:47,035 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:36:47,044 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:36:47,044 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:36:47,044 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:36:47,044 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/joinfieldedpipesplatform/testJoinNone/joinnone"]
2015-07-21 11:36:47,044 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:36:47,045 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:36:47,045 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:36:47,046 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2015-07-21 11:36:47,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0029
2015-07-21 11:36:47,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0029/
2015-07-21 11:37:03,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0029_01_000003 is : 143
2015-07-21 11:37:03,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0029_01_000002 is : 143
2015-07-21 11:37:03,744 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0029_01_000006 is : 143
2015-07-21 11:37:03,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0029_01_000005 is : 143
2015-07-21 11:37:03,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0029_01_000004 is : 143
2015-07-21 11:37:05,134 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone/_temporary
2015-07-21 11:37:05,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:18.090
2015-07-21 11:37:05,175 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinNone/joinnone
2015-07-21 11:37:05,218 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:37:05,219 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:37:05,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-07-21 11:37:05,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-07-21 11:37:05,245 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:37:05,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:37:05,261 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:37:05,261 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:37:05,262 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/joinfieldedpipesplatform/testJoinSelf/joinself"]
2015-07-21 11:37:05,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:37:05,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-07-21 11:37:05,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-07-21 11:37:05,265 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-07-21 11:37:05,393 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0030
2015-07-21 11:37:05,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0030/
2015-07-21 11:37:22,166 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0030_01_000005 is : 143
2015-07-21 11:37:22,271 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0030_01_000004 is : 143
2015-07-21 11:37:22,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0030_01_000002 is : 143
2015-07-21 11:37:22,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0030_01_000003 is : 143
2015-07-21 11:37:22,567 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0030_01_000006 is : 143
2015-07-21 11:37:23,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...orm/testJoinSelf/joinself
2015-07-21 11:37:23,843 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0031
2015-07-21 11:37:23,843 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0031/
2015-07-21 11:37:40,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0031_01_000003 is : 143
2015-07-21 11:37:40,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0031_01_000002 is : 143
2015-07-21 11:37:40,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0031_01_000006 is : 143
2015-07-21 11:37:40,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0031_01_000004 is : 143
2015-07-21 11:37:40,971 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0031_01_000005 is : 143
2015-07-21 11:37:42,166 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself/_temporary
2015-07-21 11:37:42,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:36.902
2015-07-21 11:37:42,207 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSelf/joinself
2015-07-21 11:37:42,239 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:37:42,240 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:37:42,291 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2015-07-21 11:37:42,292 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-07-21 11:37:42,293 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs"]
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs"]
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-07-21 11:37:42,324 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 3
2015-07-21 11:37:42,325 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 3
2015-07-21 11:37:42,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/3)
2015-07-21 11:37:42,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0032
2015-07-21 11:37:42,431 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0032/
2015-07-21 11:37:56,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0032_01_000002 is : 143
2015-07-21 11:37:56,174 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0032_01_000003 is : 143
2015-07-21 11:37:56,488 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0032_01_000004 is : 143
2015-07-21 11:37:56,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0032_01_000005 is : 143
2015-07-21 11:37:57,696 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/3) ...urceJoinSplitIntoJoin/lhs
2015-07-21 11:37:57,696 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (3/3) ...urceJoinSplitIntoJoin/rhs
2015-07-21 11:37:57,812 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0033
2015-07-21 11:37:57,813 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0033/
2015-07-21 11:37:57,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0034
2015-07-21 11:37:57,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0034/
2015-07-21 11:38:14,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0033_01_000003 is : 143
2015-07-21 11:38:14,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0033_01_000002 is : 143
2015-07-21 11:38:14,592 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0033_01_000005 is : 143
2015-07-21 11:38:14,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0033_01_000004 is : 143
2015-07-21 11:38:25,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0034_01_000003 is : 143
2015-07-21 11:38:25,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0034_01_000002 is : 143
2015-07-21 11:38:25,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0034_01_000004 is : 143
2015-07-21 11:38:26,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0034_01_000005 is : 143
2015-07-21 11:38:27,173 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs/_temporary
2015-07-21 11:38:27,174 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs/_temporary
2015-07-21 11:38:27,176 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:44.846
2015-07-21 11:38:27,223 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/lhs
2015-07-21 11:38:27,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/joinfieldedpipesplatform/testSameSourceJoinSplitIntoJoin/rhs
2015-07-21 11:38:27,287 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:38:27,287 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:38:27,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-07-21 11:38:27,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-07-21 11:38:27,326 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting
2015-07-21 11:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] 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:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] 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:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] 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:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped"]
2015-07-21 11:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] parallel execution of steps is enabled: true
2015-07-21 11:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] executing total steps: 2
2015-07-21 11:38:27,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] allocating management threads: 2
2015-07-21 11:38:27,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (1/2)
2015-07-21 11:38:27,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_1437503279917_0035
2015-07-21 11:38:27,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0035/
2015-07-21 11:38:44,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0035_01_000006 is : 143
2015-07-21 11:38:44,261 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0035_01_000002 is : 143
2015-07-21 11:38:44,320 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0035_01_000005 is : 143
2015-07-21 11:38:44,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0035_01_000004 is : 143
2015-07-21 11:38:44,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0035_01_000003 is : 143
2015-07-21 11:38:45,719 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] starting step: (2/2) ...ped/joinaroundjoinswapped
2015-07-21 11:38:45,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] submitted hadoop job: job_1437503279917_0036
2015-07-21 11:38:45,832 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0036/
2015-07-21 11:39:02,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0036_01_000002 is : 143
2015-07-21 11:39:02,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0036_01_000003 is : 143
2015-07-21 11:39:02,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0036_01_000006 is : 143
2015-07-21 11:39:02,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0036_01_000004 is : 143
2015-07-21 11:39:03,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0036_01_000005 is : 143
2015-07-21 11:39:04,262 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped/_temporary
2015-07-21 11:39:04,264 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper2*lower*upper1] completed in: 00:36.918
2015-07-21 11:39:04,311 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinAroundJoinRightMostSwapped/joinaroundjoinswapped
2015-07-21 11:39:04,346 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:39:04,347 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:39:04,384 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-07-21 11:39:04,385 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 11:39:04,386 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:39:04,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:39:04,405 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:39:04,405 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:39:04,405 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/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch"]
2015-07-21 11:39:04,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:39:04,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-07-21 11:39:04,406 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-07-21 11:39:04,407 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-07-21 11:39:04,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0037
2015-07-21 11:39:04,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0037/
2015-07-21 11:39:21,997 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0037_01_000006 is : 143
2015-07-21 11:39:22,249 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0037_01_000005 is : 143
2015-07-21 11:39:22,339 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0037_01_000002 is : 143
2015-07-21 11:39:22,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0037_01_000004 is : 143
2015-07-21 11:39:22,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0037_01_000003 is : 143
2015-07-21 11:39:27,524 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0037_01_000007 is : 143
2015-07-21 11:39:28,721 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...Branch/joinfilteredbranch
2015-07-21 11:39:28,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0038
2015-07-21 11:39:28,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0038/
2015-07-21 11:39:46,092 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0038_01_000002 is : 143
2015-07-21 11:39:46,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0038_01_000003 is : 143
2015-07-21 11:39:46,483 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0038_01_000006 is : 143
2015-07-21 11:39:46,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0038_01_000004 is : 143
2015-07-21 11:39:46,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0038_01_000005 is : 143
2015-07-21 11:39:48,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/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch/_temporary
2015-07-21 11:39:48,140 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:43.730
2015-07-21 11:39:48,183 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinFilteredBranch/joinfilteredbranch
2015-07-21 11:39:48,218 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:39:48,218 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:39:48,261 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-07-21 11:39:48,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-07-21 11:39:48,262 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 11:39:48,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2015-07-21 11:39:48,279 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 11:39:48,279 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 11:39:48,279 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 11:39:48,279 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/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin"]
2015-07-21 11:39:48,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] parallel execution of steps is enabled: true
2015-07-21 11:39:48,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executing total steps: 3
2015-07-21 11:39:48,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] allocating management threads: 3
2015-07-21 11:39:48,284 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/3)
2015-07-21 11:39:48,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1437503279917_0039
2015-07-21 11:39:48,394 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0039/
2015-07-21 11:40:05,204 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0039_01_000005 is : 143
2015-07-21 11:40:05,311 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0039_01_000006 is : 143
2015-07-21 11:40:05,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0039_01_000004 is : 143
2015-07-21 11:40:05,632 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0039_01_000003 is : 143
2015-07-21 11:40:05,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0039_01_000002 is : 143
2015-07-21 11:40:06,834 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/3)
2015-07-21 11:40:06,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1437503279917_0040
2015-07-21 11:40:06,938 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0040/
2015-07-21 11:40:24,129 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0040_01_000002 is : 143
2015-07-21 11:40:24,408 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0040_01_000004 is : 143
2015-07-21 11:40:24,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0040_01_000005 is : 143
2015-07-21 11:40:24,647 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0040_01_000003 is : 143
2015-07-21 11:40:24,868 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0040_01_000006 is : 143
2015-07-21 11:40:26,129 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (3/3) ...in/joinsamesourceintojoin
2015-07-21 11:40:26,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1437503279917_0041
2015-07-21 11:40:26,255 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0041/
2015-07-21 11:40:44,732 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0041_01_000003 is : 143
2015-07-21 11:40:45,033 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0041_01_000002 is : 143
2015-07-21 11:40:45,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0041_01_000006 is : 143
2015-07-21 11:40:45,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0041_01_000005 is : 143
2015-07-21 11:40:45,372 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0041_01_000004 is : 143
2015-07-21 11:40:46,569 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin/_temporary
2015-07-21 11:40:46,576 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] completed in: 00:58.287
2015-07-21 11:40:46,617 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceIntoJoin/joinsamesourceintojoin
2015-07-21 11:40:46,670 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:40:46,671 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:40:46,716 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.042
2015-07-21 11:40:46,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:40:46,717 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:40:46,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting
2015-07-21 11:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] 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:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup"]
2015-07-21 11:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] parallel execution of steps is enabled: true
2015-07-21 11:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] executing total steps: 1
2015-07-21 11:40:46,734 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] allocating management threads: 1
2015-07-21 11:40:46,736 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] starting step: (1/1) ...oCoGroup/joinsintocogroup
2015-07-21 11:40:46,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] submitted hadoop job: job_1437503279917_0042
2015-07-21 11:40:46,871 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0042/
2015-07-21 11:41:07,744 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000003 is : 143
2015-07-21 11:41:07,902 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000002 is : 143
2015-07-21 11:41:08,088 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000005 is : 143
2015-07-21 11:41:08,123 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000007 is : 143
2015-07-21 11:41:08,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000006 is : 143
2015-07-21 11:41:08,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000004 is : 143
2015-07-21 11:41:14,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0042_01_000008 is : 143
2015-07-21 11:41:15,373 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup/_temporary
2015-07-21 11:41:15,375 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [cogrouping] completed in: 00:28.638
2015-07-21 11:41:15,404 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinsIntoCoGroup/joinsintocogroup
2015-07-21 11:41:15,450 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:41:15,451 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:41:15,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-07-21 11:41:15,473 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:41:15,474 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:41:15,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:41:15,488 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:41:15,489 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:41:15,489 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/joinfieldedpipesplatform/testJoinInner/joininner"]
2015-07-21 11:41:15,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:41:15,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:41:15,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:41:15,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...m/testJoinInner/joininner
2015-07-21 11:41:15,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0043
2015-07-21 11:41:15,601 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0043/
2015-07-21 11:41:32,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0043_01_000003 is : 143
2015-07-21 11:41:32,669 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0043_01_000005 is : 143
2015-07-21 11:41:32,758 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0043_01_000004 is : 143
2015-07-21 11:41:32,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0043_01_000006 is : 143
2015-07-21 11:41:33,018 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0043_01_000002 is : 143
2015-07-21 11:41:34,208 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner/_temporary
2015-07-21 11:41:34,210 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:18.718
2015-07-21 11:41:34,249 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInner/joininner
2015-07-21 11:41:34,283 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:41:34,284 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:41:34,317 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-07-21 11:41:34,318 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-07-21 11:41:34,319 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:41:34,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting
2015-07-21 11:41:34,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-21 11:41:34,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-21 11:41:34,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs"]
2015-07-21 11:41:34,332 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs"]
2015-07-21 11:41:34,333 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] parallel execution of steps is enabled: true
2015-07-21 11:41:34,333 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] executing total steps: 2
2015-07-21 11:41:34,333 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] allocating management threads: 2
2015-07-21 11:41:34,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (1/2) ...latform/testJoinSplit/lhs
2015-07-21 11:41:34,335 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] starting step: (2/2) ...latform/testJoinSplit/rhs
2015-07-21 11:41:34,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0044
2015-07-21 11:41:34,481 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0044/
2015-07-21 11:41:34,500 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] submitted hadoop job: job_1437503279917_0045
2015-07-21 11:41:34,500 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0045/
2015-07-21 11:41:53,775 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0044_01_000003 is : 143
2015-07-21 11:41:53,870 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0044_01_000002 is : 143
2015-07-21 11:41:54,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0044_01_000004 is : 143
2015-07-21 11:41:54,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0044_01_000005 is : 143
2015-07-21 11:42:00,876 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1067)) - Event EventType: KILL_CONTAINER sent to absent container container_1437503279917_0044_01_000001
2015-07-21 11:42:04,795 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0045_01_000002 is : 143
2015-07-21 11:42:04,892 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0045_01_000003 is : 143
2015-07-21 11:42:05,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0045_01_000005 is : 143
2015-07-21 11:42:05,367 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0045_01_000004 is : 143
2015-07-21 11:42:06,578 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs/_temporary
2015-07-21 11:42:06,580 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs/_temporary
2015-07-21 11:42:06,584 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [] completed in: 00:32.245
2015-07-21 11:42:06,645 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/rhs
2015-07-21 11:42:06,664 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSplit/lhs
2015-07-21 11:42:06,696 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:42:06,696 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:42:06,731 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-07-21 11:42:06,732 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 3
2015-07-21 11:42:06,733 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:42:06,756 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-07-21 11:42:06,757 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:42:06,757 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/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby"]
2015-07-21 11:42:06,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] parallel execution of steps is enabled: true
2015-07-21 11:42:06,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executing total steps: 2
2015-07-21 11:42:06,757 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] allocating management threads: 2
2015-07-21 11:42:06,758 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/2)
2015-07-21 11:42:06,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1437503279917_0046
2015-07-21 11:42:06,860 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0046/
2015-07-21 11:42:24,854 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0046_01_000002 is : 143
2015-07-21 11:42:25,022 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0046_01_000003 is : 143
2015-07-21 11:42:25,259 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0046_01_000006 is : 143
2015-07-21 11:42:25,378 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0046_01_000005 is : 143
2015-07-21 11:42:25,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0046_01_000004 is : 143
2015-07-21 11:42:31,704 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0046_01_000007 is : 143
2015-07-21 11:42:32,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (2/2) ...pBy/samepipearoundgroupby
2015-07-21 11:42:32,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1437503279917_0047
2015-07-21 11:42:32,969 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0047/
2015-07-21 11:42:50,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0047_01_000003 is : 143
2015-07-21 11:42:50,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0047_01_000002 is : 143
2015-07-21 11:42:50,362 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0047_01_000005 is : 143
2015-07-21 11:42:50,428 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0047_01_000006 is : 143
2015-07-21 11:42:50,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0047_01_000004 is : 143
2015-07-21 11:42:51,668 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby/_temporary
2015-07-21 11:42:51,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] completed in: 00:44.908
2015-07-21 11:42:51,707 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipeAroundGroupBy/samepipearoundgroupby
2015-07-21 11:42:51,737 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:42:51,738 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:42:51,775 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-07-21 11:42:51,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-07-21 11:42:51,776 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-07-21 11:42:51,794 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting
2015-07-21 11:42:51,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [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 11:42:51,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [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 11:42:51,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple"]
2015-07-21 11:42:51,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] parallel execution of steps is enabled: true
2015-07-21 11:42:51,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] executing total steps: 3
2015-07-21 11:42:51,795 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] allocating management threads: 3
2015-07-21 11:42:51,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (1/3)
2015-07-21 11:42:51,797 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (2/3)
2015-07-21 11:42:51,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1437503279917_0048
2015-07-21 11:42:51,923 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0048/
2015-07-21 11:42:51,941 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1437503279917_0049
2015-07-21 11:42:51,942 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0049/
2015-07-21 11:43:11,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0048_01_000003 is : 143
2015-07-21 11:43:11,292 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0048_01_000002 is : 143
2015-07-21 11:43:11,390 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0048_01_000005 is : 143
2015-07-21 11:43:11,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0048_01_000004 is : 143
2015-07-21 11:43:11,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0048_01_000006 is : 143
2015-07-21 11:43:26,485 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0048_01_000007 is : 143
2015-07-21 11:43:28,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0049_01_000003 is : 143
2015-07-21 11:43:28,372 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0049_01_000006 is : 143
2015-07-21 11:43:28,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0049_01_000002 is : 143
2015-07-21 11:43:28,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0049_01_000005 is : 143
2015-07-21 11:43:28,508 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0049_01_000004 is : 143
2015-07-21 11:43:35,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0049_01_000007 is : 143
2015-07-21 11:43:36,599 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] starting step: (3/3) ...overgroupbyintojoinsimple
2015-07-21 11:43:36,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] submitted hadoop job: job_1437503279917_0050
2015-07-21 11:43:36,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0050/
2015-07-21 11:43:46,809 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0050_01_000002 is : 143
2015-07-21 11:43:47,994 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple/_temporary
2015-07-21 11:43:47,997 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [upper1*upper2] completed in: 00:56.197
2015-07-21 11:43:48,023 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSameSourceOverGroupByIntoJoinSimple/joinsamesourceovergroupbyintojoinsimple
2015-07-21 11:43:48,069 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:43:48,070 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:43:48,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.022
2015-07-21 11:43:48,095 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [join-merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-07-21 11:43:48,096 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/testJoinMergeGroupBy/hashjoin
2015-07-21 11:43:48,109 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:43:48,110 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:43:48,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.014
2015-07-21 11:43:48,128 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:43:48,129 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 11:43:48,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-07-21 11:43:48,136 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 11:43:48,136 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/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2"]
2015-07-21 11:43:48,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2015-07-21 11:43:48,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2015-07-21 11:43:48,136 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2015-07-21 11:43:48,137 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...stJoinSamePipe2/samepipe2
2015-07-21 11:43:48,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1437503279917_0051
2015-07-21 11:43:48,240 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0051/
2015-07-21 11:44:04,853 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0051_01_000006 is : 143
2015-07-21 11:44:04,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0051_01_000002 is : 143
2015-07-21 11:44:05,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0051_01_000003 is : 143
2015-07-21 11:44:05,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0051_01_000004 is : 143
2015-07-21 11:44:05,889 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0051_01_000005 is : 143
2015-07-21 11:44:07,058 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2/_temporary
2015-07-21 11:44:07,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:18.921
2015-07-21 11:44:07,099 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe2/samepipe2
2015-07-21 11:44:07,132 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:44:07,133 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:44:07,147 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.012
2015-07-21 11:44:07,148 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:44:07,148 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 11:44:07,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2015-07-21 11:44:07,155 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 11:44:07,155 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/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3"]
2015-07-21 11:44:07,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] parallel execution of steps is enabled: true
2015-07-21 11:44:07,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executing total steps: 1
2015-07-21 11:44:07,155 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] allocating management threads: 1
2015-07-21 11:44:07,157 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...stJoinSamePipe3/samepipe3
2015-07-21 11:44:07,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_1437503279917_0052
2015-07-21 11:44:07,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0052/
2015-07-21 11:44:23,697 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0052_01_000002 is : 143
2015-07-21 11:44:24,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0052_01_000003 is : 143
2015-07-21 11:44:24,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0052_01_000004 is : 143
2015-07-21 11:44:24,107 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0052_01_000006 is : 143
2015-07-21 11:44:24,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0052_01_000005 is : 143
2015-07-21 11:44:26,124 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3/_temporary
2015-07-21 11:44:26,126 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] completed in: 00:18.968
2015-07-21 11:44:26,174 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe3/samepipe3
2015-07-21 11:44:26,216 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:44:26,217 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:44:26,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-07-21 11:44:26,249 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-07-21 11:44:26,249 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:44:26,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:44:26,266 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:44:26,267 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:44:26,267 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/joinfieldedpipesplatform/testJoinGroupBy/joingroupby"]
2015-07-21 11:44:26,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:44:26,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:44:26,267 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:44:26,268 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stJoinGroupBy/joingroupby
2015-07-21 11:44:26,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0053
2015-07-21 11:44:26,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0053/
2015-07-21 11:44:42,917 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0053_01_000002 is : 143
2015-07-21 11:44:43,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0053_01_000003 is : 143
2015-07-21 11:44:43,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0053_01_000006 is : 143
2015-07-21 11:44:43,277 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0053_01_000004 is : 143
2015-07-21 11:44:43,399 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0053_01_000005 is : 143
2015-07-21 11:44:49,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0053_01_000007 is : 143
2015-07-21 11:44:50,439 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby/_temporary
2015-07-21 11:44:50,441 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:24.171
2015-07-21 11:44:50,467 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinGroupBy/joingroupby
2015-07-21 11:44:50,487 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:44:50,487 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:44:50,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.013
2015-07-21 11:44:50,503 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:44:50,504 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 11:44:50,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-07-21 11:44:50,511 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 11:44:50,511 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/joinfieldedpipesplatform/testJoinSamePipe/samepipe"]
2015-07-21 11:44:50,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] parallel execution of steps is enabled: true
2015-07-21 11:44:50,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executing total steps: 1
2015-07-21 11:44:50,511 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] allocating management threads: 1
2015-07-21 11:44:50,512 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...testJoinSamePipe/samepipe
2015-07-21 11:44:50,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1437503279917_0054
2015-07-21 11:44:50,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0054/
2015-07-21 11:45:08,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0054_01_000002 is : 143
2015-07-21 11:45:08,636 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0054_01_000005 is : 143
2015-07-21 11:45:08,672 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0054_01_000003 is : 143
2015-07-21 11:45:08,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0054_01_000004 is : 143
2015-07-21 11:45:08,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0054_01_000006 is : 143
2015-07-21 11:45:09,978 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe/_temporary
2015-07-21 11:45:09,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] completed in: 00:19.466
2015-07-21 11:45:10,020 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinSamePipe/samepipe
2015-07-21 11:45:10,055 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:45:10,056 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:45:10,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-07-21 11:45:10,078 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:45:10,079 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:45:10,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:45:10,088 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:45:10,088 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:45:10,088 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/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter"]
2015-07-21 11:45:10,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:45:10,088 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:45:10,089 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:45:10,090 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...InnerOuter/joininnerouter
2015-07-21 11:45:10,196 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0055
2015-07-21 11:45:10,196 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0055/
2015-07-21 11:45:27,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0055_01_000003 is : 143
2015-07-21 11:45:27,318 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0055_01_000002 is : 143
2015-07-21 11:45:27,600 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0055_01_000004 is : 143
2015-07-21 11:45:27,632 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0055_01_000005 is : 143
2015-07-21 11:45:27,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0055_01_000006 is : 143
2015-07-21 11:45:28,811 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter/_temporary
2015-07-21 11:45:28,820 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:18.721
2015-07-21 11:45:28,861 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinInnerOuter/joininnerouter
2015-07-21 11:45:28,894 INFO util.Util (Util.java:findMainClass(1325)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-21 11:45:28,895 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:45:28,915 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.017
2015-07-21 11:45:28,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-07-21 11:45:28,917 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:45:28,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-07-21 11:45:28,927 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:45:28,927 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:45:28,927 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/joinfieldedpipesplatform/testJoinDiffFields/difffields"]
2015-07-21 11:45:28,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-07-21 11:45:28,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-07-21 11:45:28,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-07-21 11:45:28,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...JoinDiffFields/difffields
2015-07-21 11:45:29,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1437503279917_0056
2015-07-21 11:45:29,042 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://Marks-MacBook.local:64573/proxy/application_1437503279917_0056/
2015-07-21 11:45:45,749 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0056_01_000003 is : 143
2015-07-21 11:45:45,994 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0056_01_000004 is : 143
2015-07-21 11:45:46,028 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0056_01_000005 is : 143
2015-07-21 11:45:46,181 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0056_01_000002 is : 143
2015-07-21 11:45:47,079 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437503279917_0056_01_000006 is : 143
2015-07-21 11:45:48,252 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields/_temporary
2015-07-21 11:45:48,257 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:19.324
2015-07-21 11:45:48,304 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/castillo/code/cascading.compatibility/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinDiffFields/difffields