2015-09-24 12:31:29,789 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 12:31:29,831 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.MergePipesPlatformTest, with platform: hadoop2-mr1
2015-09-24 12:31:29,856 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 12:31:41,876 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 12:31:42,453 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 12:31:49,833 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 12:31:50,155 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 12:31:50,421 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 12:31:50,660 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 12:31:50,915 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 12:32:08,055 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-09-24 12:32:08,201 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:32:08,203 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 12:32:08,260 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: BBA0E67E7D7547329FCB35175E47623B
2015-09-24 12:32:08,400 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.100
2015-09-24 12:32:08,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:32:08,405 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:32:08,532 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 12:32:08,533 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-09-24 12:32:08,534 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] 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 12:32:08,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] 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 12:32:08,535 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMerge/simplemerge"]
2015-09-24 12:32:08,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2015-09-24 12:32:08,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2015-09-24 12:32:08,536 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2015-09-24 12:32:08,538 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2015-09-24 12:32:09,523 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1443112322544_0001
2015-09-24 12:32:09,523 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:51390/proxy/application_1443112322544_0001/
2015-09-24 12:32:32,551 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0001_01_000008
2015-09-24 12:32:32,686 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0001_01_000009
2015-09-24 12:32:57,466 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0001_01_000007 is : 143
2015-09-24 12:32:57,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0001_01_000004 is : 143
2015-09-24 12:32:57,696 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0001_01_000006 is : 143
2015-09-24 12:32:57,937 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0001_01_000002 is : 143
2015-09-24 12:32:58,061 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0001_01_000003 is : 143
2015-09-24 12:32:58,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0001_01_000005 is : 143
2015-09-24 12:32:59,492 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/mergepipesplatform/testSimpleMerge/simplemerge/_temporary
2015-09-24 12:32:59,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:50.954
2015-09-24 12:32:59,599 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/mergepipesplatform/testSimpleMerge/simplemerge
2015-09-24 12:32:59,676 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:32:59,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 12:32:59,865 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.178
2015-09-24 12:32:59,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-09-24 12:32:59,869 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:32:59,961 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2015-09-24 12:32:59,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] 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 12:32:59,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] 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 12:32:59,962 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] 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 12:32:59,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-09-24 12:32:59,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] parallel execution of steps is enabled: true
2015-09-24 12:32:59,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executing total steps: 3
2015-09-24 12:32:59,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] allocating management threads: 3
2015-09-24 12:32:59,965 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/3)
2015-09-24 12:33:00,168 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1443112322544_0002
2015-09-24 12:33:00,169 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:51390/proxy/application_1443112322544_0002/
2015-09-24 12:33:21,989 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0002_01_000008
2015-09-24 12:33:22,106 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0002_01_000009
2015-09-24 12:33:45,343 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0002_01_000002 is : 143
2015-09-24 12:33:45,440 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0002_01_000004 is : 143
2015-09-24 12:33:45,621 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0002_01_000006 is : 143
2015-09-24 12:33:45,773 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0002_01_000003 is : 143
2015-09-24 12:33:45,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0002_01_000005 is : 143
2015-09-24 12:33:45,982 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0002_01_000007 is : 143
2015-09-24 12:33:47,208 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/3)
2015-09-24 12:33:47,433 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1443112322544_0003
2015-09-24 12:33:47,434 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:51390/proxy/application_1443112322544_0003/
2015-09-24 12:34:08,947 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0003_01_000008
2015-09-24 12:34:09,019 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0003_01_000009
2015-09-24 12:34:31,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0003_01_000003 is : 143
2015-09-24 12:34:32,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0003_01_000006 is : 143
2015-09-24 12:34:32,570 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0003_01_000007 is : 143
2015-09-24 12:34:32,620 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0003_01_000002 is : 143
2015-09-24 12:34:32,741 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0003_01_000005 is : 143
2015-09-24 12:34:32,798 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0003_01_000004 is : 143
2015-09-24 12:34:34,024 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (3/3) ...condAccumulatedinterMerge
2015-09-24 12:34:34,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1443112322544_0004
2015-09-24 12:34:34,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:51390/proxy/application_1443112322544_0004/
2015-09-24 12:34:55,796 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0004_01_000007
2015-09-24 12:35:17,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0004_01_000004 is : 143
2015-09-24 12:35:17,313 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0004_01_000006 is : 143
2015-09-24 12:35:17,786 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0004_01_000002 is : 143
2015-09-24 12:35:17,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0004_01_000005 is : 143
2015-09-24 12:35:18,003 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0004_01_000003 is : 143
2015-09-24 12:35:19,307 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-09-24 12:35:19,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] completed in: 02:19.338
2015-09-24 12:35:19,347 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-09-24 12:35:19,402 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:35:19,403 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 12:35:19,492 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.082
2015-09-24 12:35:19,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:35:19,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:35:19,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2015-09-24 12:35:19,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] 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 12:35:19,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] 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 12:35:19,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] 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 12:35:19,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-09-24 12:35:19,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] parallel execution of steps is enabled: true
2015-09-24 12:35:19,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executing total steps: 1
2015-09-24 12:35:19,518 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] allocating management threads: 1
2015-09-24 12:35:19,520 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/1) ...dsecondStreamedinterMerge
2015-09-24 12:35:19,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1443112322544_0005
2015-09-24 12:35:19,769 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0005/
2015-09-24 12:35:41,808 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0005_01_000008
2015-09-24 12:35:42,046 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0005_01_000010
2015-09-24 12:36:06,386 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0005_01_000006 is : 143
2015-09-24 12:36:06,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0005_01_000003 is : 143
2015-09-24 12:36:06,686 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0005_01_000007 is : 143
2015-09-24 12:36:06,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0005_01_000005 is : 143
2015-09-24 12:36:06,846 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0005_01_000002 is : 143
2015-09-24 12:36:07,036 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0005_01_000004 is : 143
2015-09-24 12:36:08,298 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-09-24 12:36:08,301 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] completed in: 00:48.777
2015-09-24 12:36:08,344 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-09-24 12:36:08,400 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:36:08,400 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 12:36:08,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-09-24 12:36:08,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:36:08,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:36:08,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-09-24 12:36:08,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] 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 12:36:08,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] 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 12:36:08,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] 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 12:36:08,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThree/simplemergethree"]
2015-09-24 12:36:08,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] parallel execution of steps is enabled: true
2015-09-24 12:36:08,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executing total steps: 1
2015-09-24 12:36:08,490 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] allocating management threads: 1
2015-09-24 12:36:08,491 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2015-09-24 12:36:08,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1443112322544_0006
2015-09-24 12:36:08,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:51390/proxy/application_1443112322544_0006/
2015-09-24 12:36:30,068 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0006_01_000012
2015-09-24 12:36:30,750 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0006_01_000013
2015-09-24 12:36:31,890 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0006_01_000014
2015-09-24 12:37:01,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000009 is : 143
2015-09-24 12:37:01,661 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000008 is : 143
2015-09-24 12:37:01,887 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000002 is : 143
2015-09-24 12:37:02,029 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000005 is : 143
2015-09-24 12:37:02,110 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000004 is : 143
2015-09-24 12:37:02,167 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000011 is : 143
2015-09-24 12:37:02,381 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000003 is : 143
2015-09-24 12:37:02,519 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000006 is : 143
2015-09-24 12:37:02,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0006_01_000007 is : 143
2015-09-24 12:37:04,024 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/mergepipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2015-09-24 12:37:04,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] completed in: 00:55.531
2015-09-24 12:37:04,098 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/mergepipesplatform/testSimpleMergeThree/simplemergethree
2015-09-24 12:37:04,156 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:37:04,156 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 12:37:04,237 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.073
2015-09-24 12:37:04,238 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:37:04,239 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:37:04,276 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting
2015-09-24 12:37:04,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] 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 12:37:04,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] 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 12:37:04,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] 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 12:37:04,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-09-24 12:37:04,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] parallel execution of steps is enabled: true
2015-09-24 12:37:04,277 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] executing total steps: 1
2015-09-24 12:37:04,278 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] allocating management threads: 1
2015-09-24 12:37:04,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] starting step: (1/1) ...econdStreamednoInterMerge
2015-09-24 12:37:04,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] submitted hadoop job: job_1443112322544_0007
2015-09-24 12:37:04,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0007/
2015-09-24 12:37:26,740 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0007_01_000009
2015-09-24 12:37:27,086 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0007_01_000010
2015-09-24 12:37:50,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0007_01_000004 is : 143
2015-09-24 12:37:50,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0007_01_000006 is : 143
2015-09-24 12:37:50,961 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0007_01_000003 is : 143
2015-09-24 12:37:51,047 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0007_01_000007 is : 143
2015-09-24 12:37:51,187 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0007_01_000005 is : 143
2015-09-24 12:37:51,229 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0007_01_000002 is : 143
2015-09-24 12:37:52,501 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-09-24 12:37:52,503 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge1*offset*offset] completed in: 00:48.221
2015-09-24 12:37:52,542 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedStreamed/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-09-24 12:37:52,590 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:37:52,590 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 12:37:52,647 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2015-09-24 12:37:52,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:37:52,649 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:37:52,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2015-09-24 12:37:52,665 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:37:52,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:37:52,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:37:52,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain"]
2015-09-24 12:37:52,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2015-09-24 12:37:52,666 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 1
2015-09-24 12:37:52,667 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 1
2015-09-24 12:37:52,668 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...ain/simplemergethreechain
2015-09-24 12:37:52,866 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1443112322544_0008
2015-09-24 12:37:52,867 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0008/
2015-09-24 12:38:15,259 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0008_01_000012
2015-09-24 12:38:15,303 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0008_01_000013
2015-09-24 12:38:15,854 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0008_01_000014
2015-09-24 12:38:45,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000008 is : 143
2015-09-24 12:38:45,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000004 is : 143
2015-09-24 12:38:45,421 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000003 is : 143
2015-09-24 12:38:45,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000009 is : 143
2015-09-24 12:38:45,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000010 is : 143
2015-09-24 12:38:46,082 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000002 is : 143
2015-09-24 12:38:46,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000005 is : 143
2015-09-24 12:38:46,149 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000007 is : 143
2015-09-24 12:38:46,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0008_01_000006 is : 143
2015-09-24 12:38:47,504 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/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain/_temporary
2015-09-24 12:38:47,507 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 00:54.836
2015-09-24 12:38:47,561 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/mergepipesplatform/testSimpleMergeThreeChain/simplemergethreechain
2015-09-24 12:38:47,618 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:38:47,619 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 12:38:47,709 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.084
2015-09-24 12:38:47,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-09-24 12:38:47,712 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:38:47,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2015-09-24 12:38:47,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] 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 12:38:47,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] 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 12:38:47,740 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] 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 12:38:47,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-09-24 12:38:47,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2015-09-24 12:38:47,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executing total steps: 2
2015-09-24 12:38:47,741 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] allocating management threads: 2
2015-09-24 12:38:47,743 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/2)
2015-09-24 12:38:47,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1443112322544_0009
2015-09-24 12:38:47,926 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0009/
2015-09-24 12:39:10,228 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0009_01_000009
2015-09-24 12:39:10,300 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0009_01_000010
2015-09-24 12:39:33,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0009_01_000005 is : 143
2015-09-24 12:39:33,519 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0009_01_000006 is : 143
2015-09-24 12:39:33,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0009_01_000003 is : 143
2015-09-24 12:39:33,806 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0009_01_000002 is : 143
2015-09-24 12:39:33,894 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0009_01_000007 is : 143
2015-09-24 12:39:33,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0009_01_000004 is : 143
2015-09-24 12:39:35,145 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/2) ...ndAccumulatednoInterMerge
2015-09-24 12:39:35,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1443112322544_0010
2015-09-24 12:39:35,315 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0010/
2015-09-24 12:39:56,874 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0010_01_000007
2015-09-24 12:40:18,449 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0010_01_000006 is : 143
2015-09-24 12:40:18,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0010_01_000004 is : 143
2015-09-24 12:40:18,646 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0010_01_000005 is : 143
2015-09-24 12:40:18,651 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0010_01_000003 is : 143
2015-09-24 12:40:18,908 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0010_01_000002 is : 143
2015-09-24 12:40:20,132 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-09-24 12:40:20,134 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] completed in: 01:32.387
2015-09-24 12:40:20,165 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulated/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-09-24 12:40:20,227 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:40:20,227 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 12:40:20,272 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-09-24 12:40:20,274 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:40:20,274 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:40:20,288 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2015-09-24 12:40:20,288 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 12:40:20,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2015-09-24 12:40:20,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] parallel execution of steps is enabled: true
2015-09-24 12:40:20,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executing total steps: 1
2015-09-24 12:40:20,289 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] allocating management threads: 1
2015-09-24 12:40:20,290 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2015-09-24 12:40:20,457 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1443112322544_0011
2015-09-24 12:40:20,457 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://localhost:51390/proxy/application_1443112322544_0011/
2015-09-24 12:41:00,162 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0011_01_000004 is : 143
2015-09-24 12:41:00,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0011_01_000005 is : 143
2015-09-24 12:41:00,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0011_01_000002 is : 143
2015-09-24 12:41:00,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0011_01_000003 is : 143
2015-09-24 12:41:01,860 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/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2015-09-24 12:41:01,862 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] completed in: 00:41.569
2015-09-24 12:41:01,894 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/mergepipesplatform/testSplitSameSourceMerged/splitsourcemerged
2015-09-24 12:41:01,930 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:41:01,931 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 12:41:02,000 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2015-09-24 12:41:02,002 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:41:02,002 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:41:02,025 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2015-09-24 12:41:02,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:41:02,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:41:02,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:41:02,026 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed"]
2015-09-24 12:41:02,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2015-09-24 12:41:02,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2015-09-24 12:41:02,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2015-09-24 12:41:02,028 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-09-24 12:41:02,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1443112322544_0012
2015-09-24 12:41:02,205 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0012/
2015-09-24 12:41:23,666 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0012_01_000009
2015-09-24 12:41:23,700 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0012_01_000010
2015-09-24 12:41:47,004 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0012_01_000007 is : 143
2015-09-24 12:41:47,255 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0012_01_000006 is : 143
2015-09-24 12:41:47,461 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0012_01_000004 is : 143
2015-09-24 12:41:47,495 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0012_01_000002 is : 143
2015-09-24 12:41:47,643 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0012_01_000005 is : 143
2015-09-24 12:41:47,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0012_01_000003 is : 143
2015-09-24 12:41:48,986 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed/_temporary
2015-09-24 12:41:48,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:46.957
2015-09-24 12:41:49,030 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamed/hashjoinintomergeintohashjoinstreamed
2015-09-24 12:41:49,077 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:41:49,078 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 12:41:49,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: ILLEGAL, in: 00:00.019
2015-09-24 12:41:49,102 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, found assembly to be malformed
2015-09-24 12:41:49,104 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/mergepipesplatform/testSimpleMergeFail/simplemergefail
2015-09-24 12:41:49,128 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:41:49,128 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 12:41:49,201 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2015-09-24 12:41:49,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 12:41:49,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:41:49,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2015-09-24 12:41:49,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:41:49,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:41:49,228 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:41:49,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup"]
2015-09-24 12:41:49,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2015-09-24 12:41:49,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 1
2015-09-24 12:41:49,229 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 1
2015-09-24 12:41:49,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-09-24 12:41:49,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1443112322544_0013
2015-09-24 12:41:49,417 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0013/
2015-09-24 12:42:12,111 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0013_01_000013
2015-09-24 12:42:12,111 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0013_01_000014
2015-09-24 12:42:12,111 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0013_01_000012
2015-09-24 12:42:39,598 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000009 is : 143
2015-09-24 12:42:39,730 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000006 is : 143
2015-09-24 12:42:39,819 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000008 is : 143
2015-09-24 12:42:39,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000007 is : 143
2015-09-24 12:42:40,075 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000003 is : 143
2015-09-24 12:42:40,202 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000004 is : 143
2015-09-24 12:42:40,284 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000002 is : 143
2015-09-24 12:42:40,403 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000010 is : 143
2015-09-24 12:42:40,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000005 is : 143
2015-09-24 12:42:57,778 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0013_01_000015 is : 143
2015-09-24 12:42:58,995 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/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup/_temporary
2015-09-24 12:42:58,998 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 01:09.765
2015-09-24 12:42:59,018 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/mergepipesplatform/testSimpleMergeThreeChainGroup/simplemergethreechaingroup
2015-09-24 12:42:59,050 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:42:59,051 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 12:42:59,160 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.104
2015-09-24 12:42:59,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-09-24 12:42:59,163 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:42:59,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting
2015-09-24 12:42:59,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] 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 12:42:59,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] 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 12:42:59,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] 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 12:42:59,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-09-24 12:42:59,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] parallel execution of steps is enabled: true
2015-09-24 12:42:59,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] executing total steps: 3
2015-09-24 12:42:59,204 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] allocating management threads: 3
2015-09-24 12:42:59,206 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (1/3)
2015-09-24 12:42:59,420 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1443112322544_0014
2015-09-24 12:42:59,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0014/
2015-09-24 12:43:20,845 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0014_01_000008
2015-09-24 12:43:44,410 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0014_01_000003 is : 143
2015-09-24 12:43:44,546 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0014_01_000002 is : 143
2015-09-24 12:43:44,716 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0014_01_000006 is : 143
2015-09-24 12:43:45,021 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0014_01_000004 is : 143
2015-09-24 12:43:45,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0014_01_000007 is : 143
2015-09-24 12:43:45,106 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0014_01_000005 is : 143
2015-09-24 12:43:46,308 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (2/3)
2015-09-24 12:43:46,495 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1443112322544_0015
2015-09-24 12:43:46,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0015/
2015-09-24 12:44:08,073 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0015_01_000008
2015-09-24 12:44:29,301 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0015_01_000006 is : 143
2015-09-24 12:44:29,341 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0015_01_000002 is : 143
2015-09-24 12:44:29,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0015_01_000003 is : 143
2015-09-24 12:44:29,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0015_01_000005 is : 143
2015-09-24 12:44:29,723 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0015_01_000004 is : 143
2015-09-24 12:44:30,900 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] starting step: (3/3) ...econdStreamednoInterMerge
2015-09-24 12:44:31,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] submitted hadoop job: job_1443112322544_0016
2015-09-24 12:44:31,072 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0016/
2015-09-24 12:44:52,499 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0016_01_000008
2015-09-24 12:45:15,925 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0016_01_000005 is : 143
2015-09-24 12:45:15,932 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0016_01_000006 is : 143
2015-09-24 12:45:16,254 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0016_01_000003 is : 143
2015-09-24 12:45:16,446 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0016_01_000004 is : 143
2015-09-24 12:45:16,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0016_01_000002 is : 143
2015-09-24 12:45:17,795 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-09-24 12:45:17,804 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge1*offset] completed in: 02:18.585
2015-09-24 12:45:17,857 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamed/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-09-24 12:45:17,927 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:45:17,928 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 12:45:18,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.075
2015-09-24 12:45:18,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:45:18,013 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:45:18,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2015-09-24 12:45:18,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:45:18,057 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:45:18,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:45:18,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed"]
2015-09-24 12:45:18,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2015-09-24 12:45:18,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2015-09-24 12:45:18,058 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2015-09-24 12:45:18,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-09-24 12:45:18,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1443112322544_0017
2015-09-24 12:45:18,341 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0017/
2015-09-24 12:45:41,319 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0017_01_000008
2015-09-24 12:45:41,596 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0017_01_000010
2015-09-24 12:46:06,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0017_01_000007 is : 143
2015-09-24 12:46:06,578 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0017_01_000006 is : 143
2015-09-24 12:46:06,736 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0017_01_000003 is : 143
2015-09-24 12:46:06,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0017_01_000002 is : 143
2015-09-24 12:46:07,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0017_01_000004 is : 143
2015-09-24 12:46:07,157 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0017_01_000005 is : 143
2015-09-24 12:46:08,447 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/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed/_temporary
2015-09-24 12:46:08,452 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 00:50.387
2015-09-24 12:46:08,487 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/mergepipesplatform/testMergeIntoHashJoinStreamed/mergeintohashjoinstreamed
2015-09-24 12:46:08,530 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:46:08,531 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 12:46:08,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.058
2015-09-24 12:46:08,596 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 12:46:08,596 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:46:08,623 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting
2015-09-24 12:46:08,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:46:08,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:46:08,624 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] 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 12:46:08,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup"]
2015-09-24 12:46:08,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] parallel execution of steps is enabled: true
2015-09-24 12:46:08,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] executing total steps: 1
2015-09-24 12:46:08,625 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] allocating management threads: 1
2015-09-24 12:46:08,626 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-09-24 12:46:08,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] submitted hadoop job: job_1443112322544_0018
2015-09-24 12:46:08,814 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0018/
2015-09-24 12:46:31,119 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0018_01_000012
2015-09-24 12:46:31,235 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0018_01_000013
2015-09-24 12:46:31,818 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0018_01_000014
2015-09-24 12:47:02,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000004 is : 143
2015-09-24 12:47:03,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000009 is : 143
2015-09-24 12:47:03,200 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000002 is : 143
2015-09-24 12:47:03,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000005 is : 143
2015-09-24 12:47:03,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000010 is : 143
2015-09-24 12:47:03,605 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000003 is : 143
2015-09-24 12:47:03,693 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000008 is : 143
2015-09-24 12:47:03,805 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000006 is : 143
2015-09-24 12:47:03,970 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000007 is : 143
2015-09-24 12:47:20,817 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0018_01_000015 is : 143
2015-09-24 12:47:22,059 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/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup/_temporary
2015-09-24 12:47:22,062 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge*offset] completed in: 01:13.432
2015-09-24 12:47:22,082 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/mergepipesplatform/testSimpleMergeThreeChainCoGroup/simplemergethreechaincogroup
2015-09-24 12:47:22,107 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:47:22,107 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 12:47:22,183 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2015-09-24 12:47:22,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 12:47:22,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:47:22,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting
2015-09-24 12:47:22,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] 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 12:47:22,219 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2015-09-24 12:47:22,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] parallel execution of steps is enabled: true
2015-09-24 12:47:22,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] executing total steps: 2
2015-09-24 12:47:22,220 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] allocating management threads: 2
2015-09-24 12:47:22,222 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (1/2)
2015-09-24 12:47:22,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1443112322544_0019
2015-09-24 12:47:22,426 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0019/
2015-09-24 12:47:44,886 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0019_01_000008
2015-09-24 12:48:07,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0019_01_000004 is : 143
2015-09-24 12:48:08,021 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0019_01_000006 is : 143
2015-09-24 12:48:08,074 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0019_01_000003 is : 143
2015-09-24 12:48:08,100 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0019_01_000002 is : 143
2015-09-24 12:48:08,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0019_01_000005 is : 143
2015-09-24 12:48:25,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0019_01_000009 is : 143
2015-09-24 12:48:27,011 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] starting step: (2/2) .../samemergethreechaingroup
2015-09-24 12:48:27,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] submitted hadoop job: job_1443112322544_0020
2015-09-24 12:48:27,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0020/
2015-09-24 12:48:48,901 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0020_01_000008
2015-09-24 12:49:11,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000007 is : 143
2015-09-24 12:49:11,782 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000004 is : 143
2015-09-24 12:49:11,838 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000002 is : 143
2015-09-24 12:49:11,959 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000006 is : 143
2015-09-24 12:49:12,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000005 is : 143
2015-09-24 12:49:12,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000003 is : 143
2015-09-24 12:49:30,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0020_01_000009 is : 143
2015-09-24 12:49:32,028 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/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2015-09-24 12:49:32,037 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge+offset] completed in: 02:09.805
2015-09-24 12:49:32,062 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/mergepipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2015-09-24 12:49:32,101 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:49:32,101 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 12:49:32,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.135
2015-09-24 12:49:32,245 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-09-24 12:49:32,246 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:49:32,279 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting
2015-09-24 12:49:32,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] 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 12:49:32,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] 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 12:49:32,280 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] 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 12:49:32,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-09-24 12:49:32,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] parallel execution of steps is enabled: true
2015-09-24 12:49:32,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] executing total steps: 3
2015-09-24 12:49:32,281 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] allocating management threads: 3
2015-09-24 12:49:32,285 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (1/3)
2015-09-24 12:49:32,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1443112322544_0021
2015-09-24 12:49:32,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0021/
2015-09-24 12:49:55,077 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0021_01_000009
2015-09-24 12:50:18,677 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0021_01_000002 is : 143
2015-09-24 12:50:18,759 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0021_01_000006 is : 143
2015-09-24 12:50:18,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0021_01_000005 is : 143
2015-09-24 12:50:19,021 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0021_01_000004 is : 143
2015-09-24 12:50:19,119 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0021_01_000007 is : 143
2015-09-24 12:50:19,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0021_01_000003 is : 143
2015-09-24 12:50:20,362 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (2/3)
2015-09-24 12:50:20,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1443112322544_0022
2015-09-24 12:50:20,607 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0022/
2015-09-24 12:50:43,992 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0022_01_000009
2015-09-24 12:50:44,074 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0022_01_000010
2015-09-24 12:51:07,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0022_01_000003 is : 143
2015-09-24 12:51:07,983 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0022_01_000006 is : 143
2015-09-24 12:51:08,078 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0022_01_000002 is : 143
2015-09-24 12:51:08,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0022_01_000005 is : 143
2015-09-24 12:51:08,407 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0022_01_000007 is : 143
2015-09-24 12:51:08,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0022_01_000004 is : 143
2015-09-24 12:51:09,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] starting step: (3/3) ...dsecondStreamedinterMerge
2015-09-24 12:51:09,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] submitted hadoop job: job_1443112322544_0023
2015-09-24 12:51:09,815 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] tracking url: http://localhost:51390/proxy/application_1443112322544_0023/
2015-09-24 12:51:31,467 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0023_01_000008
2015-09-24 12:51:31,526 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0023_01_000009
2015-09-24 12:51:54,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0023_01_000006 is : 143
2015-09-24 12:51:54,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0023_01_000007 is : 143
2015-09-24 12:51:54,849 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0023_01_000004 is : 143
2015-09-24 12:51:55,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0023_01_000003 is : 143
2015-09-24 12:51:55,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0023_01_000002 is : 143
2015-09-24 12:51:55,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0023_01_000005 is : 143
2015-09-24 12:51:56,501 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-09-24 12:51:56,505 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merge2*offset] completed in: 02:24.215
2015-09-24 12:51:56,539 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedStreamedMerge/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-09-24 12:51:56,588 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:51:56,589 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 12:51:56,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.049
2015-09-24 12:51:56,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:51:56,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:51:56,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2015-09-24 12:51:56,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] 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 12:51:56,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] 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 12:51:56,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] 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 12:51:56,660 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated"]
2015-09-24 12:51:56,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] parallel execution of steps is enabled: true
2015-09-24 12:51:56,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executing total steps: 1
2015-09-24 12:51:56,661 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] allocating management threads: 1
2015-09-24 12:51:56,663 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/1) ...geintohashjoinaccumulated
2015-09-24 12:51:56,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1443112322544_0024
2015-09-24 12:51:56,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://localhost:51390/proxy/application_1443112322544_0024/
2015-09-24 12:52:18,276 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0024_01_000008
2015-09-24 12:52:39,323 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0024_01_000003 is : 143
2015-09-24 12:52:39,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0024_01_000002 is : 143
2015-09-24 12:52:39,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0024_01_000006 is : 143
2015-09-24 12:52:39,759 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0024_01_000004 is : 143
2015-09-24 12:52:39,829 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0024_01_000005 is : 143
2015-09-24 12:52:41,076 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/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated/_temporary
2015-09-24 12:52:41,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] completed in: 00:44.413
2015-09-24 12:52:41,109 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/mergepipesplatform/testMergeIntoHashJoinAccumulated/mergeintohashjoinaccumulated
2015-09-24 12:52:41,141 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:52:41,141 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 12:52:41,180 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-09-24 12:52:41,182 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 12:52:41,183 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:52:41,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting
2015-09-24 12:52:41,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 12:52:41,198 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex"]
2015-09-24 12:52:41,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] parallel execution of steps is enabled: true
2015-09-24 12:52:41,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] executing total steps: 1
2015-09-24 12:52:41,199 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] allocating management threads: 1
2015-09-24 12:52:41,200 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] starting step: (1/1) .../splitsourcemergedcomplex
2015-09-24 12:52:41,350 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] submitted hadoop job: job_1443112322544_0025
2015-09-24 12:52:41,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] tracking url: http://localhost:51390/proxy/application_1443112322544_0025/
2015-09-24 12:53:22,212 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0025_01_000004 is : 143
2015-09-24 12:53:22,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0025_01_000003 is : 143
2015-09-24 12:53:22,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0025_01_000005 is : 143
2015-09-24 12:53:22,697 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0025_01_000002 is : 143
2015-09-24 12:53:23,914 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/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex/_temporary
2015-09-24 12:53:23,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [merged-second] completed in: 00:42.713
2015-09-24 12:53:23,947 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/mergepipesplatform/testSplitSameSourceMergedComplex/splitsourcemergedcomplex
2015-09-24 12:53:23,978 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:53:23,979 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 12:53:24,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2015-09-24 12:53:24,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-09-24 12:53:24,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:53:24,075 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting
2015-09-24 12:53:24,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] 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 12:53:24,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] 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 12:53:24,076 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] 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 12:53:24,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated"]
2015-09-24 12:53:24,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] parallel execution of steps is enabled: true
2015-09-24 12:53:24,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] executing total steps: 2
2015-09-24 12:53:24,077 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] allocating management threads: 2
2015-09-24 12:53:24,079 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (1/2)
2015-09-24 12:53:24,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1443112322544_0026
2015-09-24 12:53:24,236 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://localhost:51390/proxy/application_1443112322544_0026/
2015-09-24 12:53:45,756 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0026_01_000008
2015-09-24 12:53:46,267 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0026_01_000009
2015-09-24 12:54:09,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0026_01_000002 is : 143
2015-09-24 12:54:09,693 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0026_01_000003 is : 143
2015-09-24 12:54:09,754 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0026_01_000007 is : 143
2015-09-24 12:54:09,790 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0026_01_000006 is : 143
2015-09-24 12:54:10,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0026_01_000005 is : 143
2015-09-24 12:54:10,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0026_01_000004 is : 143
2015-09-24 12:54:11,262 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] starting step: (2/2) ...geintohashjoinaccumulated
2015-09-24 12:54:11,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] submitted hadoop job: job_1443112322544_0027
2015-09-24 12:54:11,419 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] tracking url: http://localhost:51390/proxy/application_1443112322544_0027/
2015-09-24 12:54:33,061 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0027_01_000007
2015-09-24 12:54:55,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0027_01_000006 is : 143
2015-09-24 12:54:55,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0027_01_000004 is : 143
2015-09-24 12:54:55,956 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0027_01_000002 is : 143
2015-09-24 12:54:55,987 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0027_01_000005 is : 143
2015-09-24 12:54:56,045 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0027_01_000003 is : 143
2015-09-24 12:54:57,307 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-09-24 12:54:57,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge] completed in: 01:33.223
2015-09-24 12:54:57,343 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulated/hashjoinintomergeintohashjoinaccumulated
2015-09-24 12:54:57,379 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:54:57,380 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 12:54:57,468 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2015-09-24 12:54:57,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-09-24 12:54:57,470 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:54:57,500 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting
2015-09-24 12:54:57,501 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] 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 12:54:57,501 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] 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 12:54:57,501 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] 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 12:54:57,501 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-09-24 12:54:57,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] parallel execution of steps is enabled: true
2015-09-24 12:54:57,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] executing total steps: 3
2015-09-24 12:54:57,502 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] allocating management threads: 3
2015-09-24 12:54:57,506 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (1/3)
2015-09-24 12:54:57,678 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1443112322544_0028
2015-09-24 12:54:57,678 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://localhost:51390/proxy/application_1443112322544_0028/
2015-09-24 12:55:19,688 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0028_01_000008
2015-09-24 12:55:20,054 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0028_01_000010
2015-09-24 12:55:43,619 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0028_01_000003 is : 143
2015-09-24 12:55:43,699 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0028_01_000006 is : 143
2015-09-24 12:55:43,767 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0028_01_000002 is : 143
2015-09-24 12:55:44,016 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0028_01_000007 is : 143
2015-09-24 12:55:44,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0028_01_000004 is : 143
2015-09-24 12:55:44,231 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0028_01_000005 is : 143
2015-09-24 12:55:45,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (2/3)
2015-09-24 12:55:45,574 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1443112322544_0029
2015-09-24 12:55:45,574 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://localhost:51390/proxy/application_1443112322544_0029/
2015-09-24 12:56:07,071 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0029_01_000007
2015-09-24 12:56:28,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0029_01_000006 is : 143
2015-09-24 12:56:28,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0029_01_000005 is : 143
2015-09-24 12:56:28,953 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0029_01_000002 is : 143
2015-09-24 12:56:28,960 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0029_01_000004 is : 143
2015-09-24 12:56:29,026 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0029_01_000003 is : 143
2015-09-24 12:56:30,273 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] starting step: (3/3) ...ndAccumulatednoInterMerge
2015-09-24 12:56:30,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] submitted hadoop job: job_1443112322544_0030
2015-09-24 12:56:30,460 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] tracking url: http://localhost:51390/proxy/application_1443112322544_0030/
2015-09-24 12:56:53,018 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0030_01_000008
2015-09-24 12:57:13,854 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0030_01_000004 is : 143
2015-09-24 12:57:13,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0030_01_000002 is : 143
2015-09-24 12:57:13,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0030_01_000005 is : 143
2015-09-24 12:57:13,989 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0030_01_000006 is : 143
2015-09-24 12:57:14,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0030_01_000003 is : 143
2015-09-24 12:57:15,413 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-09-24 12:57:15,416 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*offset*merge1] completed in: 02:17.906
2015-09-24 12:57:15,447 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/mergepipesplatform/testHashJoinMergeIntoHashJoinAccumulatedAccumulated/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-09-24 12:57:15,490 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 12:57:15,490 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 12:57:15,561 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2015-09-24 12:57:15,563 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-09-24 12:57:15,564 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 12:57:15,593 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting
2015-09-24 12:57:15,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] 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 12:57:15,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] 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 12:57:15,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] 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 12:57:15,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-09-24 12:57:15,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] parallel execution of steps is enabled: true
2015-09-24 12:57:15,594 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] executing total steps: 2
2015-09-24 12:57:15,595 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] allocating management threads: 2
2015-09-24 12:57:15,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (1/2)
2015-09-24 12:57:15,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1443112322544_0031
2015-09-24 12:57:15,760 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:51390/proxy/application_1443112322544_0031/
2015-09-24 12:57:38,015 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0031_01_000009
2015-09-24 12:57:38,040 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0031_01_000010
2015-09-24 12:58:01,289 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0031_01_000007 is : 143
2015-09-24 12:58:01,697 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0031_01_000006 is : 143
2015-09-24 12:58:01,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0031_01_000005 is : 143
2015-09-24 12:58:01,860 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0031_01_000002 is : 143
2015-09-24 12:58:01,911 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0031_01_000004 is : 143
2015-09-24 12:58:01,918 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0031_01_000003 is : 143
2015-09-24 12:58:03,141 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] starting step: (2/2) ...condAccumulatedinterMerge
2015-09-24 12:58:03,307 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] submitted hadoop job: job_1443112322544_0032
2015-09-24 12:58:03,307 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] tracking url: http://localhost:51390/proxy/application_1443112322544_0032/
2015-09-24 12:58:25,929 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443112322544_0032_01_000008
2015-09-24 12:58:47,575 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0032_01_000005 is : 143
2015-09-24 12:58:47,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0032_01_000004 is : 143
2015-09-24 12:58:47,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0032_01_000006 is : 143
2015-09-24 12:58:47,834 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0032_01_000002 is : 143
2015-09-24 12:58:47,858 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443112322544_0032_01_000003 is : 143
2015-09-24 12:58:49,098 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-09-24 12:58:49,101 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [offset*merge2] completed in: 01:33.500
2015-09-24 12:58:49,133 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/mergepipesplatform/testHashJoinMergeIntoHashJoinStreamedAccumulatedMerge/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge