2015-09-24 14:48:43,672 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 14:48:43,707 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.tuple.hadoop.SerializedPipesPlatformTest, with platform: hadoop2-mr1
2015-09-24 14:48:43,732 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 14:48:55,690 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-09-24 14:48:56,271 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 14:49:00,454 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 14:49:00,783 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:49:01,031 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:49:01,254 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:49:01,482 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:49:18,616 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-09-24 14:49:18,714 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:49:18,715 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:49:18,778 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: DFF3E6D2DA3B4B728C508E34E09BE3CF
2015-09-24 14:49:18,913 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.094
2015-09-24 14:49:18,916 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:49:18,917 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:49:19,049 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 14:49:19,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:49:19,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:49:19,051 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["SequenceFile[[UNKNOWN]->['ip', 'count', 'boolean']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testSimpleGroup/serialization"]
2015-09-24 14:49:19,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:49:19,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:49:19,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:49:19,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SimpleGroup/serialization
2015-09-24 14:49:20,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120553098_0001
2015-09-24 14:49:20,203 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:52529/proxy/application_1443120553098_0001/
2015-09-24 14:50:00,921 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0001_01_000002 is : 143
2015-09-24 14:50:01,013 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0001_01_000003 is : 143
2015-09-24 14:50:01,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0001_01_000005 is : 143
2015-09-24 14:50:01,216 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0001_01_000004 is : 143
2015-09-24 14:50:20,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0001_01_000006 is : 143
2015-09-24 14:50:20,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0001_01_000007 is : 143
2015-09-24 14:50:21,747 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testSimpleGroup/serialization/_temporary
2015-09-24 14:50:21,750 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 01:02.690
2015-09-24 14:50:21,836 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testSimpleGroup/serialization
2015-09-24 14:50:21,929 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:50:21,930 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:50:22,015 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.079
2015-09-24 14:50:22,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:50:22,018 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:50:22,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:50:22,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:50:22,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:50:22,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[[UNKNOWN]->[0:7]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupWritableAsKeyValue/writablekeyvalue"]
2015-09-24 14:50:22,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:50:22,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-09-24 14:50:22,053 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-09-24 14:50:22,054 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...KeyValue/writablekeyvalue
2015-09-24 14:50:22,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0002
2015-09-24 14:50:22,296 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0002/
2015-09-24 14:50:43,416 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120553098_0002_01_000009
2015-09-24 14:50:44,311 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120553098_0002_01_000008
2015-09-24 14:51:05,785 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000003 is : 143
2015-09-24 14:51:05,922 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000004 is : 143
2015-09-24 14:51:05,982 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000007 is : 143
2015-09-24 14:51:06,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000005 is : 143
2015-09-24 14:51:06,218 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000006 is : 143
2015-09-24 14:51:06,260 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000002 is : 143
2015-09-24 14:51:26,111 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000011 is : 143
2015-09-24 14:51:26,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0002_01_000010 is : 143
2015-09-24 14:51:27,506 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupWritableAsKeyValue/writablekeyvalue/_temporary
2015-09-24 14:51:27,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:05.451
2015-09-24 14:51:27,550 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupWritableAsKeyValue/writablekeyvalue
2015-09-24 14:51:27,590 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:51:27,591 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:51:27,688 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.092
2015-09-24 14:51:27,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 14:51:27,691 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:51:27,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:51:27,727 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:51:27,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:51:27,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultNoSecondary/rawbyteskeyvalue/true/false/false/false"]
2015-09-24 14:51:27,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:51:27,728 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 14:51:27,729 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 14:51:27,730 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 14:51:27,918 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0003
2015-09-24 14:51:27,919 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0003/
2015-09-24 14:52:02,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0003_01_000002 is : 143
2015-09-24 14:52:02,804 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0003_01_000003 is : 143
2015-09-24 14:52:20,865 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0003_01_000004 is : 143
2015-09-24 14:52:22,060 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...ue/true/false/false/false
2015-09-24 14:52:22,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0004
2015-09-24 14:52:22,254 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0004/
2015-09-24 14:52:55,503 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0004_01_000002 is : 143
2015-09-24 14:53:14,098 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0004_01_000003 is : 143
2015-09-24 14:53:15,357 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultNoSecondary/rawbyteskeyvalue/true/false/false/false/_temporary
2015-09-24 14:53:15,360 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:47.624
2015-09-24 14:53:15,408 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultNoSecondary/rawbyteskeyvalue/true/false/false/false
2015-09-24 14:53:15,462 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:53:15,463 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:53:15,513 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-09-24 14:53:15,514 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:53:15,515 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:53:15,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:53:15,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:53:15,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:53:15,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupBytesWritableAsKeyValue/byteswritablekeyvalue"]
2015-09-24 14:53:15,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:53:15,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-09-24 14:53:15,543 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-09-24 14:53:15,544 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...lue/byteswritablekeyvalue
2015-09-24 14:53:15,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0005
2015-09-24 14:53:15,817 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0005/
2015-09-24 14:53:39,071 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120553098_0005_01_000009
2015-09-24 14:53:39,142 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120553098_0005_01_000010
2015-09-24 14:54:05,174 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000007 is : 143
2015-09-24 14:54:05,175 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000005 is : 143
2015-09-24 14:54:05,237 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000002 is : 143
2015-09-24 14:54:05,479 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000003 is : 143
2015-09-24 14:54:05,529 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000006 is : 143
2015-09-24 14:54:05,562 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000004 is : 143
2015-09-24 14:54:26,471 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000011 is : 143
2015-09-24 14:54:26,616 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0005_01_000012 is : 143
2015-09-24 14:54:27,902 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupBytesWritableAsKeyValue/byteswritablekeyvalue/_temporary
2015-09-24 14:54:27,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:12.356
2015-09-24 14:54:27,961 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupBytesWritableAsKeyValue/byteswritablekeyvalue
2015-09-24 14:54:28,012 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:54:28,013 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:54:28,081 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-09-24 14:54:28,082 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:54:28,083 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:54:28,108 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:54:28,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line' | cascading.tuple.coerce.BigDecimalCoerce@8c230e9, String]->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:54:28,109 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["SequenceFile[['offset', 'count' | cascading.tuple.coerce.BigDecimalCoerce@8c230e9, long]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testBigDecimal/bigdecimal"]
2015-09-24 14:54:28,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:54:28,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:54:28,110 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:54:28,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...testBigDecimal/bigdecimal
2015-09-24 14:54:28,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120553098_0006
2015-09-24 14:54:28,351 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:52529/proxy/application_1443120553098_0006/
2015-09-24 14:55:09,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0006_01_000005 is : 143
2015-09-24 14:55:09,217 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0006_01_000002 is : 143
2015-09-24 14:55:09,222 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0006_01_000003 is : 143
2015-09-24 14:55:09,278 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0006_01_000004 is : 143
2015-09-24 14:55:29,909 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0006_01_000006 is : 143
2015-09-24 14:55:30,033 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0006_01_000007 is : 143
2015-09-24 14:55:31,296 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testBigDecimal/bigdecimal/_temporary
2015-09-24 14:55:31,299 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 01:03.184
2015-09-24 14:55:31,330 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testBigDecimal/bigdecimal
2015-09-24 14:55:31,366 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:55:31,367 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:55:31,443 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.072
2015-09-24 14:55:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 14:55:31,445 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:55:31,478 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:55:31,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:55:31,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:55:31,479 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultIgnoreToken/rawbyteskeyvalue/true/true/true/false"]
2015-09-24 14:55:31,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:55:31,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 14:55:31,480 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 14:55:31,482 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 14:55:31,670 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0007
2015-09-24 14:55:31,671 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0007/
2015-09-24 14:56:09,293 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0007_01_000002 is : 143
2015-09-24 14:56:09,294 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0007_01_000003 is : 143
2015-09-24 14:56:27,056 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0007_01_000004 is : 143
2015-09-24 14:56:28,243 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...alue/true/true/true/false
2015-09-24 14:56:28,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0008
2015-09-24 14:56:28,438 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0008/
2015-09-24 14:57:02,580 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0008_01_000002 is : 143
2015-09-24 14:57:21,178 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0008_01_000003 is : 143
2015-09-24 14:57:22,418 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultIgnoreToken/rawbyteskeyvalue/true/true/true/false/_temporary
2015-09-24 14:57:22,421 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:50.935
2015-09-24 14:57:22,468 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultIgnoreToken/rawbyteskeyvalue/true/true/true/false
2015-09-24 14:57:22,508 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:57:22,508 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:57:22,598 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.085
2015-09-24 14:57:22,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 14:57:22,605 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:57:22,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:57:22,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:57:22,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:57:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValue/rawbyteskeyvalue/false/true/false/false"]
2015-09-24 14:57:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:57:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 14:57:22,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 14:57:22,646 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 14:57:22,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0009
2015-09-24 14:57:22,824 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0009/
2015-09-24 14:57:58,392 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0009_01_000003 is : 143
2015-09-24 14:57:58,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0009_01_000002 is : 143
2015-09-24 14:58:17,143 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0009_01_000004 is : 143
2015-09-24 14:58:18,323 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...ue/false/true/false/false
2015-09-24 14:58:18,509 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0010
2015-09-24 14:58:18,510 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0010/
2015-09-24 14:58:52,992 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0010_01_000002 is : 143
2015-09-24 14:59:11,564 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0010_01_000003 is : 143
2015-09-24 14:59:12,797 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValue/rawbyteskeyvalue/false/true/false/false/_temporary
2015-09-24 14:59:12,800 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:50.138
2015-09-24 14:59:12,840 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValue/rawbyteskeyvalue/false/true/false/false
2015-09-24 14:59:12,875 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:59:12,876 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:59:12,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.083
2015-09-24 14:59:12,965 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 14:59:12,966 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:59:12,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:59:12,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:59:12,993 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:59:12,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultIgnoreTokenCompositeGrouping/rawbyteskeyvalue/true/true/true/true"]
2015-09-24 14:59:12,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:59:12,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 14:59:12,994 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 14:59:12,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 14:59:13,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0011
2015-09-24 14:59:13,170 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0011/
2015-09-24 14:59:48,051 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0011_01_000002 is : 143
2015-09-24 14:59:48,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0011_01_000003 is : 143
2015-09-24 15:00:05,957 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0011_01_000004 is : 143
2015-09-24 15:00:07,135 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...value/true/true/true/true
2015-09-24 15:00:07,314 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0012
2015-09-24 15:00:07,314 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0012/
2015-09-24 15:00:40,893 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0012_01_000002 is : 143
2015-09-24 15:00:59,147 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0012_01_000003 is : 143
2015-09-24 15:01:00,378 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultIgnoreTokenCompositeGrouping/rawbyteskeyvalue/true/true/true/true/_temporary
2015-09-24 15:01:00,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:47.380
2015-09-24 15:01:00,419 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultIgnoreTokenCompositeGrouping/rawbyteskeyvalue/true/true/true/true
2015-09-24 15:01:00,453 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 15:01:00,454 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 15:01:00,526 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.066
2015-09-24 15:01:00,531 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 15:01:00,532 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 15:01:00,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 15:01:00,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 15:01:00,567 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 15:01:00,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueNoSecondary/rawbyteskeyvalue/false/false/false/false"]
2015-09-24 15:01:00,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 15:01:00,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 15:01:00,568 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 15:01:00,570 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 15:01:00,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0013
2015-09-24 15:01:00,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0013/
2015-09-24 15:01:36,728 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0013_01_000002 is : 143
2015-09-24 15:01:36,838 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0013_01_000003 is : 143
2015-09-24 15:01:54,924 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0013_01_000004 is : 143
2015-09-24 15:01:56,096 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...e/false/false/false/false
2015-09-24 15:01:56,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0014
2015-09-24 15:01:56,294 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0014/
2015-09-24 15:02:29,419 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0014_01_000002 is : 143
2015-09-24 15:02:48,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0014_01_000003 is : 143
2015-09-24 15:02:49,786 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueNoSecondary/rawbyteskeyvalue/false/false/false/false/_temporary
2015-09-24 15:02:49,788 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:49.213
2015-09-24 15:02:49,835 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueNoSecondary/rawbyteskeyvalue/false/false/false/false
2015-09-24 15:02:49,869 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 15:02:49,869 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 15:02:49,934 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-09-24 15:02:49,936 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 15:02:49,936 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 15:02:49,963 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 15:02:49,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 15:02:49,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 15:02:49,964 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefault/rawbyteskeyvalue/true/true/false/false"]
2015-09-24 15:02:49,965 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 15:02:49,965 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 15:02:49,965 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 15:02:49,967 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 15:02:50,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0015
2015-09-24 15:02:50,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0015/
2015-09-24 15:03:25,714 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0015_01_000002 is : 143
2015-09-24 15:03:25,832 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0015_01_000003 is : 143
2015-09-24 15:03:43,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0015_01_000004 is : 143
2015-09-24 15:03:44,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...lue/true/true/false/false
2015-09-24 15:03:44,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0016
2015-09-24 15:03:44,429 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0016/
2015-09-24 15:04:17,398 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0016_01_000002 is : 143
2015-09-24 15:04:35,296 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0016_01_000003 is : 143
2015-09-24 15:04:36,524 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefault/rawbyteskeyvalue/true/true/false/false/_temporary
2015-09-24 15:04:36,527 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:46.556
2015-09-24 15:04:36,568 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefault/rawbyteskeyvalue/true/true/false/false
2015-09-24 15:04:36,602 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 15:04:36,602 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 15:04:36,639 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 15:04:36,643 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 15:04:36,644 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 15:04:36,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 15:04:36,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 15:04:36,657 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["SequenceFile[[UNKNOWN]->['bytes', 'count']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testSimpleGroupOnBytes/grouponbytes"]
2015-09-24 15:04:36,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 15:04:36,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 15:04:36,658 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 15:04:36,659 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...GroupOnBytes/grouponbytes
2015-09-24 15:04:36,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120553098_0017
2015-09-24 15:04:36,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:52529/proxy/application_1443120553098_0017/
2015-09-24 15:05:15,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0017_01_000004 is : 143
2015-09-24 15:05:15,264 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0017_01_000005 is : 143
2015-09-24 15:05:15,392 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0017_01_000002 is : 143
2015-09-24 15:05:15,436 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0017_01_000003 is : 143
2015-09-24 15:05:35,500 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0017_01_000006 is : 143
2015-09-24 15:05:35,553 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0017_01_000007 is : 143
2015-09-24 15:05:36,820 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testSimpleGroupOnBytes/grouponbytes/_temporary
2015-09-24 15:05:36,823 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 01:00.161
2015-09-24 15:05:36,854 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testSimpleGroupOnBytes/grouponbytes
2015-09-24 15:05:36,888 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 15:05:36,888 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 15:05:36,955 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.062
2015-09-24 15:05:36,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 15:05:36,957 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 15:05:36,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 15:05:36,989 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 15:05:36,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 15:05:36,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[['num', 'char', 'group', 'value', 'num2', 'char2', 'group2', 'value2']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultNoSecondaryCompositeGrouping/rawbyteskeyvalue/true/false/false/true"]
2015-09-24 15:05:36,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 15:05:36,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 2
2015-09-24 15:05:36,990 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 2
2015-09-24 15:05:36,992 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/2)
2015-09-24 15:05:37,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0018
2015-09-24 15:05:37,166 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0018/
2015-09-24 15:06:11,935 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0018_01_000002 is : 143
2015-09-24 15:06:12,000 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0018_01_000003 is : 143
2015-09-24 15:06:30,189 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0018_01_000004 is : 143
2015-09-24 15:06:31,360 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (2/2) ...lue/true/false/false/true
2015-09-24 15:06:31,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0019
2015-09-24 15:06:31,542 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0019/
2015-09-24 15:07:04,774 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0019_01_000002 is : 143
2015-09-24 15:07:22,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0019_01_000003 is : 143
2015-09-24 15:07:23,730 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultNoSecondaryCompositeGrouping/rawbyteskeyvalue/true/false/false/true/_temporary
2015-09-24 15:07:23,733 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:46.736
2015-09-24 15:07:23,772 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupRawAsKeyValueDefaultNoSecondaryCompositeGrouping/rawbyteskeyvalue/true/false/false/true
2015-09-24 15:07:23,813 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 15:07:23,814 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 15:07:23,853 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-09-24 15:07:23,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 15:07:23,855 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 15:07:23,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 15:07:23,874 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 15:07:23,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 15:07:23,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["SequenceFile[[UNKNOWN]->[0:9]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupSpillCustomWritable/customerwritable"]
2015-09-24 15:07:23,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 15:07:23,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-09-24 15:07:23,875 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-09-24 15:07:23,879 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...Writable/customerwritable
2015-09-24 15:07:24,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120553098_0020
2015-09-24 15:07:24,050 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:52529/proxy/application_1443120553098_0020/
2015-09-24 15:07:45,380 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120553098_0020_01_000009
2015-09-24 15:07:45,526 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120553098_0020_01_000010
2015-09-24 15:08:08,046 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000005 is : 143
2015-09-24 15:08:08,163 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000007 is : 143
2015-09-24 15:08:08,258 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000002 is : 143
2015-09-24 15:08:08,358 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000004 is : 143
2015-09-24 15:08:08,412 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000006 is : 143
2015-09-24 15:08:08,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000003 is : 143
2015-09-24 15:08:27,888 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000011 is : 143
2015-09-24 15:08:28,041 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120553098_0020_01_000012 is : 143
2015-09-24 15:08:29,278 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/serializedpipesplatform/testCoGroupSpillCustomWritable/customerwritable/_temporary
2015-09-24 15:08:29,287 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 01:05.401
2015-09-24 15:08:29,316 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/serializedpipesplatform/testCoGroupSpillCustomWritable/customerwritable