Class cascading.CoGroupFieldedPipesPlatformTest

all > cascading > CoGroupFieldedPipesPlatformTest
31

tests
0

failures
0

ignored
54m26.34s

duration
100%

successful

Tests

Test Duration Result
testCoGroup 1m8.19s passed
testCoGroupAfterEvery 2m17.79s passed
testCoGroupAfterEveryNoDeclared 2m16.79s passed
testCoGroupAroundCoGroup 2m9.25s passed
testCoGroupAroundCoGroupWith 2m2.83s passed
testCoGroupAroundCoGroupWithout 2m4.78s passed
testCoGroupDiffFields 1m4.61s passed
testCoGroupDiffFieldsSameFile 1m6.56s passed
testCoGroupFilteredBranch 2m10.80s passed
testCoGroupGroupBy 2m4.95s passed
testCoGroupInner 2m45.79s passed
testCoGroupInnerNull 2m5.84s passed
testCoGroupInnerOuter 2m6.91s passed
testCoGroupInnerOuterNull 2m14.34s passed
testCoGroupInnerSingleField 1m4.88s passed
testCoGroupMixed 1m14.80s passed
testCoGroupOuter 2m7.17s passed
testCoGroupOuterInner 2m7.32s passed
testCoGroupOuterInnerNull 2m5.99s passed
testCoGroupOuterNull 2m22.48s passed
testCoGroupSamePipe 1m4.65s passed
testCoGroupSamePipe2 1m2.17s passed
testCoGroupSamePipe3 1m2.88s passed
testCoGroupSamePipeName 1m7.24s passed
testCoGroupSelf 1m3.54s passed
testCoGroupWithUnknowns 1m7.60s passed
testCross 1m4.64s passed
testJoinNone 1m5.04s passed
testMultiJoin 3m25.84s passed
testMultiJoinWithSplits 2m8.68s passed
testSplitCoGroupSelf 1m32.00s passed

Standard output

2015-09-24 10:12:11,517 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 10:12:11,554 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.CoGroupFieldedPipesPlatformTest, with platform: hadoop2-mr1
2015-09-24 10:12:11,577 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 10:12:23,800 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-09-24 10:12:24,620 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 10:12:32,708 WARN  fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 10:12:33,085 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-09-24 10:12:33,361 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-09-24 10:12:33,610 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-09-24 10:12:33,906 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-09-24 10:12:51,085 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-09-24 10:12:51,238 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:12:51,240 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:12:51,289 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: 780EBD7EBF4D4B52B16DC805E211380A
2015-09-24 10:12:51,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.090
2015-09-24 10:12:51,414 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:12:51,416 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:12:51,573 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 10:12:51,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:12:51,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:12:51,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:12:51,575 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner"]
2015-09-24 10:12:51,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:12:51,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:12:51,576 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:12:51,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...CoGroupInner/cogroupinner
2015-09-24 10:12:52,659 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0001
2015-09-24 10:12:52,659 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0001/
2015-09-24 10:13:14,573 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0001_01_000007
2015-09-24 10:13:35,943 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0001_01_000006 is : 143
2015-09-24 10:13:36,070 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0001_01_000003 is : 143
2015-09-24 10:13:36,147 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0001_01_000005 is : 143
2015-09-24 10:13:36,211 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0001_01_000004 is : 143
2015-09-24 10:13:36,315 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0001_01_000002 is : 143
2015-09-24 10:13:54,481 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0001_01_000008 is : 143
2015-09-24 10:13:55,801 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner/_temporary
2015-09-24 10:13:55,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:04.221
2015-09-24 10:13:55,891 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:13:55,892 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:13:55,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.061
2015-09-24 10:13:55,962 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:13:55,963 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:13:55,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:13:55,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:13:55,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:13:55,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup"]
2015-09-24 10:13:55,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:13:55,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:13:55,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:13:55,994 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) .../cogroupinner-resultgroup
2015-09-24 10:13:56,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0002
2015-09-24 10:13:56,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0002/
2015-09-24 10:14:17,407 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0002_01_000007
2015-09-24 10:14:37,973 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0002_01_000003 is : 143
2015-09-24 10:14:38,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0002_01_000002 is : 143
2015-09-24 10:14:38,245 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0002_01_000005 is : 143
2015-09-24 10:14:38,307 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0002_01_000004 is : 143
2015-09-24 10:14:38,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0002_01_000006 is : 143
2015-09-24 10:14:56,016 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0002_01_000008 is : 143
2015-09-24 10:14:57,263 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup/_temporary
2015-09-24 10:14:57,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:01.269
2015-09-24 10:14:57,332 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner
2015-09-24 10:14:57,350 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInner/cogroupinner-resultgroup
2015-09-24 10:14:57,456 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:14:57,456 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:14:57,549 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.086
2015-09-24 10:14:57,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:14:57,554 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:14:57,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] starting
2015-09-24 10:14:57,590 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:14:57,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:14:57,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-09-24 10:14:57,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  sink: Hfs["TextDelimited[[0:5]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed"]
2015-09-24 10:14:57,591 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  parallel execution of steps is enabled: true
2015-09-24 10:14:57,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  executing total steps: 1
2015-09-24 10:14:57,592 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  allocating management threads: 1
2015-09-24 10:14:57,593 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] starting step: (1/1) ...CoGroupMixed/cogroupmixed
2015-09-24 10:14:57,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] submitted hadoop job: job_1443103965561_0003
2015-09-24 10:14:57,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower] tracking url: http://localhost:49576/proxy/application_1443103965561_0003/
2015-09-24 10:15:19,430 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0003_01_000012
2015-09-24 10:15:19,430 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0003_01_000013
2015-09-24 10:15:20,344 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0003_01_000014
2015-09-24 10:15:51,254 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000011 is : 143
2015-09-24 10:15:51,468 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000004 is : 143
2015-09-24 10:15:51,549 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000005 is : 143
2015-09-24 10:15:51,590 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000003 is : 143
2015-09-24 10:15:51,672 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000008 is : 143
2015-09-24 10:15:51,727 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000009 is : 143
2015-09-24 10:15:51,911 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000007 is : 143
2015-09-24 10:15:51,953 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000002 is : 143
2015-09-24 10:15:52,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000006 is : 143
2015-09-24 10:16:10,847 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0003_01_000015 is : 143
2015-09-24 10:16:12,105 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed/_temporary
2015-09-24 10:16:12,107 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [loweroffset*upper*lower]  completed in: 01:14.512
2015-09-24 10:16:12,154 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupMixed/cogroupmixed
2015-09-24 10:16:12,221 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:16:12,222 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:16:12,286 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-09-24 10:16:12,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:16:12,289 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:16:12,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:16:12,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:16:12,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:16:12,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter"]
2015-09-24 10:16:12,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:16:12,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:16:12,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:16:12,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...CoGroupOuter/cogroupouter
2015-09-24 10:16:12,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0004
2015-09-24 10:16:12,506 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0004/
2015-09-24 10:16:34,894 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0004_01_000008
2015-09-24 10:16:57,155 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0004_01_000004 is : 143
2015-09-24 10:16:57,221 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0004_01_000003 is : 143
2015-09-24 10:16:57,280 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0004_01_000002 is : 143
2015-09-24 10:16:57,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0004_01_000005 is : 143
2015-09-24 10:16:57,481 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0004_01_000006 is : 143
2015-09-24 10:17:15,552 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0004_01_000009 is : 143
2015-09-24 10:17:16,803 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter/_temporary
2015-09-24 10:17:16,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:04.487
2015-09-24 10:17:16,872 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:17:16,873 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:17:16,912 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-09-24 10:17:16,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:17:16,915 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:17:16,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:17:16,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:17:16,940 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:17:16,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup"]
2015-09-24 10:17:16,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:17:16,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:17:16,941 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:17:16,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) .../cogroupouter-resultgroup
2015-09-24 10:17:17,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0005
2015-09-24 10:17:17,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0005/
2015-09-24 10:17:38,458 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0005_01_000008
2015-09-24 10:17:59,436 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0005_01_000003 is : 143
2015-09-24 10:17:59,500 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0005_01_000005 is : 143
2015-09-24 10:17:59,551 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0005_01_000004 is : 143
2015-09-24 10:17:59,644 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0005_01_000006 is : 143
2015-09-24 10:17:59,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0005_01_000002 is : 143
2015-09-24 10:18:18,040 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0005_01_000009 is : 143
2015-09-24 10:18:19,276 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup/_temporary
2015-09-24 10:18:19,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:02.333
2015-09-24 10:18:19,325 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter-resultgroup
2015-09-24 10:18:19,333 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuter/cogroupouter
2015-09-24 10:18:19,413 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:18:19,414 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:18:19,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.078
2015-09-24 10:18:19,501 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 10:18:19,502 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:18:19,543 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting
2015-09-24 10:18:19,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  source: Hfs["TextDelimited[['num']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/nums.10.txt"]
2015-09-24 10:18:19,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  source: Hfs["TextDelimited[['num']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/nums.10.txt"]
2015-09-24 10:18:19,544 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  source: Hfs["TextDelimited[['num']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/nums.20.txt"]
2015-09-24 10:18:19,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2"]
2015-09-24 10:18:19,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  parallel execution of steps is enabled: true
2015-09-24 10:18:19,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  executing total steps: 2
2015-09-24 10:18:19,545 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  allocating management threads: 2
2015-09-24 10:18:19,547 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (1/2)
2015-09-24 10:18:19,755 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1443103965561_0006
2015-09-24 10:18:19,755 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://localhost:49576/proxy/application_1443103965561_0006/
2015-09-24 10:18:41,087 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0006_01_000008
2015-09-24 10:19:01,712 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0006_01_000004 is : 143
2015-09-24 10:19:01,950 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0006_01_000006 is : 143
2015-09-24 10:19:01,988 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0006_01_000002 is : 143
2015-09-24 10:19:02,106 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0006_01_000005 is : 143
2015-09-24 10:19:02,173 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0006_01_000003 is : 143
2015-09-24 10:19:19,261 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0006_01_000009 is : 143
2015-09-24 10:19:20,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (2/2) ...pWith/cogroupacogroupopt2
2015-09-24 10:19:20,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1443103965561_0007
2015-09-24 10:19:20,646 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://localhost:49576/proxy/application_1443103965561_0007/
2015-09-24 10:19:42,207 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0007_01_000008
2015-09-24 10:20:02,786 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0007_01_000002 is : 143
2015-09-24 10:20:02,863 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0007_01_000006 is : 143
2015-09-24 10:20:02,865 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0007_01_000005 is : 143
2015-09-24 10:20:02,956 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0007_01_000003 is : 143
2015-09-24 10:20:03,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0007_01_000004 is : 143
2015-09-24 10:20:20,896 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0007_01_000009 is : 143
2015-09-24 10:20:22,123 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2/_temporary
2015-09-24 10:20:22,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  completed in: 02:02.574
2015-09-24 10:20:22,163 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWith/cogroupacogroupopt2
2015-09-24 10:20:22,195 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:20:22,196 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:20:22,279 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.077
2015-09-24 10:20:22,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 10:20:22,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:20:22,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting
2015-09-24 10:20:22,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  source: Hfs["TextDelimited[['num']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/nums.10.txt"]
2015-09-24 10:20:22,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  source: Hfs["TextDelimited[['num']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/nums.10.txt"]
2015-09-24 10:20:22,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  source: Hfs["TextDelimited[['num']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/nums.20.txt"]
2015-09-24 10:20:22,315 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1"]
2015-09-24 10:20:22,315 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  parallel execution of steps is enabled: true
2015-09-24 10:20:22,315 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  executing total steps: 2
2015-09-24 10:20:22,315 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  allocating management threads: 2
2015-09-24 10:20:22,317 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (1/2)
2015-09-24 10:20:22,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1443103965561_0008
2015-09-24 10:20:22,491 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://localhost:49576/proxy/application_1443103965561_0008/
2015-09-24 10:20:44,962 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0008_01_000008
2015-09-24 10:21:05,962 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0008_01_000003 is : 143
2015-09-24 10:21:05,962 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0008_01_000002 is : 143
2015-09-24 10:21:06,164 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0008_01_000006 is : 143
2015-09-24 10:21:06,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0008_01_000004 is : 143
2015-09-24 10:21:06,255 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0008_01_000005 is : 143
2015-09-24 10:21:23,927 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0008_01_000009 is : 143
2015-09-24 10:21:25,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] starting step: (2/2) ...thout/cogroupacogroupopt1
2015-09-24 10:21:25,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] submitted hadoop job: job_1443103965561_0009
2015-09-24 10:21:25,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt] tracking url: http://localhost:49576/proxy/application_1443103965561_0009/
2015-09-24 10:21:47,250 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0009_01_000007
2015-09-24 10:22:07,500 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0009_01_000004 is : 143
2015-09-24 10:22:07,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0009_01_000003 is : 143
2015-09-24 10:22:07,773 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0009_01_000006 is : 143
2015-09-24 10:22:07,832 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0009_01_000005 is : 143
2015-09-24 10:22:07,969 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0009_01_000002 is : 143
2015-09-24 10:22:25,641 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0009_01_000008 is : 143
2015-09-24 10:22:26,896 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1/_temporary
2015-09-24 10:22:26,900 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [cogroupopt]  completed in: 02:04.576
2015-09-24 10:22:26,940 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroupWithout/cogroupacogroupopt1
2015-09-24 10:22:26,966 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:22:26,967 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:22:27,035 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.063
2015-09-24 10:22:27,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 10:22:27,038 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:22:27,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting
2015-09-24 10:22:27,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:22:27,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:22:27,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:22:27,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup"]
2015-09-24 10:22:27,069 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  parallel execution of steps is enabled: true
2015-09-24 10:22:27,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  executing total steps: 2
2015-09-24 10:22:27,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  allocating management threads: 2
2015-09-24 10:22:27,072 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (1/2)
2015-09-24 10:22:27,251 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1443103965561_0010
2015-09-24 10:22:27,251 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://localhost:49576/proxy/application_1443103965561_0010/
2015-09-24 10:22:48,755 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0010_01_000009
2015-09-24 10:22:48,946 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0010_01_000010
2015-09-24 10:23:11,962 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000007 is : 143
2015-09-24 10:23:12,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000005 is : 143
2015-09-24 10:23:12,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000002 is : 143
2015-09-24 10:23:12,139 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000003 is : 143
2015-09-24 10:23:12,236 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000004 is : 143
2015-09-24 10:23:12,446 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000006 is : 143
2015-09-24 10:23:29,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0010_01_000011 is : 143
2015-09-24 10:23:31,135 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] starting step: (2/2) ...ndCoGroup/cogroupacogroup
2015-09-24 10:23:31,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] submitted hadoop job: job_1443103965561_0011
2015-09-24 10:23:31,331 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2] tracking url: http://localhost:49576/proxy/application_1443103965561_0011/
2015-09-24 10:23:52,987 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0011_01_000008
2015-09-24 10:23:53,229 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0011_01_000009
2015-09-24 10:24:16,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000007 is : 143
2015-09-24 10:24:16,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000002 is : 143
2015-09-24 10:24:16,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000006 is : 143
2015-09-24 10:24:16,406 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000005 is : 143
2015-09-24 10:24:16,449 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000003 is : 143
2015-09-24 10:24:16,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000004 is : 143
2015-09-24 10:24:34,904 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0011_01_000010 is : 143
2015-09-24 10:24:36,153 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup/_temporary
2015-09-24 10:24:36,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper1*upper2]  completed in: 02:09.079
2015-09-24 10:24:36,192 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAroundCoGroup/cogroupacogroup
2015-09-24 10:24:36,222 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:24:36,222 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:24:36,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 10:24:36,259 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:24:36,260 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:24:36,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:24:36,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:24:36,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:24:36,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter"]
2015-09-24 10:24:36,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:24:36,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:24:36,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:24:36,278 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...erOuter/cogroupinnerouter
2015-09-24 10:24:36,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0012
2015-09-24 10:24:36,465 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0012/
2015-09-24 10:24:57,519 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0012_01_000007
2015-09-24 10:25:20,232 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0012_01_000004 is : 143
2015-09-24 10:25:20,391 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0012_01_000002 is : 143
2015-09-24 10:25:20,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0012_01_000003 is : 143
2015-09-24 10:25:20,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0012_01_000005 is : 143
2015-09-24 10:25:20,602 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0012_01_000006 is : 143
2015-09-24 10:25:38,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0012_01_000008 is : 143
2015-09-24 10:25:39,727 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter/_temporary
2015-09-24 10:25:39,730 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:03.449
2015-09-24 10:25:39,793 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:25:39,793 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:25:39,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.037
2015-09-24 10:25:39,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:25:39,837 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:25:39,855 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:25:39,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:25:39,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:25:39,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup"]
2015-09-24 10:25:39,856 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:25:39,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:25:39,857 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:25:39,858 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...oupinnerouter-resultgroup
2015-09-24 10:25:40,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0013
2015-09-24 10:25:40,045 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0013/
2015-09-24 10:26:03,848 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0013_01_000007
2015-09-24 10:26:23,105 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0013_01_000004 is : 143
2015-09-24 10:26:23,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0013_01_000005 is : 143
2015-09-24 10:26:23,301 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0013_01_000003 is : 143
2015-09-24 10:26:23,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0013_01_000002 is : 143
2015-09-24 10:26:23,495 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0013_01_000006 is : 143
2015-09-24 10:26:41,795 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0013_01_000008 is : 143
2015-09-24 10:26:43,036 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup/_temporary
2015-09-24 10:26:43,039 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:03.177
2015-09-24 10:26:43,085 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter
2015-09-24 10:26:43,100 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuter/cogroupinnerouter-resultgroup
2015-09-24 10:26:43,132 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:26:43,133 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:26:43,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 10:26:43,171 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:26:43,172 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:26:43,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:26:43,189 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:26:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:26:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields"]
2015-09-24 10:26:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:26:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:26:43,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:26:43,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupDiffFields/difffields
2015-09-24 10:26:43,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0014
2015-09-24 10:26:43,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0014/
2015-09-24 10:27:05,337 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0014_01_000009
2015-09-24 10:27:05,845 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0014_01_000008
2015-09-24 10:27:28,559 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000005 is : 143
2015-09-24 10:27:28,641 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000004 is : 143
2015-09-24 10:27:28,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000003 is : 143
2015-09-24 10:27:28,769 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000007 is : 143
2015-09-24 10:27:28,836 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000006 is : 143
2015-09-24 10:27:28,968 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000002 is : 143
2015-09-24 10:27:46,413 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0014_01_000010 is : 143
2015-09-24 10:27:47,667 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields/_temporary
2015-09-24 10:27:47,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:04.477
2015-09-24 10:27:47,710 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFields/difffields
2015-09-24 10:27:47,739 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:27:47,739 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:27:47,772 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-09-24 10:27:47,773 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:27:47,774 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:27:47,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-09-24 10:27:47,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:27:47,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2"]
2015-09-24 10:27:47,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2015-09-24 10:27:47,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2015-09-24 10:27:47,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2015-09-24 10:27:47,788 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...oGroupSamePipe2/samepipe2
2015-09-24 10:27:47,967 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1443103965561_0015
2015-09-24 10:27:47,967 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://localhost:49576/proxy/application_1443103965561_0015/
2015-09-24 10:28:09,472 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0015_01_000007
2015-09-24 10:28:30,609 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0015_01_000005 is : 143
2015-09-24 10:28:30,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0015_01_000003 is : 143
2015-09-24 10:28:30,711 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0015_01_000002 is : 143
2015-09-24 10:28:30,758 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0015_01_000006 is : 143
2015-09-24 10:28:30,825 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0015_01_000004 is : 143
2015-09-24 10:28:48,605 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0015_01_000008 is : 143
2015-09-24 10:28:49,838 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2/_temporary
2015-09-24 10:28:49,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 01:02.048
2015-09-24 10:28:49,882 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe2/samepipe2
2015-09-24 10:28:49,913 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:28:49,914 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:28:49,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.024
2015-09-24 10:28:49,945 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:28:49,946 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:28:49,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting
2015-09-24 10:28:49,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:28:49,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3"]
2015-09-24 10:28:49,957 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  parallel execution of steps is enabled: true
2015-09-24 10:28:49,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  executing total steps: 1
2015-09-24 10:28:49,958 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  allocating management threads: 1
2015-09-24 10:28:49,959 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] starting step: (1/1) ...oGroupSamePipe3/samepipe3
2015-09-24 10:28:50,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] submitted hadoop job: job_1443103965561_0016
2015-09-24 10:28:50,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs] tracking url: http://localhost:49576/proxy/application_1443103965561_0016/
2015-09-24 10:29:11,702 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0016_01_000007
2015-09-24 10:29:32,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0016_01_000004 is : 143
2015-09-24 10:29:33,016 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0016_01_000003 is : 143
2015-09-24 10:29:33,077 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0016_01_000005 is : 143
2015-09-24 10:29:33,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0016_01_000002 is : 143
2015-09-24 10:29:33,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0016_01_000006 is : 143
2015-09-24 10:29:51,477 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0016_01_000008 is : 143
2015-09-24 10:29:52,711 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3/_temporary
2015-09-24 10:29:52,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs]  completed in: 01:02.751
2015-09-24 10:29:52,763 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe3/samepipe3
2015-09-24 10:29:52,831 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:29:52,831 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:29:52,874 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-09-24 10:29:52,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:29:52,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:29:52,890 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting
2015-09-24 10:29:52,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs.txt"]
2015-09-24 10:29:52,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs.txt"]
2015-09-24 10:29:52,891 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross"]
2015-09-24 10:29:52,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  parallel execution of steps is enabled: true
2015-09-24 10:29:52,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  executing total steps: 1
2015-09-24 10:29:52,892 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  allocating management threads: 1
2015-09-24 10:29:52,893 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] starting step: (1/1) ...splatform/testCross/cross
2015-09-24 10:29:53,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] submitted hadoop job: job_1443103965561_0017
2015-09-24 10:29:53,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs] tracking url: http://localhost:49576/proxy/application_1443103965561_0017/
2015-09-24 10:30:14,533 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0017_01_000007
2015-09-24 10:30:36,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0017_01_000006 is : 143
2015-09-24 10:30:36,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0017_01_000002 is : 143
2015-09-24 10:30:36,639 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0017_01_000003 is : 143
2015-09-24 10:30:36,722 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0017_01_000005 is : 143
2015-09-24 10:30:36,788 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0017_01_000004 is : 143
2015-09-24 10:30:56,073 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0017_01_000008 is : 143
2015-09-24 10:30:57,355 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross/_temporary
2015-09-24 10:30:57,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs*rhs]  completed in: 01:04.460
2015-09-24 10:30:57,404 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCross/cross
2015-09-24 10:30:57,428 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:30:57,428 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:30:57,470 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-09-24 10:30:57,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:30:57,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:30:57,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting
2015-09-24 10:30:57,488 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:30:57,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe"]
2015-09-24 10:30:57,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  parallel execution of steps is enabled: true
2015-09-24 10:30:57,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  executing total steps: 1
2015-09-24 10:30:57,489 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  allocating management threads: 1
2015-09-24 10:30:57,490 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] starting step: (1/1) ...tCoGroupSamePipe/samepipe
2015-09-24 10:30:57,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] submitted hadoop job: job_1443103965561_0018
2015-09-24 10:30:57,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower] tracking url: http://localhost:49576/proxy/application_1443103965561_0018/
2015-09-24 10:31:19,883 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0018_01_000007
2015-09-24 10:31:42,786 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0018_01_000006 is : 143
2015-09-24 10:31:43,040 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0018_01_000003 is : 143
2015-09-24 10:31:43,097 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0018_01_000004 is : 143
2015-09-24 10:31:43,167 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0018_01_000002 is : 143
2015-09-24 10:31:43,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0018_01_000005 is : 143
2015-09-24 10:32:00,761 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0018_01_000008 is : 143
2015-09-24 10:32:02,015 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe/_temporary
2015-09-24 10:32:02,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower]  completed in: 01:04.523
2015-09-24 10:32:02,055 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipe/samepipe
2015-09-24 10:32:02,082 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:32:02,083 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:32:02,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-09-24 10:32:02,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:32:02,127 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:32:02,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:32:02,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:32:02,141 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:32:02,142 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone"]
2015-09-24 10:32:02,142 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:32:02,142 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:32:02,142 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:32:02,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...orm/testJoinNone/joinnone
2015-09-24 10:32:02,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0019
2015-09-24 10:32:02,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0019/
2015-09-24 10:32:24,215 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0019_01_000008
2015-09-24 10:32:24,260 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0019_01_000009
2015-09-24 10:32:47,698 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000006 is : 143
2015-09-24 10:32:47,903 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000002 is : 143
2015-09-24 10:32:47,917 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000003 is : 143
2015-09-24 10:32:47,982 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000005 is : 143
2015-09-24 10:32:48,107 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000007 is : 143
2015-09-24 10:32:48,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000004 is : 143
2015-09-24 10:33:05,785 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0019_01_000010 is : 143
2015-09-24 10:33:07,049 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone/_temporary
2015-09-24 10:33:07,053 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:04.905
2015-09-24 10:33:07,099 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testJoinNone/joinnone
2015-09-24 10:33:07,129 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:33:07,130 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:33:07,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.080
2015-09-24 10:33:07,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 10:33:07,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:33:07,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:33:07,256 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:33:07,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:33:07,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery"]
2015-09-24 10:33:07,257 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:33:07,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 10:33:07,258 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 10:33:07,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-09-24 10:33:07,262 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-09-24 10:33:07,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0020
2015-09-24 10:33:07,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0020/
2015-09-24 10:33:07,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0021
2015-09-24 10:33:07,548 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0021/
2015-09-24 10:33:33,194 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0020_01_000009
2015-09-24 10:33:33,240 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0021_01_000007
2015-09-24 10:34:09,296 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0020_01_000007 is : 143
2015-09-24 10:34:09,722 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0021_01_000006 is : 143
2015-09-24 10:34:09,908 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0020_01_000003 is : 143
2015-09-24 10:34:10,071 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0021_01_000004 is : 143
2015-09-24 10:34:10,217 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0021_01_000005 is : 143
2015-09-24 10:34:10,308 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0021_01_000003 is : 143
2015-09-24 10:34:10,436 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0020_01_000002 is : 143
2015-09-24 10:34:10,438 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0021_01_000002 is : 143
2015-09-24 10:34:10,526 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0020_01_000004 is : 143
2015-09-24 10:34:10,602 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0020_01_000005 is : 143
2015-09-24 10:34:29,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0020_01_000011 is : 143
2015-09-24 10:34:29,127 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0021_01_000008 is : 143
2015-09-24 10:34:30,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...roupAfterEvery/afterevery
2015-09-24 10:34:30,562 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0022
2015-09-24 10:34:30,562 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0022/
2015-09-24 10:35:05,949 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0022_01_000003 is : 143
2015-09-24 10:35:05,951 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0022_01_000002 is : 143
2015-09-24 10:35:23,618 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0022_01_000004 is : 143
2015-09-24 10:35:24,837 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery/_temporary
2015-09-24 10:35:24,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 02:17.576
2015-09-24 10:35:24,888 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEvery/afterevery
2015-09-24 10:35:24,946 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:35:24,947 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:35:25,076 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.125
2015-09-24 10:35:25,078 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 10
2015-09-24 10:35:25,079 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:35:25,184 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting
2015-09-24 10:35:25,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-09-24 10:35:25,185 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-09-24 10:35:25,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer"]
2015-09-24 10:35:25,186 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner"]
2015-09-24 10:35:25,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left"]
2015-09-24 10:35:25,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right"]
2015-09-24 10:35:25,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  parallel execution of steps is enabled: true
2015-09-24 10:35:25,187 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  executing total steps: 5
2015-09-24 10:35:25,188 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  allocating management threads: 5
2015-09-24 10:35:25,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (1/5)
2015-09-24 10:35:25,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0023
2015-09-24 10:35:25,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0023/
2015-09-24 10:36:05,905 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0023_01_000005 is : 143
2015-09-24 10:36:06,092 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0023_01_000004 is : 143
2015-09-24 10:36:06,171 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0023_01_000003 is : 143
2015-09-24 10:36:06,215 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0023_01_000002 is : 143
2015-09-24 10:36:24,339 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0023_01_000006 is : 143
2015-09-24 10:36:25,518 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (2/5) ...atform/testMultiJoin/left
2015-09-24 10:36:25,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (4/5) ...tform/testMultiJoin/inner
2015-09-24 10:36:25,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (5/5) ...tform/testMultiJoin/outer
2015-09-24 10:36:25,519 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (3/5) ...tform/testMultiJoin/right
2015-09-24 10:36:25,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0024
2015-09-24 10:36:25,781 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0024/
2015-09-24 10:36:25,921 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0026
2015-09-24 10:36:25,922 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0026/
2015-09-24 10:36:25,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0025
2015-09-24 10:36:25,956 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0025/
2015-09-24 10:36:25,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0027
2015-09-24 10:36:25,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0027/
2015-09-24 10:37:29,290 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0025_01_000002 is : 143
2015-09-24 10:37:29,413 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0026_01_000003 is : 143
2015-09-24 10:37:29,495 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0025_01_000003 is : 143
2015-09-24 10:37:29,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0024_01_000003 is : 143
2015-09-24 10:37:29,755 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0027_01_000003 is : 143
2015-09-24 10:37:29,808 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0026_01_000002 is : 143
2015-09-24 10:37:29,994 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0027_01_000002 is : 143
2015-09-24 10:37:30,184 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0024_01_000002 is : 143
2015-09-24 10:38:10,678 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0024_01_000007 is : 143
2015-09-24 10:38:10,996 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0027_01_000004 is : 143
2015-09-24 10:38:11,060 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0024_01_000005 is : 143
2015-09-24 10:38:11,149 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0024_01_000006 is : 143
2015-09-24 10:38:11,264 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0026_01_000004 is : 143
2015-09-24 10:38:11,462 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0025_01_000004 is : 143
2015-09-24 10:38:11,628 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0025_01_000005 is : 143
2015-09-24 10:38:11,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0026_01_000005 is : 143
2015-09-24 10:38:46,483 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0025_01_000006 is : 143
2015-09-24 10:38:46,698 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0027_01_000005 is : 143
2015-09-24 10:38:46,783 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0026_01_000006 is : 143
2015-09-24 10:38:46,896 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0024_01_000008 is : 143
2015-09-24 10:38:47,174 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0027_01_000007 is : 143
2015-09-24 10:38:48,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0026_01_000007 is : 143
2015-09-24 10:38:48,790 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0025_01_000007 is : 143
2015-09-24 10:38:49,417 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0027_01_000009 is : 143
2015-09-24 10:38:50,617 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left/_temporary
2015-09-24 10:38:50,619 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right/_temporary
2015-09-24 10:38:50,620 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner/_temporary
2015-09-24 10:38:50,621 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer/_temporary
2015-09-24 10:38:50,628 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  completed in: 03:25.428
2015-09-24 10:38:50,712 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/left
2015-09-24 10:38:50,718 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/inner
2015-09-24 10:38:50,723 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/right
2015-09-24 10:38:50,729 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoin/outer
2015-09-24 10:38:50,757 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:38:50,757 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:38:50,802 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-09-24 10:38:50,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:38:50,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:38:50,828 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] starting
2015-09-24 10:38:50,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:38:50,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:38:50,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields"]
2015-09-24 10:38:50,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  parallel execution of steps is enabled: true
2015-09-24 10:38:50,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  executing total steps: 1
2015-09-24 10:38:50,829 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  allocating management threads: 1
2015-09-24 10:38:50,831 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] starting step: (1/1) ...meFile/samefiledifffields
2015-09-24 10:38:50,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] submitted hadoop job: job_1443103965561_0028
2015-09-24 10:38:50,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower] tracking url: http://localhost:49576/proxy/application_1443103965561_0028/
2015-09-24 10:39:14,855 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0028_01_000008
2015-09-24 10:39:15,263 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0028_01_000009
2015-09-24 10:39:38,312 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000003 is : 143
2015-09-24 10:39:38,505 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000005 is : 143
2015-09-24 10:39:38,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000007 is : 143
2015-09-24 10:39:38,635 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000004 is : 143
2015-09-24 10:39:38,734 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000006 is : 143
2015-09-24 10:39:38,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000002 is : 143
2015-09-24 10:39:56,010 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0028_01_000010 is : 143
2015-09-24 10:39:57,249 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields/_temporary
2015-09-24 10:39:57,252 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [offsetLower*lower]  completed in: 01:06.418
2015-09-24 10:39:57,292 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupDiffFieldsSameFile/samefiledifffields
2015-09-24 10:39:57,321 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:39:57,321 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:39:57,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 10:39:57,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:39:57,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:39:57,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:39:57,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:39:57,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:39:57,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner"]
2015-09-24 10:39:57,378 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:39:57,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:39:57,379 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:39:57,380 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...erInner/cogroupouterinner
2015-09-24 10:39:57,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0029
2015-09-24 10:39:57,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0029/
2015-09-24 10:40:19,755 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0029_01_000007
2015-09-24 10:40:39,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0029_01_000002 is : 143
2015-09-24 10:40:39,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0029_01_000003 is : 143
2015-09-24 10:40:39,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0029_01_000005 is : 143
2015-09-24 10:40:40,048 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0029_01_000006 is : 143
2015-09-24 10:40:40,199 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0029_01_000004 is : 143
2015-09-24 10:40:57,388 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0029_01_000008 is : 143
2015-09-24 10:40:58,603 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner/_temporary
2015-09-24 10:40:58,606 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:01.223
2015-09-24 10:40:58,669 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:40:58,669 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:40:58,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-09-24 10:40:58,705 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:40:58,705 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:40:58,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:40:58,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:40:58,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:40:58,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup"]
2015-09-24 10:40:58,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:40:58,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:40:58,721 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:40:58,723 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...oupouterinner-resultgroup
2015-09-24 10:40:58,872 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0030
2015-09-24 10:40:58,872 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0030/
2015-09-24 10:41:20,151 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0030_01_000008
2015-09-24 10:41:41,502 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0030_01_000005 is : 143
2015-09-24 10:41:41,606 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0030_01_000004 is : 143
2015-09-24 10:41:41,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0030_01_000002 is : 143
2015-09-24 10:41:41,717 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0030_01_000003 is : 143
2015-09-24 10:41:41,799 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0030_01_000006 is : 143
2015-09-24 10:42:03,338 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0030_01_000009 is : 143
2015-09-24 10:42:04,560 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup/_temporary
2015-09-24 10:42:04,563 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:05.838
2015-09-24 10:42:04,607 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner
2015-09-24 10:42:04,614 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInner/cogroupouterinner-resultgroup
2015-09-24 10:42:04,652 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:42:04,653 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:42:04,771 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.114
2015-09-24 10:42:04,774 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 4, nodes: 8
2015-09-24 10:42:04,774 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:42:04,834 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting
2015-09-24 10:42:04,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs+rhs-cross-x2.txt"]
2015-09-24 10:42:04,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs"]
2015-09-24 10:42:04,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs"]
2015-09-24 10:42:04,835 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs"]
2015-09-24 10:42:04,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs"]
2015-09-24 10:42:04,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  parallel execution of steps is enabled: true
2015-09-24 10:42:04,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  executing total steps: 4
2015-09-24 10:42:04,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  allocating management threads: 4
2015-09-24 10:42:04,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (1/4) ...JoinWithSplits/uniquesRhs
2015-09-24 10:42:04,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (2/4) ...tiJoinWithSplits/innerLhs
2015-09-24 10:42:04,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (3/4) ...tiJoinWithSplits/innerRhs
2015-09-24 10:42:04,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] starting step: (4/4) ...JoinWithSplits/uniquesLhs
2015-09-24 10:42:05,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0031
2015-09-24 10:42:05,140 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0031/
2015-09-24 10:42:05,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0033
2015-09-24 10:42:05,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0033/
2015-09-24 10:42:05,249 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0034
2015-09-24 10:42:05,249 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0034/
2015-09-24 10:42:05,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] submitted hadoop job: job_1443103965561_0032
2015-09-24 10:42:05,253 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins] tracking url: http://localhost:49576/proxy/application_1443103965561_0032/
2015-09-24 10:43:07,730 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0033_01_000003 is : 143
2015-09-24 10:43:07,863 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0032_01_000003 is : 143
2015-09-24 10:43:08,027 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0031_01_000003 is : 143
2015-09-24 10:43:08,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0032_01_000002 is : 143
2015-09-24 10:43:08,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0034_01_000002 is : 143
2015-09-24 10:43:08,517 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0033_01_000002 is : 143
2015-09-24 10:43:08,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0034_01_000003 is : 143
2015-09-24 10:43:08,749 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0031_01_000002 is : 143
2015-09-24 10:43:44,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0032_01_000004 is : 143
2015-09-24 10:43:44,680 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0031_01_000006 is : 143
2015-09-24 10:43:44,751 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0032_01_000005 is : 143
2015-09-24 10:43:44,868 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0034_01_000004 is : 143
2015-09-24 10:43:45,183 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0034_01_000005 is : 143
2015-09-24 10:43:45,224 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0033_01_000004 is : 143
2015-09-24 10:43:45,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0033_01_000005 is : 143
2015-09-24 10:43:45,270 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0031_01_000004 is : 143
2015-09-24 10:44:11,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0033_01_000006 is : 143
2015-09-24 10:44:11,062 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0032_01_000008 is : 143
2015-09-24 10:44:11,830 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0034_01_000006 is : 143
2015-09-24 10:44:11,899 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0031_01_000011 is : 143
2015-09-24 10:44:13,113 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs/_temporary
2015-09-24 10:44:13,116 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs/_temporary
2015-09-24 10:44:13,117 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs/_temporary
2015-09-24 10:44:13,119 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs/_temporary
2015-09-24 10:44:13,125 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [multi-joins]  completed in: 02:08.278
2015-09-24 10:44:13,272 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerLhs
2015-09-24 10:44:13,278 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesRhs
2015-09-24 10:44:13,284 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/uniquesLhs
2015-09-24 10:44:13,290 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testMultiJoinWithSplits/innerRhs
2015-09-24 10:44:13,313 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:44:13,314 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:44:13,346 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-09-24 10:44:13,348 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:44:13,349 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:44:13,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:44:13,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:44:13,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:44:13,366 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull"]
2015-09-24 10:44:13,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:44:13,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:44:13,367 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:44:13,369 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ull/cogroupinnerouternull
2015-09-24 10:44:13,520 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0035
2015-09-24 10:44:13,521 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0035/
2015-09-24 10:44:39,134 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0035_01_000007
2015-09-24 10:45:00,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0035_01_000005 is : 143
2015-09-24 10:45:00,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0035_01_000003 is : 143
2015-09-24 10:45:00,413 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0035_01_000004 is : 143
2015-09-24 10:45:00,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0035_01_000002 is : 143
2015-09-24 10:45:00,535 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0035_01_000006 is : 143
2015-09-24 10:45:18,017 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0035_01_000008 is : 143
2015-09-24 10:45:19,284 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull/_temporary
2015-09-24 10:45:19,287 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:05.915
2015-09-24 10:45:19,348 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:45:19,348 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:45:19,381 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.029
2015-09-24 10:45:19,381 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:45:19,383 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:45:19,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:45:19,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:45:19,397 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:45:19,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup"]
2015-09-24 10:45:19,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:45:19,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:45:19,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:45:19,400 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nnerouternull-resultgroup
2015-09-24 10:45:19,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0036
2015-09-24 10:45:19,574 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0036/
2015-09-24 10:45:41,051 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0036_01_000008
2015-09-24 10:46:05,046 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0036_01_000005 is : 143
2015-09-24 10:46:05,156 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0036_01_000006 is : 143
2015-09-24 10:46:05,309 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0036_01_000002 is : 143
2015-09-24 10:46:05,386 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0036_01_000004 is : 143
2015-09-24 10:46:05,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0036_01_000003 is : 143
2015-09-24 10:46:26,247 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0036_01_000009 is : 143
2015-09-24 10:46:27,530 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup/_temporary
2015-09-24 10:46:27,533 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:08.129
2015-09-24 10:46:27,617 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull
2015-09-24 10:46:27,629 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerOuterNull/cogroupinnerouternull-resultgroup
2015-09-24 10:46:27,671 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:46:27,676 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:46:27,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.081
2015-09-24 10:46:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:46:27,766 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:46:27,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:46:27,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:46:27,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:46:27,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull"]
2015-09-24 10:46:27,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:46:27,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:46:27,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:46:27,796 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...uterNull/cogroupouternull
2015-09-24 10:46:28,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0037
2015-09-24 10:46:28,037 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0037/
2015-09-24 10:47:23,135 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0037_01_000004 is : 143
2015-09-24 10:47:23,142 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0037_01_000002 is : 143
2015-09-24 10:47:23,209 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0037_01_000003 is : 143
2015-09-24 10:47:23,381 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0037_01_000005 is : 143
2015-09-24 10:47:23,513 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0037_01_000006 is : 143
2015-09-24 10:47:42,030 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0037_01_000007 is : 143
2015-09-24 10:47:43,263 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull/_temporary
2015-09-24 10:47:43,266 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:15.468
2015-09-24 10:47:43,326 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:47:43,326 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:47:43,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.027
2015-09-24 10:47:43,359 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:47:43,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:47:43,373 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:47:43,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:47:43,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:47:43,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup"]
2015-09-24 10:47:43,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:47:43,374 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:47:43,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:47:43,376 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupouternull-resultgroup
2015-09-24 10:47:43,551 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0038
2015-09-24 10:47:43,552 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0038/
2015-09-24 10:48:29,512 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0038_01_000003 is : 143
2015-09-24 10:48:29,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0038_01_000006 is : 143
2015-09-24 10:48:29,670 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0038_01_000002 is : 143
2015-09-24 10:48:29,746 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0038_01_000005 is : 143
2015-09-24 10:48:29,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0038_01_000004 is : 143
2015-09-24 10:48:48,811 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0038_01_000007 is : 143
2015-09-24 10:48:50,057 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup/_temporary
2015-09-24 10:48:50,059 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:06.682
2015-09-24 10:48:50,100 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull
2015-09-24 10:48:50,107 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterNull/cogroupouternull-resultgroup
2015-09-24 10:48:50,134 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:48:50,135 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:48:50,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-09-24 10:48:50,181 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 10:48:50,183 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:48:50,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting
2015-09-24 10:48:50,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:48:50,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs"]
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs"]
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  parallel execution of steps is enabled: true
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  executing total steps: 2
2015-09-24 10:48:50,216 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  allocating management threads: 2
2015-09-24 10:48:50,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (1/2) ...Self/splitcogroupself/rhs
2015-09-24 10:48:50,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] starting step: (2/2) ...Self/splitcogroupself/lhs
2015-09-24 10:48:50,434 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1443103965561_0039
2015-09-24 10:48:50,435 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:49576/proxy/application_1443103965561_0039/
2015-09-24 10:48:50,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] submitted hadoop job: job_1443103965561_0040
2015-09-24 10:48:50,451 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs] tracking url: http://localhost:49576/proxy/application_1443103965561_0040/
2015-09-24 10:49:16,879 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0039_01_000008
2015-09-24 10:49:16,943 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0040_01_000008
2015-09-24 10:49:57,749 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0040_01_000002 is : 143
2015-09-24 10:49:58,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0040_01_000005 is : 143
2015-09-24 10:49:58,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0039_01_000005 is : 143
2015-09-24 10:49:58,418 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0039_01_000003 is : 143
2015-09-24 10:49:58,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0040_01_000004 is : 143
2015-09-24 10:49:58,542 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0039_01_000004 is : 143
2015-09-24 10:49:58,816 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0040_01_000007 is : 143
2015-09-24 10:49:58,868 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0039_01_000007 is : 143
2015-09-24 10:49:58,941 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0040_01_000003 is : 143
2015-09-24 10:49:59,032 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0039_01_000002 is : 143
2015-09-24 10:50:20,488 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0040_01_000009 is : 143
2015-09-24 10:50:20,832 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0039_01_000009 is : 143
2015-09-24 10:50:22,045 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs/_temporary
2015-09-24 10:50:22,047 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs/_temporary
2015-09-24 10:50:22,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lhs+rhs]  completed in: 01:31.828
2015-09-24 10:50:22,094 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/lhs
2015-09-24 10:50:22,102 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testSplitCoGroupSelf/splitcogroupself/rhs
2015-09-24 10:50:22,136 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:50:22,136 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:50:22,176 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-09-24 10:50:22,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:50:22,177 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:50:22,190 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting
2015-09-24 10:50:22,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:50:22,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:50:22,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes"]
2015-09-24 10:50:22,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  parallel execution of steps is enabled: true
2015-09-24 10:50:22,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  executing total steps: 1
2015-09-24 10:50:22,191 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  allocating management threads: 1
2015-09-24 10:50:22,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] starting step: (1/1) ...SamePipeName/renamedpipes
2015-09-24 10:50:22,352 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] submitted hadoop job: job_1443103965561_0041
2015-09-24 10:50:22,353 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail] tracking url: http://localhost:49576/proxy/application_1443103965561_0041/
2015-09-24 10:50:44,167 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0041_01_000008
2015-09-24 10:51:09,602 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000003 is : 143
2015-09-24 10:51:09,860 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000006 is : 143
2015-09-24 10:51:09,924 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000004 is : 143
2015-09-24 10:51:10,015 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000007 is : 143
2015-09-24 10:51:10,151 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000002 is : 143
2015-09-24 10:51:10,228 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000005 is : 143
2015-09-24 10:51:28,083 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0041_01_000009 is : 143
2015-09-24 10:51:29,297 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes/_temporary
2015-09-24 10:51:29,300 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [tail]  completed in: 01:07.104
2015-09-24 10:51:29,339 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSamePipeName/renamedpipes
2015-09-24 10:51:29,364 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:51:29,365 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:51:29,409 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-09-24 10:51:29,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 10:51:29,411 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:51:29,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:51:29,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:51:29,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:51:29,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch"]
2015-09-24 10:51:29,442 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:51:29,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 2
2015-09-24 10:51:29,443 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 2
2015-09-24 10:51:29,446 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 10:51:29,588 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0042
2015-09-24 10:51:29,588 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0042/
2015-09-24 10:51:52,148 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0042_01_000008
2015-09-24 10:52:14,421 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0042_01_000004 is : 143
2015-09-24 10:52:14,522 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0042_01_000003 is : 143
2015-09-24 10:52:14,583 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0042_01_000002 is : 143
2015-09-24 10:52:14,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0042_01_000006 is : 143
2015-09-24 10:52:14,680 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0042_01_000005 is : 143
2015-09-24 10:52:32,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0042_01_000009 is : 143
2015-09-24 10:52:33,629 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...nch/cogroupfilteredbranch
2015-09-24 10:52:33,816 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0043
2015-09-24 10:52:33,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0043/
2015-09-24 10:52:56,628 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0043_01_000009
2015-09-24 10:52:56,761 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0043_01_000010
2015-09-24 10:53:21,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000007 is : 143
2015-09-24 10:53:21,140 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000006 is : 143
2015-09-24 10:53:21,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000002 is : 143
2015-09-24 10:53:21,354 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000003 is : 143
2015-09-24 10:53:21,458 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000004 is : 143
2015-09-24 10:53:21,519 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000005 is : 143
2015-09-24 10:53:38,832 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0043_01_000011 is : 143
2015-09-24 10:53:40,088 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch/_temporary
2015-09-24 10:53:40,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 02:10.641
2015-09-24 10:53:40,136 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupFilteredBranch/cogroupfilteredbranch
2015-09-24 10:53:40,166 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:53:40,166 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:53:40,200 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-09-24 10:53:40,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:53:40,202 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:53:40,229 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:53:40,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:53:40,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:53:40,230 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup"]
2015-09-24 10:53:40,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:53:40,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:53:40,231 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:53:40,232 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...tform/testCoGroup/cogroup
2015-09-24 10:53:40,396 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0044
2015-09-24 10:53:40,396 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0044/
2015-09-24 10:54:02,440 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0044_01_000008
2015-09-24 10:54:02,622 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0044_01_000010
2015-09-24 10:54:27,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000007 is : 143
2015-09-24 10:54:27,514 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000003 is : 143
2015-09-24 10:54:27,619 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000006 is : 143
2015-09-24 10:54:27,781 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000005 is : 143
2015-09-24 10:54:27,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000004 is : 143
2015-09-24 10:54:28,090 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000002 is : 143
2015-09-24 10:54:47,051 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0044_01_000011 is : 143
2015-09-24 10:54:48,277 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup/_temporary
2015-09-24 10:54:48,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:08.045
2015-09-24 10:54:48,330 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroup/cogroup
2015-09-24 10:54:48,359 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:54:48,359 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:54:48,401 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-09-24 10:54:48,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:54:48,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:54:48,421 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:54:48,421 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 10:54:48,421 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 10:54:48,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown"]
2015-09-24 10:54:48,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:54:48,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:54:48,422 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:54:48,424 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...GroupWithUnknowns/unknown
2015-09-24 10:54:48,612 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0045
2015-09-24 10:54:48,613 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0045/
2015-09-24 10:55:11,068 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0045_01_000009
2015-09-24 10:55:11,132 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0045_01_000010
2015-09-24 10:55:35,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000004 is : 143
2015-09-24 10:55:35,768 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000005 is : 143
2015-09-24 10:55:35,994 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000006 is : 143
2015-09-24 10:55:36,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000003 is : 143
2015-09-24 10:55:36,129 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000002 is : 143
2015-09-24 10:55:36,203 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000007 is : 143
2015-09-24 10:55:54,630 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0045_01_000011 is : 143
2015-09-24 10:55:55,884 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown/_temporary
2015-09-24 10:55:55,887 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:07.461
2015-09-24 10:55:55,929 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupWithUnknowns/unknown
2015-09-24 10:55:55,955 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:55:55,956 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:55:55,993 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-09-24 10:55:55,995 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:55:55,995 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:55:56,010 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:55:56,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:55:56,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:55:56,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull"]
2015-09-24 10:55:56,011 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:55:56,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:55:56,012 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:55:56,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...ull/cogroupouterinnernull
2015-09-24 10:55:56,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0046
2015-09-24 10:55:56,180 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0046/
2015-09-24 10:56:18,241 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0046_01_000007
2015-09-24 10:56:40,398 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0046_01_000004 is : 143
2015-09-24 10:56:40,462 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0046_01_000003 is : 143
2015-09-24 10:56:40,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0046_01_000005 is : 143
2015-09-24 10:56:40,627 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0046_01_000006 is : 143
2015-09-24 10:56:40,706 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0046_01_000002 is : 143
2015-09-24 10:56:58,782 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0046_01_000008 is : 143
2015-09-24 10:57:00,048 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull/_temporary
2015-09-24 10:57:00,051 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:04.035
2015-09-24 10:57:00,105 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:57:00,105 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:57:00,136 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.028
2015-09-24 10:57:00,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:57:00,138 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:57:00,154 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:57:00,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:57:00,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:57:00,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup"]
2015-09-24 10:57:00,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:57:00,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:57:00,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:57:00,157 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...uterinnernull-resultgroup
2015-09-24 10:57:00,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0047
2015-09-24 10:57:00,330 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0047/
2015-09-24 10:57:21,819 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0047_01_000007
2015-09-24 10:57:42,768 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0047_01_000006 is : 143
2015-09-24 10:57:42,862 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0047_01_000005 is : 143
2015-09-24 10:57:42,939 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0047_01_000003 is : 143
2015-09-24 10:57:42,945 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0047_01_000004 is : 143
2015-09-24 10:57:43,056 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0047_01_000002 is : 143
2015-09-24 10:58:00,651 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0047_01_000008 is : 143
2015-09-24 10:58:01,867 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup/_temporary
2015-09-24 10:58:01,870 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:01.711
2015-09-24 10:58:01,915 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull-resultgroup
2015-09-24 10:58:01,923 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupOuterInnerNull/cogroupouterinnernull
2015-09-24 10:58:01,968 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:58:01,969 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:58:02,006 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.033
2015-09-24 10:58:02,008 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:58:02,009 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:58:02,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:58:02,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:58:02,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:58:02,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull"]
2015-09-24 10:58:02,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:58:02,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:58:02,029 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:58:02,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nnerNull/cogroupinnernull
2015-09-24 10:58:02,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0048
2015-09-24 10:58:02,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0048/
2015-09-24 10:58:24,018 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0048_01_000008
2015-09-24 10:58:43,550 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0048_01_000005 is : 143
2015-09-24 10:58:43,610 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0048_01_000002 is : 143
2015-09-24 10:58:43,676 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0048_01_000006 is : 143
2015-09-24 10:58:43,753 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0048_01_000004 is : 143
2015-09-24 10:58:43,772 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0048_01_000003 is : 143
2015-09-24 10:59:02,803 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0048_01_000009 is : 143
2015-09-24 10:59:04,063 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull/_temporary
2015-09-24 10:59:04,066 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:02.032
2015-09-24 10:59:04,150 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 10:59:04,151 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 10:59:04,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.038
2015-09-24 10:59:04,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 10:59:04,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 10:59:04,212 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 10:59:04,212 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/rhs-sparse.txt"]
2015-09-24 10:59:04,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextDelimited[['num', 'char' | Integer, String]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lhs-sparse.txt"]
2015-09-24 10:59:04,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextDelimited[[0:3]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup"]
2015-09-24 10:59:04,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 10:59:04,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 10:59:04,213 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 10:59:04,215 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...roupinnernull-resultgroup
2015-09-24 10:59:04,406 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0049
2015-09-24 10:59:04,406 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0049/
2015-09-24 10:59:27,785 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0049_01_000007
2015-09-24 10:59:47,977 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0049_01_000004 is : 143
2015-09-24 10:59:48,019 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0049_01_000006 is : 143
2015-09-24 10:59:48,128 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0049_01_000003 is : 143
2015-09-24 10:59:48,169 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0049_01_000002 is : 143
2015-09-24 10:59:48,339 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0049_01_000005 is : 143
2015-09-24 11:00:06,478 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0049_01_000008 is : 143
2015-09-24 11:00:07,717 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup/_temporary
2015-09-24 11:00:07,720 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:03.503
2015-09-24 11:00:07,761 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull
2015-09-24 11:00:07,768 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerNull/cogroupinnernull-resultgroup
2015-09-24 11:00:07,795 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:00:07,796 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:00:07,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-09-24 11:00:07,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:00:07,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:00:07,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 11:00:07,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 11:00:07,861 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-09-24 11:00:07,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle"]
2015-09-24 11:00:07,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 11:00:07,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 11:00:07,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 11:00:07,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...eField/cogroupinnersingle
2015-09-24 11:00:08,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0050
2015-09-24 11:00:08,025 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0050/
2015-09-24 11:00:29,460 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0050_01_000008
2015-09-24 11:00:29,527 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0050_01_000009
2015-09-24 11:00:53,349 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000002 is : 143
2015-09-24 11:00:53,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000006 is : 143
2015-09-24 11:00:53,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000003 is : 143
2015-09-24 11:00:53,518 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000004 is : 143
2015-09-24 11:00:53,560 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000007 is : 143
2015-09-24 11:00:53,715 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000005 is : 143
2015-09-24 11:01:11,370 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0050_01_000010 is : 143
2015-09-24 11:01:12,600 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle/_temporary
2015-09-24 11:01:12,603 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:04.735
2015-09-24 11:01:12,648 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupInnerSingleField/cogroupinnersingle
2015-09-24 11:01:12,677 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:01:12,677 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:01:12,750 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2015-09-24 11:01:12,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 6
2015-09-24 11:01:12,753 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:01:12,799 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 11:01:12,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 11:01:12,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:01:12,800 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared"]
2015-09-24 11:01:12,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 11:01:12,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 3
2015-09-24 11:01:12,801 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 3
2015-09-24 11:01:12,803 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/3)
2015-09-24 11:01:12,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/3)
2015-09-24 11:01:13,043 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0051
2015-09-24 11:01:13,044 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0051/
2015-09-24 11:01:13,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0052
2015-09-24 11:01:13,057 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0052/
2015-09-24 11:01:38,644 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0051_01_000009
2015-09-24 11:01:38,654 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0052_01_000007
2015-09-24 11:02:12,151 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0052_01_000005 is : 143
2015-09-24 11:02:12,413 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0052_01_000003 is : 143
2015-09-24 11:02:12,511 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0051_01_000008 is : 143
2015-09-24 11:02:12,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0052_01_000002 is : 143
2015-09-24 11:02:12,724 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0051_01_000004 is : 143
2015-09-24 11:02:12,804 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0051_01_000003 is : 143
2015-09-24 11:02:12,902 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0051_01_000002 is : 143
2015-09-24 11:02:12,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0051_01_000005 is : 143
2015-09-24 11:02:13,022 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0052_01_000006 is : 143
2015-09-24 11:02:13,115 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0052_01_000004 is : 143
2015-09-24 11:02:32,545 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0051_01_000010 is : 143
2015-09-24 11:02:32,633 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0052_01_000008 is : 143
2015-09-24 11:02:33,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (3/3) ...ared/aftereverynodeclared
2015-09-24 11:02:34,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0053
2015-09-24 11:02:34,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0053/
2015-09-24 11:03:09,887 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0053_01_000002 is : 143
2015-09-24 11:03:09,923 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0053_01_000003 is : 143
2015-09-24 11:03:28,176 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0053_01_000004 is : 143
2015-09-24 11:03:29,393 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared/_temporary
2015-09-24 11:03:29,398 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 02:16.590
2015-09-24 11:03:29,435 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupAfterEveryNoDeclared/aftereverynodeclared
2015-09-24 11:03:29,462 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:03:29,462 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:03:29,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 11:03:29,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:03:29,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:03:29,514 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 11:03:29,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:03:29,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:03:29,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself"]
2015-09-24 11:03:29,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 11:03:29,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 1
2015-09-24 11:03:29,515 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 1
2015-09-24 11:03:29,517 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...stCoGroupSelf/cogroupself
2015-09-24 11:03:29,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0054
2015-09-24 11:03:29,688 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0054/
2015-09-24 11:03:52,243 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0054_01_000008
2015-09-24 11:04:13,543 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0054_01_000005 is : 143
2015-09-24 11:04:13,662 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0054_01_000002 is : 143
2015-09-24 11:04:13,758 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0054_01_000006 is : 143
2015-09-24 11:04:13,823 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0054_01_000003 is : 143
2015-09-24 11:04:13,896 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0054_01_000004 is : 143
2015-09-24 11:04:31,718 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0054_01_000009 is : 143
2015-09-24 11:04:32,931 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself/_temporary
2015-09-24 11:04:32,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 01:03.415
2015-09-24 11:04:32,976 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupSelf/cogroupself
2015-09-24 11:04:33,015 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:04:33,016 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:04:33,068 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-09-24 11:04:33,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 11:04:33,070 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:04:33,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 11:04:33,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 11:04:33,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:04:33,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby"]
2015-09-24 11:04:33,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  parallel execution of steps is enabled: true
2015-09-24 11:04:33,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  executing total steps: 2
2015-09-24 11:04:33,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  allocating management threads: 2
2015-09-24 11:04:33,097 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 11:04:33,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0055
2015-09-24 11:04:33,255 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0055/
2015-09-24 11:04:55,783 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0055_01_000009
2015-09-24 11:04:55,950 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443103965561_0055_01_000010
2015-09-24 11:05:20,782 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000005 is : 143
2015-09-24 11:05:20,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000002 is : 143
2015-09-24 11:05:20,995 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000004 is : 143
2015-09-24 11:05:21,092 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000003 is : 143
2015-09-24 11:05:21,227 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000006 is : 143
2015-09-24 11:05:21,289 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000007 is : 143
2015-09-24 11:05:41,215 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0055_01_000011 is : 143
2015-09-24 11:05:42,403 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...oupGroupBy/cogroupgroupby
2015-09-24 11:05:42,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443103965561_0056
2015-09-24 11:05:42,641 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:49576/proxy/application_1443103965561_0056/
2015-09-24 11:06:17,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0056_01_000002 is : 143
2015-09-24 11:06:36,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443103965561_0056_01_000003 is : 143
2015-09-24 11:06:37,873 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby/_temporary
2015-09-24 11:06:37,876 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper]  completed in: 02:04.776
2015-09-24 11:06:37,926 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/cogroupfieldedpipesplatform/testCoGroupGroupBy/cogroupgroupby

Standard error

Sep 24, 2015 10:12:46 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices as a root resource class
Sep 24, 2015 10:12:46 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 10:12:46 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 10:12:46 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 10:12:46 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:46 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.mapreduce.v2.hs.webapp.HsWebServices to GuiceManagedComponentProvider with the scope "PerRequest"
Sep 24, 2015 10:12:47 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root resource class
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 10:12:47 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:47 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:47 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 10:12:48 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Sep 24, 2015 10:12:48 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 10:12:48 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 10:12:48 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 10:12:48 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:48 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:48 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:48 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 10:12:49 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Sep 24, 2015 10:12:49 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 10:12:49 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 10:12:49 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 10:12:49 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:49 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:49 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:49 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.
Sep 24, 2015 10:12:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root resource class
Sep 24, 2015 10:12:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a provider class
Sep 24, 2015 10:12:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a provider class
Sep 24, 2015 10:12:50 AM com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17 AM'
Sep 24, 2015 10:12:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:50 AM com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices to GuiceManagedComponentProvider with the scope "Singleton"
Sep 24, 2015 10:12:50 AM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating that you have more than one GuiceFilter running in your web application. If this is deliberate, you may safely ignore this message. If this is NOT deliberate however, your application may not work as expected.