Class cascading.JoinFieldedPipesPlatformTest

all > cascading > JoinFieldedPipesPlatformTest
32

tests
0

failures
0

ignored
16m9.95s

duration
100%

successful

Tests

Test Duration Result
testCross 15.392s passed
testJoin 17.369s passed
testJoinAfterEvery 56.676s passed
testJoinAroundJoinLeftMost 36.740s passed
testJoinAroundJoinRightMost 17.623s passed
testJoinAroundJoinRightMostSwapped 34.902s passed
testJoinDiffFields 18.454s passed
testJoinFilteredBranch 40.155s passed
testJoinGroupBy 25.059s passed
testJoinGroupByJoin 32.886s passed
testJoinInner 18.391s passed
testJoinInnerOuter 18.204s passed
testJoinInnerSingleField 47.510s passed
testJoinMergeGroupBy 3m1.52s passed
testJoinMixed 0s passed
testJoinNone 17.236s passed
testJoinOuter 0s passed
testJoinOuterInner 0.001s passed
testJoinSamePipe 18.796s passed
testJoinSamePipe2 17.698s passed
testJoinSamePipe3 17.721s passed
testJoinSamePipeAroundGroupBy 40.652s passed
testJoinSamePipeName 17.735s passed
testJoinSameSourceIntoJoin 53.728s passed
testJoinSelf 35.303s passed
testJoinWithHasher 18.084s passed
testJoinWithUnknowns 17.823s passed
testJoinsIntoCoGroup 26.720s passed
testJoinsIntoCoGroupLhs 40.329s passed
testJoinsIntoCoGroupLhsSwappedJoin 22.996s passed
testJoinsIntoCoGroupRhs 39.559s passed
testJoinsIntoGroupBy 24.696s passed

Standard output

2015-07-17 14:23:14,984 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 14:23:15,004 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 14:23:15,005 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.JoinFieldedPipesPlatformTest
2015-07-17 14:23:15,034 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 14:23:15,904 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-17 14:23:16,398 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 14:23:20,657 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-17 14:23:20,866 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-17 14:23:21,095 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-17 14:23:21,291 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-17 14:23:38,398 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides: 
2015-07-17 14:23:38,553 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:23:38,555 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:23:38,561 INFO  property.AppProps (AppProps.java:getAppID(169)) - using app.id: CF1BDF3B36B647B084DCB2D8F0764318
2015-07-17 14:23:38,713 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 14:23:38,716 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:23:38,717 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:23:38,717 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:23:38,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle"]
2015-07-17 14:23:38,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:23:38,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:23:38,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:23:38,719 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...splatform/joininnersingle
2015-07-17 14:23:39,482 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0001
2015-07-17 14:23:39,482 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0001/
2015-07-17 14:24:00,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0001_01_000006 is : 143
2015-07-17 14:24:00,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0001_01_000005 is : 143
2015-07-17 14:24:00,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0001_01_000004 is : 143
2015-07-17 14:24:01,034 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0001_01_000003 is : 143
2015-07-17 14:24:01,123 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0001_01_000002 is : 143
2015-07-17 14:24:02,432 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnersingle/_temporary
2015-07-17 14:24:02,515 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnersingle
2015-07-17 14:24:02,630 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:24:02,630 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:24:02,738 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower] starting
2015-07-17 14:24:02,739 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:24:02,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:24:02,740 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:24:02,741 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost"]
2015-07-17 14:24:02,741 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  parallel execution is enabled: true
2015-07-17 14:24:02,741 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  starting jobs: 2
2015-07-17 14:24:02,742 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper1*upper2*lower]  allocating threads: 2
2015-07-17 14:24:02,744 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (2/2)
2015-07-17 14:24:03,029 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1437168212887_0002
2015-07-17 14:24:03,030 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0002/
2015-07-17 14:24:19,937 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0002_01_000003 is : 143
2015-07-17 14:24:20,086 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0002_01_000002 is : 143
2015-07-17 14:24:20,366 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0002_01_000004 is : 143
2015-07-17 14:24:20,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0002_01_000006 is : 143
2015-07-17 14:24:20,480 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0002_01_000005 is : 143
2015-07-17 14:24:21,682 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] starting step: (1/2) ...rm/joinaroundjoinleftmost
2015-07-17 14:24:21,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] submitted hadoop job: job_1437168212887_0003
2015-07-17 14:24:21,841 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper1*upper2*lower] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0003/
2015-07-17 14:24:37,438 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0003_01_000002 is : 143
2015-07-17 14:24:37,534 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0003_01_000003 is : 143
2015-07-17 14:24:37,857 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0003_01_000004 is : 143
2015-07-17 14:24:37,913 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0003_01_000006 is : 143
2015-07-17 14:24:37,967 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0003_01_000005 is : 143
2015-07-17 14:24:39,207 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost/_temporary
2015-07-17 14:24:39,259 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinleftmost
2015-07-17 14:24:39,306 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:24:39,307 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:24:39,338 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail] starting
2015-07-17 14:24:39,338 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:24:39,338 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:24:39,338 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes"]
2015-07-17 14:24:39,338 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  parallel execution is enabled: true
2015-07-17 14:24:39,339 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  starting jobs: 1
2015-07-17 14:24:39,339 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [tail]  allocating threads: 1
2015-07-17 14:24:39,340 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] starting step: (1/1) ...ipesplatform/renamedpipes
2015-07-17 14:24:39,494 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] submitted hadoop job: job_1437168212887_0004
2015-07-17 14:24:39,495 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [tail] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0004/
2015-07-17 14:24:55,130 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0004_01_000003 is : 143
2015-07-17 14:24:55,166 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0004_01_000002 is : 143
2015-07-17 14:24:55,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0004_01_000006 is : 143
2015-07-17 14:24:55,646 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0004_01_000004 is : 143
2015-07-17 14:24:55,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0004_01_000005 is : 143
2015-07-17 14:24:56,937 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/renamedpipes/_temporary
2015-07-17 14:24:56,994 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/renamedpipes
2015-07-17 14:24:57,037 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:24:57,038 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:24:57,084 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:24:57,084 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:24:57,084 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:24:57,084 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery"]
2015-07-17 14:24:57,084 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:24:57,084 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 3
2015-07-17 14:24:57,085 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 3
2015-07-17 14:24:57,086 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/3)
2015-07-17 14:24:57,086 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/3)
2015-07-17 14:24:57,266 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0006
2015-07-17 14:24:57,266 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0006/
2015-07-17 14:24:57,273 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0005
2015-07-17 14:24:57,273 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0005/
2015-07-17 14:25:22,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0006_01_000005 is : 143
2015-07-17 14:25:23,050 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0006_01_000002 is : 143
2015-07-17 14:25:23,664 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0006_01_000004 is : 143
2015-07-17 14:25:23,923 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0006_01_000003 is : 143
2015-07-17 14:25:24,049 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0006_01_000006 is : 143
2015-07-17 14:25:34,863 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0005_01_000006 is : 143
2015-07-17 14:25:35,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0005_01_000004 is : 143
2015-07-17 14:25:35,139 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0005_01_000003 is : 143
2015-07-17 14:25:35,156 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0005_01_000005 is : 143
2015-07-17 14:25:35,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0005_01_000002 is : 143
2015-07-17 14:25:36,287 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0006_01_000007 is : 143
2015-07-17 14:25:40,496 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0005_01_000007 is : 143
2015-07-17 14:25:41,696 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (3/3) ...dpipesplatform/afterevery
2015-07-17 14:25:41,828 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0007
2015-07-17 14:25:41,828 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0007/
2015-07-17 14:25:52,440 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0007_01_000002 is : 143
2015-07-17 14:25:53,658 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/afterevery/_temporary
2015-07-17 14:25:53,688 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/afterevery
2015-07-17 14:25:53,741 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:25:53,741 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:25:53,778 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-07-17 14:25:53,778 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin"]
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 1
2015-07-17 14:25:53,779 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 1
2015-07-17 14:25:53,780 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...intocogrouplhsswappedjoin
2015-07-17 14:25:53,898 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1437168212887_0008
2015-07-17 14:25:53,898 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0008/
2015-07-17 14:26:09,685 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0008_01_000003 is : 143
2015-07-17 14:26:09,836 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0008_01_000002 is : 143
2015-07-17 14:26:09,992 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0008_01_000006 is : 143
2015-07-17 14:26:10,090 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0008_01_000004 is : 143
2015-07-17 14:26:10,164 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0008_01_000005 is : 143
2015-07-17 14:26:15,472 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0008_01_000007 is : 143
2015-07-17 14:26:16,654 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin/_temporary
2015-07-17 14:26:16,684 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhsswappedjoin
2015-07-17 14:26:16,714 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:26:16,714 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:26:16,753 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-07-17 14:26:16,753 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:26:16,753 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:26:16,753 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 14:26:16,754 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 14:26:16,754 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs"]
2015-07-17 14:26:16,754 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-07-17 14:26:16,754 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 2
2015-07-17 14:26:16,754 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 2
2015-07-17 14:26:16,756 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-07-17 14:26:16,863 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1437168212887_0009
2015-07-17 14:26:16,863 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0009/
2015-07-17 14:26:32,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0009_01_000002 is : 143
2015-07-17 14:26:32,839 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0009_01_000004 is : 143
2015-07-17 14:26:32,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0009_01_000003 is : 143
2015-07-17 14:26:33,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0009_01_000005 is : 143
2015-07-17 14:26:33,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0009_01_000006 is : 143
2015-07-17 14:26:34,352 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouplhs
2015-07-17 14:26:34,456 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1437168212887_0010
2015-07-17 14:26:34,456 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0010/
2015-07-17 14:26:50,068 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0010_01_000003 is : 143
2015-07-17 14:26:50,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0010_01_000006 is : 143
2015-07-17 14:26:50,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0010_01_000002 is : 143
2015-07-17 14:26:50,281 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0010_01_000004 is : 143
2015-07-17 14:26:50,316 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0010_01_000005 is : 143
2015-07-17 14:26:55,815 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0010_01_000007 is : 143
2015-07-17 14:26:56,984 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs/_temporary
2015-07-17 14:26:57,014 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouplhs
2015-07-17 14:26:57,041 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:26:57,041 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:26:57,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-07-17 14:26:57,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:26:57,073 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:26:57,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 14:26:57,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 14:26:57,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs"]
2015-07-17 14:26:57,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-07-17 14:26:57,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 2
2015-07-17 14:26:57,074 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 2
2015-07-17 14:26:57,076 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (2/2)
2015-07-17 14:26:57,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1437168212887_0011
2015-07-17 14:26:57,193 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0011/
2015-07-17 14:27:12,494 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0011_01_000006 is : 143
2015-07-17 14:27:12,922 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0011_01_000004 is : 143
2015-07-17 14:27:12,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0011_01_000003 is : 143
2015-07-17 14:27:13,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0011_01_000002 is : 143
2015-07-17 14:27:13,165 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0011_01_000005 is : 143
2015-07-17 14:27:14,343 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/2) ...tform/joinsintocogrouprhs
2015-07-17 14:27:14,454 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1437168212887_0012
2015-07-17 14:27:14,454 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0012/
2015-07-17 14:27:29,851 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0012_01_000006 is : 143
2015-07-17 14:27:29,920 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0012_01_000005 is : 143
2015-07-17 14:27:30,007 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0012_01_000004 is : 143
2015-07-17 14:27:30,147 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0012_01_000002 is : 143
2015-07-17 14:27:30,214 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0012_01_000003 is : 143
2015-07-17 14:27:35,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0012_01_000007 is : 143
2015-07-17 14:27:36,542 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs/_temporary
2015-07-17 14:27:36,572 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogrouprhs
2015-07-17 14:27:36,693 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:27:36,694 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher"]
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:27:36,718 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:27:36,719 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/joinhasher
2015-07-17 14:27:36,826 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0013
2015-07-17 14:27:36,826 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0013/
2015-07-17 14:27:52,842 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0013_01_000003 is : 143
2015-07-17 14:27:52,960 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0013_01_000002 is : 143
2015-07-17 14:27:53,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0013_01_000006 is : 143
2015-07-17 14:27:53,229 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0013_01_000005 is : 143
2015-07-17 14:27:53,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0013_01_000004 is : 143
2015-07-17 14:27:54,582 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinhasher/_temporary
2015-07-17 14:27:54,641 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinhasher
2015-07-17 14:27:54,703 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:27:54,704 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:27:54,731 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined] starting
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower+upper.txt"]
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin"]
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  parallel execution is enabled: true
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  starting jobs: 2
2015-07-17 14:27:54,732 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper*joined]  allocating threads: 2
2015-07-17 14:27:54,734 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (2/2)
2015-07-17 14:27:54,860 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1437168212887_0014
2015-07-17 14:27:54,861 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0014/
2015-07-17 14:28:10,192 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0014_01_000003 is : 143
2015-07-17 14:28:10,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0014_01_000002 is : 143
2015-07-17 14:28:10,455 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0014_01_000004 is : 143
2015-07-17 14:28:10,491 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0014_01_000005 is : 143
2015-07-17 14:28:10,559 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0014_01_000006 is : 143
2015-07-17 14:28:15,870 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0014_01_000007 is : 143
2015-07-17 14:28:17,040 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] starting step: (1/2) ...splatform/joingroupbyjoin
2015-07-17 14:28:17,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] submitted hadoop job: job_1437168212887_0015
2015-07-17 14:28:17,146 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper*joined] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0015/
2015-07-17 14:28:26,311 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0015_01_000002 is : 143
2015-07-17 14:28:27,517 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin/_temporary
2015-07-17 14:28:27,545 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupbyjoin
2015-07-17 14:28:27,568 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:28:27,568 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:28:27,578 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-07-17 14:28:27,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 14:28:27,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 14:28:27,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross"]
2015-07-17 14:28:27,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-07-17 14:28:27,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 1
2015-07-17 14:28:27,579 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 1
2015-07-17 14:28:27,580 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...ieldedpipesplatform/cross
2015-07-17 14:28:27,691 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1437168212887_0016
2015-07-17 14:28:27,691 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0016/
2015-07-17 14:28:41,255 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0016_01_000003 is : 143
2015-07-17 14:28:41,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0016_01_000002 is : 143
2015-07-17 14:28:41,667 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0016_01_000005 is : 143
2015-07-17 14:28:41,691 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0016_01_000004 is : 143
2015-07-17 14:28:42,883 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/cross/_temporary
2015-07-17 14:28:42,927 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/cross
2015-07-17 14:28:42,967 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:28:42,968 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:28:42,980 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:28:42,980 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:28:42,980 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:28:42,980 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join"]
2015-07-17 14:28:42,980 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:28:42,981 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:28:42,981 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:28:42,982 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...fieldedpipesplatform/join
2015-07-17 14:28:43,112 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0017
2015-07-17 14:28:43,113 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0017/
2015-07-17 14:28:58,537 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0017_01_000003 is : 143
2015-07-17 14:28:58,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0017_01_000006 is : 143
2015-07-17 14:28:58,701 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0017_01_000002 is : 143
2015-07-17 14:28:58,975 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0017_01_000004 is : 143
2015-07-17 14:28:59,036 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0017_01_000005 is : 143
2015-07-17 14:29:00,243 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/join/_temporary
2015-07-17 14:29:00,289 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/join
2015-07-17 14:29:00,332 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:29:00,332 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:29:00,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging] starting
2015-07-17 14:29:00,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:29:00,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:29:00,354 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 14:29:00,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 14:29:00,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby"]
2015-07-17 14:29:00,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  parallel execution is enabled: true
2015-07-17 14:29:00,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  starting jobs: 1
2015-07-17 14:29:00,355 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [merging]  allocating threads: 1
2015-07-17 14:29:00,357 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] starting step: (1/1) ...platform/joinsintogroupby
2015-07-17 14:29:00,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] submitted hadoop job: job_1437168212887_0018
2015-07-17 14:29:00,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merging] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0018/
2015-07-17 14:29:17,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000003 is : 143
2015-07-17 14:29:17,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000002 is : 143
2015-07-17 14:29:17,915 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000007 is : 143
2015-07-17 14:29:17,942 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000006 is : 143
2015-07-17 14:29:18,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000004 is : 143
2015-07-17 14:29:18,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000005 is : 143
2015-07-17 14:29:23,791 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0018_01_000008 is : 143
2015-07-17 14:29:24,969 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby/_temporary
2015-07-17 14:29:24,999 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintogroupby
2015-07-17 14:29:25,031 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:29:25,031 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:29:25,044 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:29:25,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:29:25,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:29:25,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown"]
2015-07-17 14:29:25,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:29:25,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:29:25,045 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:29:25,046 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...ldedpipesplatform/unknown
2015-07-17 14:29:25,174 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0019
2015-07-17 14:29:25,174 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0019/
2015-07-17 14:29:40,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0019_01_000002 is : 143
2015-07-17 14:29:41,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0019_01_000004 is : 143
2015-07-17 14:29:41,335 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0019_01_000003 is : 143
2015-07-17 14:29:41,445 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0019_01_000006 is : 143
2015-07-17 14:29:41,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0019_01_000005 is : 143
2015-07-17 14:29:42,771 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/unknown/_temporary
2015-07-17 14:29:42,813 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/unknown
2015-07-17 14:29:42,848 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:29:42,849 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:29:42,873 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-07-17 14:29:42,873 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:29:42,873 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:29:42,873 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:29:42,873 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost"]
2015-07-17 14:29:42,874 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  parallel execution is enabled: true
2015-07-17 14:29:42,874 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  starting jobs: 1
2015-07-17 14:29:42,874 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  allocating threads: 1
2015-07-17 14:29:42,877 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/1) ...m/joinaroundjoinrightmost
2015-07-17 14:29:43,005 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1437168212887_0020
2015-07-17 14:29:43,005 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0020/
2015-07-17 14:29:58,744 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0020_01_000003 is : 143
2015-07-17 14:29:58,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0020_01_000002 is : 143
2015-07-17 14:29:59,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0020_01_000004 is : 143
2015-07-17 14:29:59,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0020_01_000005 is : 143
2015-07-17 14:29:59,180 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0020_01_000006 is : 143
2015-07-17 14:30:00,387 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost/_temporary
2015-07-17 14:30:00,437 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinrightmost
2015-07-17 14:30:00,477 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:30:00,477 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:30:00,488 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:30:00,488 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:30:00,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:30:00,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone"]
2015-07-17 14:30:00,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:30:00,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:30:00,489 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:30:00,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dedpipesplatform/joinnone
2015-07-17 14:30:00,614 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0021
2015-07-17 14:30:00,615 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0021/
2015-07-17 14:30:15,757 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0021_01_000006 is : 143
2015-07-17 14:30:16,134 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0021_01_000004 is : 143
2015-07-17 14:30:16,168 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0021_01_000002 is : 143
2015-07-17 14:30:16,376 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0021_01_000005 is : 143
2015-07-17 14:30:16,420 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0021_01_000003 is : 143
2015-07-17 14:30:17,624 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinnone/_temporary
2015-07-17 14:30:17,676 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinnone
2015-07-17 14:30:17,717 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:30:17,718 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:30:17,745 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:30:17,745 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:30:17,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:30:17,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself"]
2015-07-17 14:30:17,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:30:17,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-07-17 14:30:17,746 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-07-17 14:30:17,749 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-07-17 14:30:17,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0022
2015-07-17 14:30:17,866 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0022/
2015-07-17 14:30:33,809 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0022_01_000003 is : 143
2015-07-17 14:30:33,859 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0022_01_000002 is : 143
2015-07-17 14:30:34,176 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0022_01_000005 is : 143
2015-07-17 14:30:34,206 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0022_01_000004 is : 143
2015-07-17 14:30:34,380 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0022_01_000006 is : 143
2015-07-17 14:30:35,587 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...dedpipesplatform/joinself
2015-07-17 14:30:35,686 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0023
2015-07-17 14:30:35,686 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0023/
2015-07-17 14:30:51,150 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0023_01_000003 is : 143
2015-07-17 14:30:51,356 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0023_01_000002 is : 143
2015-07-17 14:30:51,427 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0023_01_000006 is : 143
2015-07-17 14:30:51,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0023_01_000005 is : 143
2015-07-17 14:30:51,760 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0023_01_000004 is : 143
2015-07-17 14:30:52,935 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinself/_temporary
2015-07-17 14:30:52,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinself
2015-07-17 14:30:53,021 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:30:53,022 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:30:53,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1] starting
2015-07-17 14:30:53,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:30:53,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:30:53,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:30:53,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped"]
2015-07-17 14:30:53,042 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  parallel execution is enabled: true
2015-07-17 14:30:53,043 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  starting jobs: 2
2015-07-17 14:30:53,043 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [upper2*lower*upper1]  allocating threads: 2
2015-07-17 14:30:53,044 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (2/2)
2015-07-17 14:30:53,170 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1437168212887_0024
2015-07-17 14:30:53,170 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0024/
2015-07-17 14:31:08,619 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0024_01_000003 is : 143
2015-07-17 14:31:08,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0024_01_000002 is : 143
2015-07-17 14:31:08,902 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0024_01_000005 is : 143
2015-07-17 14:31:09,076 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0024_01_000006 is : 143
2015-07-17 14:31:09,123 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0024_01_000004 is : 143
2015-07-17 14:31:10,333 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] starting step: (1/2) ...orm/joinaroundjoinswapped
2015-07-17 14:31:10,443 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] submitted hadoop job: job_1437168212887_0025
2015-07-17 14:31:10,443 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [upper2*lower*upper1] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0025/
2015-07-17 14:31:26,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0025_01_000002 is : 143
2015-07-17 14:31:26,206 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0025_01_000006 is : 143
2015-07-17 14:31:26,360 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0025_01_000003 is : 143
2015-07-17 14:31:26,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0025_01_000004 is : 143
2015-07-17 14:31:26,647 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0025_01_000005 is : 143
2015-07-17 14:31:27,839 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped/_temporary
2015-07-17 14:31:27,879 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinaroundjoinswapped
2015-07-17 14:31:27,922 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:31:27,922 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:31:27,938 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:31:27,939 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:31:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:31:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch"]
2015-07-17 14:31:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:31:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 2
2015-07-17 14:31:27,940 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 2
2015-07-17 14:31:27,943 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (2/2)
2015-07-17 14:31:28,070 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0026
2015-07-17 14:31:28,070 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0026/
2015-07-17 14:31:43,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0026_01_000006 is : 143
2015-07-17 14:31:43,515 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0026_01_000003 is : 143
2015-07-17 14:31:43,704 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0026_01_000004 is : 143
2015-07-17 14:31:43,735 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0026_01_000005 is : 143
2015-07-17 14:31:43,777 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0026_01_000002 is : 143
2015-07-17 14:31:49,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0026_01_000007 is : 143
2015-07-17 14:31:50,608 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/2) ...atform/joinfilteredbranch
2015-07-17 14:31:50,708 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0027
2015-07-17 14:31:50,708 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0027/
2015-07-17 14:32:06,102 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0027_01_000006 is : 143
2015-07-17 14:32:06,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0027_01_000005 is : 143
2015-07-17 14:32:06,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0027_01_000003 is : 143
2015-07-17 14:32:06,585 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0027_01_000004 is : 143
2015-07-17 14:32:06,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0027_01_000002 is : 143
2015-07-17 14:32:07,993 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch/_temporary
2015-07-17 14:32:08,036 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinfilteredbranch
2015-07-17 14:32:08,075 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:32:08,075 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:32:08,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2] starting
2015-07-17 14:32:08,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:32:08,107 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:32:08,108 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:32:08,108 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin"]
2015-07-17 14:32:08,108 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  parallel execution is enabled: true
2015-07-17 14:32:08,108 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  starting jobs: 3
2015-07-17 14:32:08,108 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper1*upper2]  allocating threads: 3
2015-07-17 14:32:08,110 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (3/3)
2015-07-17 14:32:08,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1437168212887_0028
2015-07-17 14:32:08,221 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0028/
2015-07-17 14:32:24,450 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0028_01_000004 is : 143
2015-07-17 14:32:24,826 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0028_01_000005 is : 143
2015-07-17 14:32:24,871 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0028_01_000003 is : 143
2015-07-17 14:32:24,906 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0028_01_000006 is : 143
2015-07-17 14:32:24,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0028_01_000002 is : 143
2015-07-17 14:32:26,116 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (2/3)
2015-07-17 14:32:26,228 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1437168212887_0029
2015-07-17 14:32:26,228 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0029/
2015-07-17 14:32:42,271 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0029_01_000006 is : 143
2015-07-17 14:32:42,445 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0029_01_000003 is : 143
2015-07-17 14:32:42,606 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0029_01_000004 is : 143
2015-07-17 14:32:42,763 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0029_01_000002 is : 143
2015-07-17 14:32:42,888 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0029_01_000005 is : 143
2015-07-17 14:32:44,087 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] starting step: (1/3) ...rm/joinsamesourceintojoin
2015-07-17 14:32:44,197 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] submitted hadoop job: job_1437168212887_0030
2015-07-17 14:32:44,197 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper1*upper2] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0030/
2015-07-17 14:33:00,039 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0030_01_000002 is : 143
2015-07-17 14:33:00,097 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0030_01_000003 is : 143
2015-07-17 14:33:00,372 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0030_01_000006 is : 143
2015-07-17 14:33:00,433 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0030_01_000005 is : 143
2015-07-17 14:33:00,506 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0030_01_000004 is : 143
2015-07-17 14:33:01,703 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin/_temporary
2015-07-17 14:33:01,763 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsamesourceintojoin
2015-07-17 14:33:01,796 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:33:01,797 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:33:01,822 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping] starting
2015-07-17 14:33:01,822 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs.txt"]
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs.txt"]
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup"]
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  parallel execution is enabled: true
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  starting jobs: 1
2015-07-17 14:33:01,823 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [cogrouping]  allocating threads: 1
2015-07-17 14:33:01,830 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] starting step: (1/1) ...platform/joinsintocogroup
2015-07-17 14:33:01,944 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] submitted hadoop job: job_1437168212887_0031
2015-07-17 14:33:01,944 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [cogrouping] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0031/
2015-07-17 14:33:21,128 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000007 is : 143
2015-07-17 14:33:21,196 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000002 is : 143
2015-07-17 14:33:21,263 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000004 is : 143
2015-07-17 14:33:21,278 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000003 is : 143
2015-07-17 14:33:21,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000006 is : 143
2015-07-17 14:33:21,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000005 is : 143
2015-07-17 14:33:27,291 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0031_01_000008 is : 143
2015-07-17 14:33:28,464 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup/_temporary
2015-07-17 14:33:28,494 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joinsintocogroup
2015-07-17 14:33:28,544 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:33:28,544 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:33:28,559 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:33:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-17 14:33:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-17 14:33:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner"]
2015-07-17 14:33:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:33:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:33:28,560 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:33:28,561 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...edpipesplatform/joininner
2015-07-17 14:33:28,678 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0032
2015-07-17 14:33:28,678 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0032/
2015-07-17 14:33:45,363 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0032_01_000002 is : 143
2015-07-17 14:33:45,388 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0032_01_000006 is : 143
2015-07-17 14:33:45,448 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0032_01_000005 is : 143
2015-07-17 14:33:45,513 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0032_01_000004 is : 143
2015-07-17 14:33:45,655 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0032_01_000003 is : 143
2015-07-17 14:33:46,836 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininner/_temporary
2015-07-17 14:33:46,877 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininner
2015-07-17 14:33:46,908 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:33:46,908 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:33:46,930 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-07-17 14:33:46,930 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:33:46,930 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby"]
2015-07-17 14:33:46,930 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  parallel execution is enabled: true
2015-07-17 14:33:46,930 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  starting jobs: 2
2015-07-17 14:33:46,931 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs]  allocating threads: 2
2015-07-17 14:33:46,932 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (2/2)
2015-07-17 14:33:47,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1437168212887_0033
2015-07-17 14:33:47,048 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0033/
2015-07-17 14:33:47,906 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-07-17 14:33:47,907 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-07-17 14:33:47,907 WARN  protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK, ARCHIVE], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-07-17 14:33:47,907 WARN  blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=false) All required storage types are unavailable:  unavailableStorages=[DISK, ARCHIVE], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-07-17 14:34:02,572 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0033_01_000004 is : 143
2015-07-17 14:34:02,619 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0033_01_000002 is : 143
2015-07-17 14:34:02,658 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0033_01_000006 is : 143
2015-07-17 14:34:02,735 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0033_01_000003 is : 143
2015-07-17 14:34:02,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0033_01_000005 is : 143
2015-07-17 14:34:08,472 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0033_01_000007 is : 143
2015-07-17 14:34:09,646 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/2) ...orm/samepipearoundgroupby
2015-07-17 14:34:09,759 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1437168212887_0034
2015-07-17 14:34:09,759 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0034/
2015-07-17 14:34:25,750 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0034_01_000002 is : 143
2015-07-17 14:34:25,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0034_01_000006 is : 143
2015-07-17 14:34:26,184 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0034_01_000003 is : 143
2015-07-17 14:34:26,244 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0034_01_000004 is : 143
2015-07-17 14:34:26,293 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0034_01_000005 is : 143
2015-07-17 14:34:27,481 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby/_temporary
2015-07-17 14:34:27,529 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipearoundgroupby
2015-07-17 14:34:27,585 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:34:27,586 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:34:27,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-07-17 14:34:27,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextLine[['id2']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.20.txt"]
2015-07-17 14:34:27,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  source: Hfs["TextLine[['id']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/nums.10.txt"]
2015-07-17 14:34:27,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  sink: Hfs["TextDelimited[['id2', 'count']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin"]
2015-07-17 14:34:27,608 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  parallel execution is enabled: true
2015-07-17 14:34:27,609 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  starting jobs: 2
2015-07-17 14:34:27,609 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - []  allocating threads: 2
2015-07-17 14:34:27,611 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2)
2015-07-17 14:34:27,725 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1437168212887_0035
2015-07-17 14:34:27,726 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0035/
2015-07-17 14:34:41,766 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0035_01_000002 is : 143
2015-07-17 14:34:41,948 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0035_01_000003 is : 143
2015-07-17 14:34:42,104 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0035_01_000005 is : 143
2015-07-17 14:34:42,245 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0035_01_000004 is : 143
2015-07-17 14:34:43,431 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...JoinMergeGroupBy/hashjoin
2015-07-17 14:34:43,549 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1437168212887_0036
2015-07-17 14:34:43,549 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0036/
2015-07-17 14:37:19,051 WARN  util.JvmPauseMonitor (JvmPauseMonitor.java:run(189)) - Detected pause in JVM or host machine (eg GC): pause of approximately 137724ms
GC pool 'PS Scavenge' had collection(s): count=1 time=15ms
2015-07-17 14:37:19,059 WARN  util.JvmPauseMonitor (JvmPauseMonitor.java:run(189)) - Detected pause in JVM or host machine (eg GC): pause of approximately 137723ms
GC pool 'PS Scavenge' had collection(s): count=1 time=15ms
2015-07-17 14:37:19,059 WARN  util.JvmPauseMonitor (JvmPauseMonitor.java:run(189)) - Detected pause in JVM or host machine (eg GC): pause of approximately 137723ms
GC pool 'PS Scavenge' had collection(s): count=1 time=15ms
2015-07-17 14:37:19,277 WARN  util.JvmPauseMonitor (JvmPauseMonitor.java:run(189)) - Detected pause in JVM or host machine (eg GC): pause of approximately 137721ms
No GCs detected
2015-07-17 14:37:19,309 WARN  util.JvmPauseMonitor (JvmPauseMonitor.java:run(189)) - Detected pause in JVM or host machine (eg GC): pause of approximately 137720ms
No GCs detected
2015-07-17 14:37:21,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000003 is : 143
2015-07-17 14:37:21,216 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000007 is : 143
2015-07-17 14:37:22,608 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000006 is : 143
2015-07-17 14:37:22,631 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000008 is : 143
2015-07-17 14:37:22,683 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000005 is : 143
2015-07-17 14:37:22,741 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000004 is : 143
2015-07-17 14:37:22,750 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000002 is : 143
2015-07-17 14:37:27,817 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0036_01_000009 is : 143
2015-07-17 14:37:29,016 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin/_temporary
2015-07-17 14:37:29,055 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/testJoinMergeGroupBy/hashjoin
2015-07-17 14:37:29,083 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:37:29,084 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:37:29,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-07-17 14:37:29,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:37:29,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2"]
2015-07-17 14:37:29,096 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-07-17 14:37:29,097 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-07-17 14:37:29,097 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-07-17 14:37:29,098 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...edpipesplatform/samepipe2
2015-07-17 14:37:29,220 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1437168212887_0037
2015-07-17 14:37:29,220 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0037/
2015-07-17 14:37:44,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0037_01_000002 is : 143
2015-07-17 14:37:45,023 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0037_01_000003 is : 143
2015-07-17 14:37:45,266 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0037_01_000004 is : 143
2015-07-17 14:37:45,344 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0037_01_000006 is : 143
2015-07-17 14:37:45,396 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0037_01_000005 is : 143
2015-07-17 14:37:46,677 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe2/_temporary
2015-07-17 14:37:46,732 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe2
2015-07-17 14:37:46,782 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:37:46,783 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:37:46,794 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs] starting
2015-07-17 14:37:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:37:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3"]
2015-07-17 14:37:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  parallel execution is enabled: true
2015-07-17 14:37:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  starting jobs: 1
2015-07-17 14:37:46,795 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs]  allocating threads: 1
2015-07-17 14:37:46,796 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] starting step: (1/1) ...edpipesplatform/samepipe3
2015-07-17 14:37:46,940 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] submitted hadoop job: job_1437168212887_0038
2015-07-17 14:37:46,940 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0038/
2015-07-17 14:38:02,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0038_01_000003 is : 143
2015-07-17 14:38:02,838 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0038_01_000002 is : 143
2015-07-17 14:38:02,944 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0038_01_000006 is : 143
2015-07-17 14:38:03,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0038_01_000005 is : 143
2015-07-17 14:38:03,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0038_01_000004 is : 143
2015-07-17 14:38:04,420 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe3/_temporary
2015-07-17 14:38:04,461 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe3
2015-07-17 14:38:04,505 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:38:04,505 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:38:04,515 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:38:04,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:38:04,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:38:04,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby"]
2015-07-17 14:38:04,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:38:04,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:38:04,516 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:38:04,517 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...pipesplatform/joingroupby
2015-07-17 14:38:04,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0039
2015-07-17 14:38:04,641 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0039/
2015-07-17 14:38:20,333 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0039_01_000002 is : 143
2015-07-17 14:38:20,504 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0039_01_000003 is : 143
2015-07-17 14:38:20,566 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0039_01_000005 is : 143
2015-07-17 14:38:20,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0039_01_000006 is : 143
2015-07-17 14:38:20,726 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0039_01_000004 is : 143
2015-07-17 14:38:28,319 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0039_01_000007 is : 143
2015-07-17 14:38:29,498 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joingroupby/_temporary
2015-07-17 14:38:29,533 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joingroupby
2015-07-17 14:38:29,558 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:38:29,558 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:38:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower] starting
2015-07-17 14:38:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:38:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe"]
2015-07-17 14:38:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  parallel execution is enabled: true
2015-07-17 14:38:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  starting jobs: 1
2015-07-17 14:38:29,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower]  allocating threads: 1
2015-07-17 14:38:29,568 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] starting step: (1/1) ...dedpipesplatform/samepipe
2015-07-17 14:38:29,677 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] submitted hadoop job: job_1437168212887_0040
2015-07-17 14:38:29,677 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0040/
2015-07-17 14:38:46,818 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0040_01_000003 is : 143
2015-07-17 14:38:46,855 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0040_01_000004 is : 143
2015-07-17 14:38:46,935 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0040_01_000005 is : 143
2015-07-17 14:38:47,014 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0040_01_000006 is : 143
2015-07-17 14:38:47,090 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0040_01_000002 is : 143
2015-07-17 14:38:48,277 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/samepipe/_temporary
2015-07-17 14:38:48,317 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/samepipe
2015-07-17 14:38:48,350 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:38:48,350 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:38:48,363 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:38:48,363 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/rhs-sparse.txt"]
2015-07-17 14:38:48,363 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lhs-sparse.txt"]
2015-07-17 14:38:48,363 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter"]
2015-07-17 14:38:48,364 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:38:48,364 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:38:48,364 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:38:48,369 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...esplatform/joininnerouter
2015-07-17 14:38:48,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0041
2015-07-17 14:38:48,490 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0041/
2015-07-17 14:39:04,568 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0041_01_000003 is : 143
2015-07-17 14:39:04,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0041_01_000002 is : 143
2015-07-17 14:39:05,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0041_01_000005 is : 143
2015-07-17 14:39:05,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0041_01_000004 is : 143
2015-07-17 14:39:06,480 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/joininnerouter/_temporary
2015-07-17 14:39:06,522 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/joininnerouter
2015-07-17 14:39:06,553 INFO  util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:39:06,554 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:39:06,565 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper] starting
2015-07-17 14:39:06,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:39:06,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:39:06,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields"]
2015-07-17 14:39:06,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  parallel execution is enabled: true
2015-07-17 14:39:06,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  starting jobs: 1
2015-07-17 14:39:06,566 INFO  flow.Flow (BaseFlow.java:logInfo(1370)) - [lower*upper]  allocating threads: 1
2015-07-17 14:39:06,567 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] starting step: (1/1) ...dpipesplatform/difffields
2015-07-17 14:39:06,687 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] submitted hadoop job: job_1437168212887_0042
2015-07-17 14:39:06,687 INFO  flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lower*upper] tracking url: http://Marks-MacBook.local:59870/proxy/application_1437168212887_0042/
2015-07-17 14:39:23,028 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0042_01_000006 is : 143
2015-07-17 14:39:23,415 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0042_01_000005 is : 143
2015-07-17 14:39:23,531 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0042_01_000002 is : 143
2015-07-17 14:39:23,585 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0042_01_000003 is : 143
2015-07-17 14:39:23,746 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437168212887_0042_01_000004 is : 143
2015-07-17 14:39:24,937 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/joinfieldedpipesplatform/difffields/_temporary
2015-07-17 14:39:24,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/joinfieldedpipesplatform/difffields

Standard error

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