2015-07-17 14:39:26,285 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-07-17 14:39:26,302 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-07-17 14:39:26,302 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.MergePipesPlatformTest
2015-07-17 14:39:26,324 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-07-17 14:39:27,122 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-07-17 14:39:27,610 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-07-17 14:39:33,043 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-17 14:39:33,256 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-17 14:39:33,493 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-17 14:39:33,689 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-07-17 14:39:50,802 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-07-17 14:39:50,923 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:39:50,924 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:39:50,931 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 13FAAD368F394F97922FD12236E184CA
2015-07-17 14:39:51,052 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 2.7.0
2015-07-17 14:39:51,053 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-07-17 14:39:51,055 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:39:51,055 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:39:51,055 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge"]
2015-07-17 14:39:51,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-07-17 14:39:51,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-07-17 14:39:51,056 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-07-17 14:39:51,057 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...pipesplatform/simplemerge
2015-07-17 14:39:51,975 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1437169185292_0001
2015-07-17 14:39:51,975 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0001/
2015-07-17 14:40:11,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0001_01_000003 is : 143
2015-07-17 14:40:12,048 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0001_01_000004 is : 143
2015-07-17 14:40:12,130 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0001_01_000006 is : 143
2015-07-17 14:40:12,262 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0001_01_000007 is : 143
2015-07-17 14:40:12,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0001_01_000002 is : 143
2015-07-17 14:40:12,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0001_01_000005 is : 143
2015-07-17 14:40:13,735 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemerge/_temporary
2015-07-17 14:40:13,833 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/simplemerge
2015-07-17 14:40:13,912 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:40:13,912 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:40:14,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-07-17 14:40:14,016 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:40:14,017 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:40:14,017 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:40:14,017 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge"]
2015-07-17 14:40:14,018 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] parallel execution is enabled: true
2015-07-17 14:40:14,018 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting jobs: 3
2015-07-17 14:40:14,018 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] allocating threads: 3
2015-07-17 14:40:14,019 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-07-17 14:40:14,177 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1437169185292_0002
2015-07-17 14:40:14,177 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0002/
2015-07-17 14:40:32,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0002_01_000003 is : 143
2015-07-17 14:40:32,387 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0002_01_000006 is : 143
2015-07-17 14:40:32,576 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0002_01_000002 is : 143
2015-07-17 14:40:32,844 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0002_01_000005 is : 143
2015-07-17 14:40:32,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0002_01_000004 is : 143
2015-07-17 14:40:32,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0002_01_000007 is : 143
2015-07-17 14:40:34,222 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-07-17 14:40:34,373 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1437169185292_0003
2015-07-17 14:40:34,373 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0003/
2015-07-17 14:40:52,944 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0003_01_000005 is : 143
2015-07-17 14:40:52,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0003_01_000007 is : 143
2015-07-17 14:40:53,314 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0003_01_000003 is : 143
2015-07-17 14:40:53,347 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0003_01_000002 is : 143
2015-07-17 14:40:53,459 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0003_01_000004 is : 143
2015-07-17 14:40:53,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0003_01_000006 is : 143
2015-07-17 14:40:54,819 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-07-17 14:40:54,932 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1437169185292_0004
2015-07-17 14:40:54,933 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0004/
2015-07-17 14:41:11,886 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0004_01_000003 is : 143
2015-07-17 14:41:11,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0004_01_000002 is : 143
2015-07-17 14:41:12,089 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0004_01_000004 is : 143
2015-07-17 14:41:12,191 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0004_01_000005 is : 143
2015-07-17 14:41:13,104 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0004_01_000006 is : 143
2015-07-17 14:41:14,314 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge/_temporary
2015-07-17 14:41:14,357 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatedinterMerge
2015-07-17 14:41:14,411 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:41:14,411 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:41:14,472 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-07-17 14:41:14,472 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:41:14,472 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:41:14,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:41:14,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge"]
2015-07-17 14:41:14,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] parallel execution is enabled: true
2015-07-17 14:41:14,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting jobs: 3
2015-07-17 14:41:14,473 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] allocating threads: 3
2015-07-17 14:41:14,475 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-07-17 14:41:14,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1437169185292_0005
2015-07-17 14:41:14,629 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0005/
2015-07-17 14:41:34,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0005_01_000003 is : 143
2015-07-17 14:41:34,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0005_01_000007 is : 143
2015-07-17 14:41:34,291 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0005_01_000006 is : 143
2015-07-17 14:41:34,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0005_01_000002 is : 143
2015-07-17 14:41:34,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0005_01_000005 is : 143
2015-07-17 14:41:34,657 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0005_01_000004 is : 143
2015-07-17 14:41:35,867 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-07-17 14:41:35,945 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) For more information, please enable DEBUG log level on org.apache.hadoop.hdfs.server.blockmanagement.BlockPlacementPolicy
2015-07-17 14:41:35,946 WARN protocol.BlockStoragePolicy (BlockStoragePolicy.java:chooseStorageTypes(160)) - Failed to place enough replicas: expected size is 1 but only 0 storage types can be selected (replication=4, selected=[], unavailable=[DISK], removed=[DISK], policy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]})
2015-07-17 14:41:35,946 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(383)) - Failed to place enough replicas, still in need of 1 to reach 4 (unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}, newBlock=true) All required storage types are unavailable: unavailableStorages=[DISK], storagePolicy=BlockStoragePolicy{HOT:7, storageTypes=[DISK], creationFallbacks=[], replicationFallbacks=[ARCHIVE]}
2015-07-17 14:41:36,014 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1437169185292_0006
2015-07-17 14:41:36,015 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0006/
2015-07-17 14:42:00,913 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000009 is : 143
2015-07-17 14:42:01,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000008 is : 143
2015-07-17 14:42:01,509 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000003 is : 143
2015-07-17 14:42:01,604 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000006 is : 143
2015-07-17 14:42:01,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000005 is : 143
2015-07-17 14:42:01,755 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000007 is : 143
2015-07-17 14:42:01,783 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000002 is : 143
2015-07-17 14:42:01,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000004 is : 143
2015-07-17 14:42:02,534 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0006_01_000010 is : 143
2015-07-17 14:42:03,736 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-07-17 14:42:03,864 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1437169185292_0007
2015-07-17 14:42:03,864 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0007/
2015-07-17 14:42:28,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000008 is : 143
2015-07-17 14:42:28,612 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000007 is : 143
2015-07-17 14:42:28,790 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000009 is : 143
2015-07-17 14:42:29,084 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000004 is : 143
2015-07-17 14:42:29,192 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000003 is : 143
2015-07-17 14:42:29,226 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000005 is : 143
2015-07-17 14:42:29,295 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000006 is : 143
2015-07-17 14:42:29,346 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000010 is : 143
2015-07-17 14:42:29,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0007_01_000002 is : 143
2015-07-17 14:42:30,733 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge/_temporary
2015-07-17 14:42:30,765 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamedinterMerge
2015-07-17 14:42:30,821 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:42:30,822 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:42:30,840 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting
2015-07-17 14:42:30,840 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:42:30,840 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:42:30,840 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:42:30,841 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree"]
2015-07-17 14:42:30,841 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] parallel execution is enabled: true
2015-07-17 14:42:30,841 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] starting jobs: 1
2015-07-17 14:42:30,841 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge] allocating threads: 1
2015-07-17 14:42:30,842 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] starting step: (1/1) ...platform/simplemergethree
2015-07-17 14:42:30,988 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] submitted hadoop job: job_1437169185292_0008
2015-07-17 14:42:30,988 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0008/
2015-07-17 14:42:55,159 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000006 is : 143
2015-07-17 14:42:55,401 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000007 is : 143
2015-07-17 14:42:55,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000009 is : 143
2015-07-17 14:42:55,648 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000008 is : 143
2015-07-17 14:42:55,822 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000002 is : 143
2015-07-17 14:42:55,855 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000003 is : 143
2015-07-17 14:42:55,934 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000010 is : 143
2015-07-17 14:42:56,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000005 is : 143
2015-07-17 14:42:56,936 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0008_01_000004 is : 143
2015-07-17 14:42:58,137 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethree/_temporary
2015-07-17 14:42:58,172 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethree
2015-07-17 14:42:58,229 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:42:58,229 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:42:58,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting
2015-07-17 14:42:58,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:42:58,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:42:58,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:42:58,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge"]
2015-07-17 14:42:58,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] parallel execution is enabled: true
2015-07-17 14:42:58,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] starting jobs: 2
2015-07-17 14:42:58,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge1*offset*offset] allocating threads: 2
2015-07-17 14:42:58,275 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (2/2)
2015-07-17 14:42:58,426 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1437169185292_0009
2015-07-17 14:42:58,426 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0009/
2015-07-17 14:43:17,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0009_01_000003 is : 143
2015-07-17 14:43:17,538 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0009_01_000002 is : 143
2015-07-17 14:43:17,848 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0009_01_000006 is : 143
2015-07-17 14:43:17,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0009_01_000004 is : 143
2015-07-17 14:43:18,083 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0009_01_000005 is : 143
2015-07-17 14:43:18,178 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0009_01_000007 is : 143
2015-07-17 14:43:19,372 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] starting step: (1/2) ...econdStreamednoInterMerge
2015-07-17 14:43:19,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] submitted hadoop job: job_1437169185292_0010
2015-07-17 14:43:19,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge1*offset*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0010/
2015-07-17 14:43:38,049 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0010_01_000007 is : 143
2015-07-17 14:43:38,376 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0010_01_000002 is : 143
2015-07-17 14:43:38,485 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0010_01_000006 is : 143
2015-07-17 14:43:38,533 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0010_01_000005 is : 143
2015-07-17 14:43:38,760 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0010_01_000003 is : 143
2015-07-17 14:43:38,839 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0010_01_000004 is : 143
2015-07-17 14:43:40,046 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge/_temporary
2015-07-17 14:43:40,073 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondStreamednoInterMerge
2015-07-17 14:43:40,120 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:43:40,121 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:43:40,136 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain"]
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 1
2015-07-17 14:43:40,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 1
2015-07-17 14:43:40,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...orm/simplemergethreechain
2015-07-17 14:43:40,268 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1437169185292_0011
2015-07-17 14:43:40,268 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0011/
2015-07-17 14:44:05,272 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000002 is : 143
2015-07-17 14:44:05,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000003 is : 143
2015-07-17 14:44:05,814 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000005 is : 143
2015-07-17 14:44:06,005 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000009 is : 143
2015-07-17 14:44:06,076 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000006 is : 143
2015-07-17 14:44:06,138 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000008 is : 143
2015-07-17 14:44:06,180 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000004 is : 143
2015-07-17 14:44:06,238 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000010 is : 143
2015-07-17 14:44:06,373 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0011_01_000007 is : 143
2015-07-17 14:44:07,639 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechain/_temporary
2015-07-17 14:44:07,680 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechain
2015-07-17 14:44:07,761 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:44:07,761 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:44:07,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-07-17 14:44:07,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:44:07,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:44:07,836 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:44:07,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge"]
2015-07-17 14:44:07,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] parallel execution is enabled: true
2015-07-17 14:44:07,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting jobs: 3
2015-07-17 14:44:07,837 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] allocating threads: 3
2015-07-17 14:44:07,839 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-07-17 14:44:07,996 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1437169185292_0012
2015-07-17 14:44:07,996 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0012/
2015-07-17 14:44:32,772 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0012_01_000006 is : 143
2015-07-17 14:44:33,006 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0012_01_000007 is : 143
2015-07-17 14:44:33,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0012_01_000003 is : 143
2015-07-17 14:44:33,455 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0012_01_000002 is : 143
2015-07-17 14:44:33,667 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0012_01_000004 is : 143
2015-07-17 14:44:33,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0012_01_000005 is : 143
2015-07-17 14:44:35,036 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-07-17 14:44:35,189 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1437169185292_0013
2015-07-17 14:44:35,189 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0013/
2015-07-17 14:44:55,788 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0013_01_000004 is : 143
2015-07-17 14:44:56,002 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0013_01_000003 is : 143
2015-07-17 14:44:56,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0013_01_000002 is : 143
2015-07-17 14:44:56,327 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0013_01_000007 is : 143
2015-07-17 14:44:56,366 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0013_01_000006 is : 143
2015-07-17 14:44:56,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0013_01_000005 is : 143
2015-07-17 14:44:57,743 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-07-17 14:44:57,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1437169185292_0014
2015-07-17 14:44:57,869 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0014/
2015-07-17 14:45:15,439 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0014_01_000005 is : 143
2015-07-17 14:45:15,629 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0014_01_000003 is : 143
2015-07-17 14:45:15,816 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0014_01_000006 is : 143
2015-07-17 14:45:15,886 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0014_01_000004 is : 143
2015-07-17 14:45:16,037 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0014_01_000002 is : 143
2015-07-17 14:45:17,268 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge/_temporary
2015-07-17 14:45:17,292 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatednoInterMerge
2015-07-17 14:45:17,345 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:45:17,346 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:45:17,365 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-07-17 14:45:17,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:45:17,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged"]
2015-07-17 14:45:17,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-07-17 14:45:17,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 1
2015-07-17 14:45:17,366 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 1
2015-07-17 14:45:17,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) ...latform/splitsourcemerged
2015-07-17 14:45:17,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1437169185292_0015
2015-07-17 14:45:17,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0015/
2015-07-17 14:45:32,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0015_01_000003 is : 143
2015-07-17 14:45:32,747 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0015_01_000004 is : 143
2015-07-17 14:45:33,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0015_01_000005 is : 143
2015-07-17 14:45:33,063 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0015_01_000002 is : 143
2015-07-17 14:45:34,268 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemerged/_temporary
2015-07-17 14:45:34,293 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemerged
2015-07-17 14:45:34,328 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:45:34,329 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:45:34,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-07-17 14:45:34,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:45:34,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:45:34,359 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:45:34,360 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed"]
2015-07-17 14:45:34,360 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-07-17 14:45:34,360 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 2
2015-07-17 14:45:34,360 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 2
2015-07-17 14:45:34,361 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (2/2)
2015-07-17 14:45:34,483 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1437169185292_0016
2015-07-17 14:45:34,484 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0016/
2015-07-17 14:45:53,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0016_01_000002 is : 143
2015-07-17 14:45:53,715 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0016_01_000006 is : 143
2015-07-17 14:45:53,717 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0016_01_000003 is : 143
2015-07-17 14:45:53,879 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0016_01_000004 is : 143
2015-07-17 14:45:54,173 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0016_01_000007 is : 143
2015-07-17 14:45:54,206 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0016_01_000005 is : 143
2015-07-17 14:45:55,371 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/2) ...mergeintohashjoinstreamed
2015-07-17 14:45:55,491 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1437169185292_0017
2015-07-17 14:45:55,491 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0017/
2015-07-17 14:46:14,170 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0017_01_000007 is : 143
2015-07-17 14:46:14,326 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0017_01_000005 is : 143
2015-07-17 14:46:14,534 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0017_01_000003 is : 143
2015-07-17 14:46:14,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0017_01_000006 is : 143
2015-07-17 14:46:14,722 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0017_01_000002 is : 143
2015-07-17 14:46:14,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0017_01_000004 is : 143
2015-07-17 14:46:16,076 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed/_temporary
2015-07-17 14:46:16,108 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinstreamed
2015-07-17 14:46:16,145 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:46:16,145 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:46:16,151 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergefail
2015-07-17 14:46:16,171 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:46:16,172 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:46:16,190 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-07-17 14:46:16,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:46:16,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:46:16,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:46:16,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup"]
2015-07-17 14:46:16,191 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-07-17 14:46:16,192 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 1
2015-07-17 14:46:16,192 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 1
2015-07-17 14:46:16,194 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/1) ...implemergethreechaingroup
2015-07-17 14:46:16,339 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1437169185292_0018
2015-07-17 14:46:16,339 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0018/
2015-07-17 14:46:42,581 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000010 is : 143
2015-07-17 14:46:42,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000004 is : 143
2015-07-17 14:46:42,875 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000006 is : 143
2015-07-17 14:46:42,883 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000002 is : 143
2015-07-17 14:46:43,008 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000008 is : 143
2015-07-17 14:46:43,047 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000007 is : 143
2015-07-17 14:46:43,128 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000003 is : 143
2015-07-17 14:46:43,213 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000005 is : 143
2015-07-17 14:46:43,248 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000009 is : 143
2015-07-17 14:46:49,651 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0018_01_000011 is : 143
2015-07-17 14:46:50,816 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup/_temporary
2015-07-17 14:46:50,834 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaingroup
2015-07-17 14:46:50,869 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:46:50,870 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:46:50,925 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting
2015-07-17 14:46:50,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:46:50,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:46:50,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:46:50,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge"]
2015-07-17 14:46:50,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] parallel execution is enabled: true
2015-07-17 14:46:50,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] starting jobs: 3
2015-07-17 14:46:50,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge1*offset] allocating threads: 3
2015-07-17 14:46:50,931 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (3/3)
2015-07-17 14:46:51,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1437169185292_0019
2015-07-17 14:46:51,091 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0019/
2015-07-17 14:47:11,272 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0019_01_000002 is : 143
2015-07-17 14:47:11,676 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0019_01_000003 is : 143
2015-07-17 14:47:11,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0019_01_000007 is : 143
2015-07-17 14:47:11,899 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0019_01_000006 is : 143
2015-07-17 14:47:12,117 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0019_01_000005 is : 143
2015-07-17 14:47:12,198 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0019_01_000004 is : 143
2015-07-17 14:47:13,383 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (2/3)
2015-07-17 14:47:13,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1437169185292_0020
2015-07-17 14:47:13,503 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0020/
2015-07-17 14:47:30,422 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0020_01_000002 is : 143
2015-07-17 14:47:30,526 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0020_01_000005 is : 143
2015-07-17 14:47:30,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0020_01_000003 is : 143
2015-07-17 14:47:30,660 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0020_01_000006 is : 143
2015-07-17 14:47:30,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0020_01_000004 is : 143
2015-07-17 14:47:32,067 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] starting step: (1/3) ...econdStreamednoInterMerge
2015-07-17 14:47:32,187 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] submitted hadoop job: job_1437169185292_0021
2015-07-17 14:47:32,187 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge1*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0021/
2015-07-17 14:47:50,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0021_01_000006 is : 143
2015-07-17 14:47:50,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0021_01_000002 is : 143
2015-07-17 14:47:50,713 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0021_01_000004 is : 143
2015-07-17 14:47:50,886 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0021_01_000005 is : 143
2015-07-17 14:47:50,940 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0021_01_000003 is : 143
2015-07-17 14:47:52,218 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge/_temporary
2015-07-17 14:47:52,241 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamednoInterMerge
2015-07-17 14:47:52,278 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:47:52,279 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:47:52,309 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-07-17 14:47:52,309 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:47:52,309 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:47:52,310 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:47:52,310 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed"]
2015-07-17 14:47:52,310 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-07-17 14:47:52,310 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 1
2015-07-17 14:47:52,310 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 1
2015-07-17 14:47:52,311 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...mergeintohashjoinstreamed
2015-07-17 14:47:52,429 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1437169185292_0022
2015-07-17 14:47:52,429 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0022/
2015-07-17 14:48:13,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0022_01_000007 is : 143
2015-07-17 14:48:13,355 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0022_01_000004 is : 143
2015-07-17 14:48:13,469 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0022_01_000006 is : 143
2015-07-17 14:48:13,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0022_01_000003 is : 143
2015-07-17 14:48:13,673 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0022_01_000002 is : 143
2015-07-17 14:48:13,727 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0022_01_000005 is : 143
2015-07-17 14:48:14,927 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed/_temporary
2015-07-17 14:48:14,954 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinstreamed
2015-07-17 14:48:14,994 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:48:14,994 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:48:15,025 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting
2015-07-17 14:48:15,025 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:48:15,025 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:48:15,025 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:48:15,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup"]
2015-07-17 14:48:15,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] parallel execution is enabled: true
2015-07-17 14:48:15,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] starting jobs: 1
2015-07-17 14:48:15,026 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge*offset] allocating threads: 1
2015-07-17 14:48:15,027 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] starting step: (1/1) ...plemergethreechaincogroup
2015-07-17 14:48:15,142 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] submitted hadoop job: job_1437169185292_0023
2015-07-17 14:48:15,142 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0023/
2015-07-17 14:48:42,477 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000004 is : 143
2015-07-17 14:48:42,608 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000003 is : 143
2015-07-17 14:48:42,675 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000002 is : 143
2015-07-17 14:48:42,754 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000007 is : 143
2015-07-17 14:48:42,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000009 is : 143
2015-07-17 14:48:42,850 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000008 is : 143
2015-07-17 14:48:42,967 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000006 is : 143
2015-07-17 14:48:43,053 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000005 is : 143
2015-07-17 14:48:43,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000010 is : 143
2015-07-17 14:48:48,475 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0023_01_000011 is : 143
2015-07-17 14:48:49,669 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup/_temporary
2015-07-17 14:48:49,686 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/simplemergethreechaincogroup
2015-07-17 14:48:49,709 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:48:49,709 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:48:49,736 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting
2015-07-17 14:48:49,736 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:48:49,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup"]
2015-07-17 14:48:49,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] parallel execution is enabled: true
2015-07-17 14:48:49,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] starting jobs: 2
2015-07-17 14:48:49,737 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge+offset] allocating threads: 2
2015-07-17 14:48:49,739 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (2/2)
2015-07-17 14:48:49,841 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1437169185292_0024
2015-07-17 14:48:49,841 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0024/
2015-07-17 14:49:07,420 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0024_01_000006 is : 143
2015-07-17 14:49:07,568 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0024_01_000003 is : 143
2015-07-17 14:49:07,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0024_01_000005 is : 143
2015-07-17 14:49:07,742 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0024_01_000002 is : 143
2015-07-17 14:49:07,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0024_01_000004 is : 143
2015-07-17 14:49:12,807 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0024_01_000007 is : 143
2015-07-17 14:49:13,982 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] starting step: (1/2) .../samemergethreechaingroup
2015-07-17 14:49:14,115 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] submitted hadoop job: job_1437169185292_0025
2015-07-17 14:49:14,115 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge+offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0025/
2015-07-17 14:49:33,588 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000007 is : 143
2015-07-17 14:49:33,687 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000003 is : 143
2015-07-17 14:49:33,760 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000005 is : 143
2015-07-17 14:49:33,794 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000002 is : 143
2015-07-17 14:49:33,840 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000006 is : 143
2015-07-17 14:49:33,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000004 is : 143
2015-07-17 14:49:38,820 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0025_01_000008 is : 143
2015-07-17 14:49:40,005 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/samemergethreechaingroup/_temporary
2015-07-17 14:49:40,022 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/samemergethreechaingroup
2015-07-17 14:49:40,047 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:49:40,048 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:49:40,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting
2015-07-17 14:49:40,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:49:40,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:49:40,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:49:40,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge"]
2015-07-17 14:49:40,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] parallel execution is enabled: true
2015-07-17 14:49:40,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] starting jobs: 3
2015-07-17 14:49:40,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merge2*offset] allocating threads: 3
2015-07-17 14:49:40,108 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (3/3)
2015-07-17 14:49:40,245 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1437169185292_0026
2015-07-17 14:49:40,245 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0026/
2015-07-17 14:49:58,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0026_01_000006 is : 143
2015-07-17 14:49:58,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0026_01_000004 is : 143
2015-07-17 14:49:59,208 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0026_01_000002 is : 143
2015-07-17 14:49:59,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0026_01_000007 is : 143
2015-07-17 14:49:59,309 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0026_01_000003 is : 143
2015-07-17 14:49:59,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0026_01_000005 is : 143
2015-07-17 14:50:00,714 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (2/3)
2015-07-17 14:50:00,845 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1437169185292_0027
2015-07-17 14:50:00,846 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0027/
2015-07-17 14:50:22,228 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0027_01_000003 is : 143
2015-07-17 14:50:22,323 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0027_01_000007 is : 143
2015-07-17 14:50:22,632 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0027_01_000002 is : 143
2015-07-17 14:50:22,898 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0027_01_000004 is : 143
2015-07-17 14:50:23,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0027_01_000006 is : 143
2015-07-17 14:50:23,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0027_01_000005 is : 143
2015-07-17 14:50:24,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] starting step: (1/3) ...dsecondStreamedinterMerge
2015-07-17 14:50:24,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] submitted hadoop job: job_1437169185292_0028
2015-07-17 14:50:24,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merge2*offset] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0028/
2015-07-17 14:50:45,386 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0028_01_000002 is : 143
2015-07-17 14:50:45,493 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0028_01_000003 is : 143
2015-07-17 14:50:45,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0028_01_000007 is : 143
2015-07-17 14:50:45,981 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0028_01_000006 is : 143
2015-07-17 14:50:46,184 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0028_01_000004 is : 143
2015-07-17 14:50:46,260 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0028_01_000005 is : 143
2015-07-17 14:50:47,453 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge/_temporary
2015-07-17 14:50:47,484 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondStreamedinterMerge
2015-07-17 14:50:47,533 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:50:47,534 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:50:47,550 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated"]
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] parallel execution is enabled: true
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting jobs: 2
2015-07-17 14:50:47,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] allocating threads: 2
2015-07-17 14:50:47,553 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-07-17 14:50:47,684 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1437169185292_0029
2015-07-17 14:50:47,684 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0029/
2015-07-17 14:51:10,193 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0029_01_000005 is : 143
2015-07-17 14:51:10,372 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0029_01_000007 is : 143
2015-07-17 14:51:10,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0029_01_000003 is : 143
2015-07-17 14:51:10,596 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0029_01_000002 is : 143
2015-07-17 14:51:10,776 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0029_01_000004 is : 143
2015-07-17 14:51:10,974 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0029_01_000006 is : 143
2015-07-17 14:51:12,184 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-07-17 14:51:12,333 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1437169185292_0030
2015-07-17 14:51:12,333 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0030/
2015-07-17 14:51:34,150 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0030_01_000002 is : 143
2015-07-17 14:51:34,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0030_01_000003 is : 143
2015-07-17 14:51:34,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0030_01_000006 is : 143
2015-07-17 14:51:34,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0030_01_000005 is : 143
2015-07-17 14:51:34,565 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0030_01_000004 is : 143
2015-07-17 14:51:35,755 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated/_temporary
2015-07-17 14:51:35,782 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/mergeintohashjoinaccumulated
2015-07-17 14:51:35,824 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:51:35,825 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:51:35,850 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting
2015-07-17 14:51:35,850 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/apache.10.txt"]
2015-07-17 14:51:35,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex"]
2015-07-17 14:51:35,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] parallel execution is enabled: true
2015-07-17 14:51:35,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] starting jobs: 1
2015-07-17 14:51:35,851 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [merged] allocating threads: 1
2015-07-17 14:51:35,852 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] starting step: (1/1) .../splitsourcemergedcomplex
2015-07-17 14:51:35,976 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] submitted hadoop job: job_1437169185292_0031
2015-07-17 14:51:35,976 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [merged] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0031/
2015-07-17 14:51:52,703 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0031_01_000002 is : 143
2015-07-17 14:51:52,824 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0031_01_000003 is : 143
2015-07-17 14:51:53,093 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0031_01_000004 is : 143
2015-07-17 14:51:53,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0031_01_000005 is : 143
2015-07-17 14:51:54,411 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex/_temporary
2015-07-17 14:51:54,442 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/splitsourcemergedcomplex
2015-07-17 14:51:54,487 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:51:54,488 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:51:54,511 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting
2015-07-17 14:51:54,511 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:51:54,511 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:51:54,511 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:51:54,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated"]
2015-07-17 14:51:54,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] parallel execution is enabled: true
2015-07-17 14:51:54,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] starting jobs: 2
2015-07-17 14:51:54,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge] allocating threads: 2
2015-07-17 14:51:54,514 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (2/2)
2015-07-17 14:51:54,679 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1437169185292_0032
2015-07-17 14:51:54,679 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0032/
2015-07-17 14:52:19,071 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0032_01_000007 is : 143
2015-07-17 14:52:19,417 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0032_01_000003 is : 143
2015-07-17 14:52:19,601 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0032_01_000002 is : 143
2015-07-17 14:52:19,731 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0032_01_000004 is : 143
2015-07-17 14:52:19,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0032_01_000006 is : 143
2015-07-17 14:52:19,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0032_01_000005 is : 143
2015-07-17 14:52:21,156 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] starting step: (1/2) ...geintohashjoinaccumulated
2015-07-17 14:52:21,329 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] submitted hadoop job: job_1437169185292_0033
2015-07-17 14:52:21,329 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0033/
2015-07-17 14:52:42,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0033_01_000002 is : 143
2015-07-17 14:52:42,348 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0033_01_000003 is : 143
2015-07-17 14:52:42,356 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0033_01_000006 is : 143
2015-07-17 14:52:42,411 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0033_01_000004 is : 143
2015-07-17 14:52:42,779 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0033_01_000005 is : 143
2015-07-17 14:52:43,985 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated/_temporary
2015-07-17 14:52:44,016 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/hashjoinintomergeintohashjoinaccumulated
2015-07-17 14:52:44,053 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:52:44,053 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:52:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting
2015-07-17 14:52:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:52:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:52:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:52:44,099 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge"]
2015-07-17 14:52:44,100 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] parallel execution is enabled: true
2015-07-17 14:52:44,100 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] starting jobs: 3
2015-07-17 14:52:44,100 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*offset*merge1] allocating threads: 3
2015-07-17 14:52:44,102 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (3/3)
2015-07-17 14:52:44,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1437169185292_0034
2015-07-17 14:52:44,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0034/
2015-07-17 14:53:05,465 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0034_01_000002 is : 143
2015-07-17 14:53:05,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0034_01_000003 is : 143
2015-07-17 14:53:05,862 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0034_01_000006 is : 143
2015-07-17 14:53:05,916 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0034_01_000005 is : 143
2015-07-17 14:53:05,979 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0034_01_000007 is : 143
2015-07-17 14:53:06,096 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0034_01_000004 is : 143
2015-07-17 14:53:07,294 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (2/3)
2015-07-17 14:53:07,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1437169185292_0035
2015-07-17 14:53:07,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0035/
2015-07-17 14:53:30,761 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0035_01_000006 is : 143
2015-07-17 14:53:31,118 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0035_01_000004 is : 143
2015-07-17 14:53:31,233 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0035_01_000003 is : 143
2015-07-17 14:53:31,333 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0035_01_000002 is : 143
2015-07-17 14:53:31,556 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0035_01_000005 is : 143
2015-07-17 14:53:32,776 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] starting step: (1/3) ...ndAccumulatednoInterMerge
2015-07-17 14:53:32,897 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] submitted hadoop job: job_1437169185292_0036
2015-07-17 14:53:32,897 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*offset*merge1] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0036/
2015-07-17 14:53:51,435 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0036_01_000003 is : 143
2015-07-17 14:53:51,700 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0036_01_000004 is : 143
2015-07-17 14:53:51,849 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0036_01_000005 is : 143
2015-07-17 14:53:51,955 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0036_01_000002 is : 143
2015-07-17 14:53:52,136 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0036_01_000006 is : 143
2015-07-17 14:53:53,330 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge/_temporary
2015-07-17 14:53:53,358 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstAccumulatedsecondAccumulatednoInterMerge
2015-07-17 14:53:53,395 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-07-17 14:53:53,396 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /Users/castillo/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.0/8b73ff12892507d12477c4f1b7607a122ddc5528/cascading-hadoop2-mr1-2.7.0.jar
2015-07-17 14:53:53,435 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting
2015-07-17 14:53:53,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/upper.txt"]
2015-07-17 14:53:53,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower.txt"]
2015-07-17 14:53:53,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/classes/test/data/lower-offset.txt"]
2015-07-17 14:53:53,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge"]
2015-07-17 14:53:53,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] parallel execution is enabled: true
2015-07-17 14:53:53,436 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] starting jobs: 3
2015-07-17 14:53:53,437 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [offset*merge2] allocating threads: 3
2015-07-17 14:53:53,438 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (3/3)
2015-07-17 14:53:53,575 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1437169185292_0037
2015-07-17 14:53:53,575 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0037/
2015-07-17 14:54:14,926 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0037_01_000003 is : 143
2015-07-17 14:54:15,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0037_01_000004 is : 143
2015-07-17 14:54:15,630 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0037_01_000007 is : 143
2015-07-17 14:54:15,777 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0037_01_000002 is : 143
2015-07-17 14:54:15,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0037_01_000006 is : 143
2015-07-17 14:54:15,880 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0037_01_000005 is : 143
2015-07-17 14:54:17,086 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (2/3)
2015-07-17 14:54:17,227 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1437169185292_0038
2015-07-17 14:54:17,228 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0038/
2015-07-17 14:54:45,304 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000002 is : 143
2015-07-17 14:54:45,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000009 is : 143
2015-07-17 14:54:45,638 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000008 is : 143
2015-07-17 14:54:46,054 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000010 is : 143
2015-07-17 14:54:46,086 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000003 is : 143
2015-07-17 14:54:46,252 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000005 is : 143
2015-07-17 14:54:46,287 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000004 is : 143
2015-07-17 14:54:46,388 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000007 is : 143
2015-07-17 14:54:46,442 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0038_01_000006 is : 143
2015-07-17 14:54:47,648 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] starting step: (1/3) ...condAccumulatedinterMerge
2015-07-17 14:54:47,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] submitted hadoop job: job_1437169185292_0039
2015-07-17 14:54:47,762 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [offset*merge2] tracking url: http://Marks-MacBook.local:64127/proxy/application_1437169185292_0039/
2015-07-17 14:55:05,473 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0039_01_000006 is : 143
2015-07-17 14:55:05,690 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0039_01_000004 is : 143
2015-07-17 14:55:05,869 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0039_01_000003 is : 143
2015-07-17 14:55:06,094 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0039_01_000005 is : 143
2015-07-17 14:55:06,127 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1437169185292_0039_01_000002 is : 143
2015-07-17 14:55:07,322 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output/hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge/_temporary
2015-07-17 14:55:07,346 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /Users/castillo/code/cascading.compatibility-2.7/microsoft-hdi-3.2/build/test/output//hadoop2-mr1/mergepipesplatform/multihashjoinintomergeintohashjoinfirstStreamedsecondAccumulatedinterMerge