Class cascading.FieldedPipesPlatformTest

all > cascading > FieldedPipesPlatformTest
29

tests
0

failures
0

ignored
39m21.33s

duration
100%

successful

Tests

Test Duration Result
testChainEndingWithEach 1m11.45s passed
testConcatenation 1m5.80s passed
testCopy 46.273s passed
testFilter 44.536s passed
testFilterAll 2m12.76s passed
testFilterComplex 1m56.61s passed
testGeneratorAggregator 1m8.28s passed
testGroupByInsensitive 1m17.86s passed
testGroupGroup 2m12.97s passed
testLogicFilter 46.291s passed
testNoGroup 42.956s passed
testNone 1m7.51s passed
testReplace 44.925s passed
testSameSourceMergeThreeChainGroup 2m30.03s passed
testSimpleChain 1m12.44s passed
testSimpleGroup 1m9.05s passed
testSimpleMerge 1m16.35s passed
testSimpleMergeThree 1m18.72s passed
testSplit 1m1.22s passed
testSplitComplex 1m52.27s passed
testSplitMultiple 3m5.60s passed
testSplitNonSafe 1m48.13s passed
testSplitOut 2m23.99s passed
testSplitSameSourceMerged 1m7.42s passed
testSplitSameSourceMergedSameName 1m9.50s passed
testSwap 1m7.50s passed
testUnGroup 50.627s passed
testUnGroupAnon 45.783s passed
testUnGroupBySize 44.485s passed

Standard output

2015-09-24 11:06:59,902 INFO  platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 11:06:59,954 INFO  platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.FieldedPipesPlatformTest, with platform: hadoop2-mr1
2015-09-24 11:06:59,982 INFO  hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 11:07:11,954 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 11:07:12,654 WARN  impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 11:07:23,619 WARN  fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 11:07:23,995 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 11:07:24,295 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 11:07:24,546 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 11:07:24,828 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 11:07:42,308 INFO  platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides: 
2015-09-24 11:07:42,431 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:07:42,432 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:07:42,515 INFO  property.AppProps (AppProps.java:getAppID(177)) - using app.id: ECF2EF1B7AC54771BF63F511A0CBEC45
2015-09-24 11:07:42,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.119
2015-09-24 11:07:42,687 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:07:42,689 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 11:07:42,866 INFO  util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 11:07:42,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:07:42,868 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 11:07:42,868 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterComplex/filtercomplex"]
2015-09-24 11:07:42,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:07:42,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:07:42,869 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:07:42,871 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...lterComplex/filtercomplex
2015-09-24 11:07:43,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0001
2015-09-24 11:07:43,878 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0001/
2015-09-24 11:08:07,814 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0001_01_000008
2015-09-24 11:08:31,708 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000005 is : 143
2015-09-24 11:08:31,708 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000003 is : 143
2015-09-24 11:08:31,946 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000004 is : 143
2015-09-24 11:08:31,957 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000002 is : 143
2015-09-24 11:08:32,081 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000006 is : 143
2015-09-24 11:08:54,740 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000011 is : 143
2015-09-24 11:08:54,804 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000010 is : 143
2015-09-24 11:08:55,192 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0001_01_000009 is : 143
2015-09-24 11:08:56,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/fieldedpipesplatform/testFilterComplex/filtercomplex/_temporary
2015-09-24 11:08:56,512 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:13.630
2015-09-24 11:08:56,569 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/fieldedpipesplatform/testFilterComplex/filtercomplex
2015-09-24 11:08:56,628 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:08:56,628 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:08:56,712 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.074
2015-09-24 11:08:56,714 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:08:56,715 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 11:08:56,761 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:08:56,762 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 11:08:56,762 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextDelimited[['ip', 'count1', 'count2', 'count3', 'count4']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleChain/simplechain"]
2015-09-24 11:08:56,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:08:56,763 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:08:56,764 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:08:56,765 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stSimpleChain/simplechain
2015-09-24 11:08:57,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0002
2015-09-24 11:08:57,099 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0002/
2015-09-24 11:09:19,818 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0002_01_000007
2015-09-24 11:09:42,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000005 is : 143
2015-09-24 11:09:42,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000002 is : 143
2015-09-24 11:09:42,530 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000006 is : 143
2015-09-24 11:09:42,606 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000004 is : 143
2015-09-24 11:09:42,690 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000003 is : 143
2015-09-24 11:10:07,369 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000010 is : 143
2015-09-24 11:10:07,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000008 is : 143
2015-09-24 11:10:07,681 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0002_01_000009 is : 143
2015-09-24 11:10:08,967 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/fieldedpipesplatform/testSimpleChain/simplechain/_temporary
2015-09-24 11:10:08,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:12.203
2015-09-24 11:10:09,011 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/fieldedpipesplatform/testSimpleChain/simplechain
2015-09-24 11:10:09,055 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:10:09,055 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:10:09,117 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2015-09-24 11:10:09,119 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:10:09,119 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 11:10:09,143 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:10:09,144 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 11:10:09,144 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleGroup/simple"]
2015-09-24 11:10:09,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:10:09,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:10:09,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:10:09,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...rm/testSimpleGroup/simple
2015-09-24 11:10:09,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0003
2015-09-24 11:10:09,360 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0003/
2015-09-24 11:10:31,430 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0003_01_000007
2015-09-24 11:10:53,797 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000006 is : 143
2015-09-24 11:10:53,876 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000002 is : 143
2015-09-24 11:10:53,944 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000003 is : 143
2015-09-24 11:10:54,025 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000004 is : 143
2015-09-24 11:10:54,038 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000005 is : 143
2015-09-24 11:11:16,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000008 is : 143
2015-09-24 11:11:16,447 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000010 is : 143
2015-09-24 11:11:16,744 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0003_01_000009 is : 143
2015-09-24 11:11:18,001 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/fieldedpipesplatform/testSimpleGroup/simple/_temporary
2015-09-24 11:11:18,004 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:08.855
2015-09-24 11:11:18,067 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/fieldedpipesplatform/testSimpleGroup/simple
2015-09-24 11:11:18,142 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:11:18,143 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:11:18,209 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-09-24 11:11:18,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:11:18,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:11:18,234 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-09-24 11:11:18,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 11:11:18,235 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:11:18,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMerge/simplemerge"]
2015-09-24 11:11:18,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2015-09-24 11:11:18,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2015-09-24 11:11:18,237 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2015-09-24 11:11:18,238 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...stSimpleMerge/simplemerge
2015-09-24 11:11:18,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1443107256790_0004
2015-09-24 11:11:18,452 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:56115/proxy/application_1443107256790_0004/
2015-09-24 11:11:40,360 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0004_01_000010
2015-09-24 11:11:40,491 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0004_01_000011
2015-09-24 11:11:41,159 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0004_01_000013
2015-09-24 11:12:10,390 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000004 is : 143
2015-09-24 11:12:10,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000008 is : 143
2015-09-24 11:12:10,666 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000007 is : 143
2015-09-24 11:12:10,754 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000009 is : 143
2015-09-24 11:12:10,858 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000006 is : 143
2015-09-24 11:12:10,914 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000005 is : 143
2015-09-24 11:12:11,014 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000002 is : 143
2015-09-24 11:12:11,125 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000003 is : 143
2015-09-24 11:12:32,699 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000014 is : 143
2015-09-24 11:12:32,983 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000015 is : 143
2015-09-24 11:12:33,087 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0004_01_000016 is : 143
2015-09-24 11:12:34,361 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/fieldedpipesplatform/testSimpleMerge/simplemerge/_temporary
2015-09-24 11:12:34,363 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 01:16.124
2015-09-24 11:12:34,422 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/fieldedpipesplatform/testSimpleMerge/simplemerge
2015-09-24 11:12:34,586 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:12:34,586 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:12:34,639 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.048
2015-09-24 11:12:34,642 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:12:34,642 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 11:12:34,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:12:34,666 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 11:12:34,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testChainEndingWithEach/chaineach"]
2015-09-24 11:12:34,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:12:34,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:12:34,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:12:34,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...nEndingWithEach/chaineach
2015-09-24 11:12:34,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0005
2015-09-24 11:12:34,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0005/
2015-09-24 11:12:56,740 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0005_01_000007
2015-09-24 11:13:19,617 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000004 is : 143
2015-09-24 11:13:19,774 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000003 is : 143
2015-09-24 11:13:19,893 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000006 is : 143
2015-09-24 11:13:19,933 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000002 is : 143
2015-09-24 11:13:19,980 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000005 is : 143
2015-09-24 11:13:44,423 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000008 is : 143
2015-09-24 11:13:44,560 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000009 is : 143
2015-09-24 11:13:44,562 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0005_01_000010 is : 143
2015-09-24 11:13:45,840 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/fieldedpipesplatform/testChainEndingWithEach/chaineach/_temporary
2015-09-24 11:13:45,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:11.170
2015-09-24 11:13:45,872 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/fieldedpipesplatform/testChainEndingWithEach/chaineach
2015-09-24 11:13:45,907 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:13:45,907 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:13:45,951 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.039
2015-09-24 11:13:45,952 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:13:45,953 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 11:13:45,971 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:13:45,972 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 11:13:45,972 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator"]
2015-09-24 11:13:45,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:13:45,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:13:45,973 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:13:45,975 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...gator/generatoraggregator
2015-09-24 11:13:46,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0006
2015-09-24 11:13:46,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0006/
2015-09-24 11:14:08,124 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0006_01_000007
2015-09-24 11:14:30,076 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000004 is : 143
2015-09-24 11:14:30,214 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000005 is : 143
2015-09-24 11:14:30,298 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000003 is : 143
2015-09-24 11:14:30,320 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000006 is : 143
2015-09-24 11:14:30,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000002 is : 143
2015-09-24 11:14:52,378 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000010 is : 143
2015-09-24 11:14:52,586 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000009 is : 143
2015-09-24 11:14:52,866 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0006_01_000008 is : 143
2015-09-24 11:14:54,118 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/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator/_temporary
2015-09-24 11:14:54,121 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:08.144
2015-09-24 11:14:54,151 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/fieldedpipesplatform/testGeneratorAggregator/generatoraggregator
2015-09-24 11:14:54,210 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:14:54,211 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:14:54,279 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.064
2015-09-24 11:14:54,280 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:14:54,281 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:14:54,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting
2015-09-24 11:14:54,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 11:14:54,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:14:54,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower-offset.txt"]
2015-09-24 11:14:54,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  sink: Hfs["TextDelimited[['num', 'first']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSimpleMergeThree/simplemergethree"]
2015-09-24 11:14:54,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  parallel execution of steps is enabled: true
2015-09-24 11:14:54,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  executing total steps: 1
2015-09-24 11:14:54,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  allocating management threads: 1
2015-09-24 11:14:54,316 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] starting step: (1/1) ...rgeThree/simplemergethree
2015-09-24 11:14:54,503 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] submitted hadoop job: job_1443107256790_0007
2015-09-24 11:14:54,504 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge] tracking url: http://localhost:56115/proxy/application_1443107256790_0007/
2015-09-24 11:15:16,920 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0007_01_000012
2015-09-24 11:15:17,219 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0007_01_000013
2015-09-24 11:15:17,445 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0007_01_000014
2015-09-24 11:15:48,090 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000006 is : 143
2015-09-24 11:15:48,163 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000008 is : 143
2015-09-24 11:15:48,291 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000003 is : 143
2015-09-24 11:15:48,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000002 is : 143
2015-09-24 11:15:48,503 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000010 is : 143
2015-09-24 11:15:48,511 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000004 is : 143
2015-09-24 11:15:48,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000005 is : 143
2015-09-24 11:15:48,741 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000009 is : 143
2015-09-24 11:15:48,742 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000007 is : 143
2015-09-24 11:16:10,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000015 is : 143
2015-09-24 11:16:11,397 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000017 is : 143
2015-09-24 11:16:11,569 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0007_01_000016 is : 143
2015-09-24 11:16:12,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/fieldedpipesplatform/testSimpleMergeThree/simplemergethree/_temporary
2015-09-24 11:16:12,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merge]  completed in: 01:18.504
2015-09-24 11:16:12,877 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/fieldedpipesplatform/testSimpleMergeThree/simplemergethree
2015-09-24 11:16:12,913 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:16:12,914 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:16:12,987 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.067
2015-09-24 11:16:12,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 3
2015-09-24 11:16:12,989 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:16:13,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2015-09-24 11:16:13,018 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  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 11:16:13,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1"]
2015-09-24 11:16:13,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2"]
2015-09-24 11:16:13,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2015-09-24 11:16:13,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 3
2015-09-24 11:16:13,020 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 3
2015-09-24 11:16:13,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2015-09-24 11:16:13,219 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0008
2015-09-24 11:16:13,220 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0008/
2015-09-24 11:16:56,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0008_01_000004 is : 143
2015-09-24 11:16:57,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0008_01_000002 is : 143
2015-09-24 11:16:57,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0008_01_000005 is : 143
2015-09-24 11:16:57,265 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0008_01_000006 is : 143
2015-09-24 11:16:57,332 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0008_01_000003 is : 143
2015-09-24 11:16:58,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...plitNonSafe/nonsafesplit1
2015-09-24 11:16:58,536 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...plitNonSafe/nonsafesplit2
2015-09-24 11:16:58,786 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0010
2015-09-24 11:16:58,787 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0010/
2015-09-24 11:16:58,790 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0009
2015-09-24 11:16:58,791 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0009/
2015-09-24 11:17:24,331 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0010_01_000009
2015-09-24 11:17:24,406 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0009_01_000007
2015-09-24 11:17:58,018 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0009_01_000005 is : 143
2015-09-24 11:17:58,189 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0010_01_000003 is : 143
2015-09-24 11:17:58,404 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0009_01_000002 is : 143
2015-09-24 11:17:58,437 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0010_01_000008 is : 143
2015-09-24 11:17:58,489 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0009_01_000004 is : 143
2015-09-24 11:17:58,659 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0010_01_000005 is : 143
2015-09-24 11:17:58,659 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0009_01_000003 is : 143
2015-09-24 11:17:58,756 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0009_01_000006 is : 143
2015-09-24 11:17:58,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0010_01_000004 is : 143
2015-09-24 11:17:59,121 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0010_01_000002 is : 143
2015-09-24 11:18:00,934 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/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1/_temporary
2015-09-24 11:18:00,938 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/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2/_temporary
2015-09-24 11:18:00,942 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 01:47.909
2015-09-24 11:18:00,994 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/fieldedpipesplatform/testSplitNonSafe/nonsafesplit1
2015-09-24 11:18:01,007 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/fieldedpipesplatform/testSplitNonSafe/nonsafesplit2
2015-09-24 11:18:01,038 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:18:01,038 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:18:01,110 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.068
2015-09-24 11:18:01,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 5
2015-09-24 11:18:01,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:18:01,145 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting
2015-09-24 11:18:01,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  source: Hfs["TextLine[['num', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 11:18:01,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout2"]
2015-09-24 11:18:01,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitOut/splitout1"]
2015-09-24 11:18:01,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  parallel execution of steps is enabled: true
2015-09-24 11:18:01,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  executing total steps: 3
2015-09-24 11:18:01,148 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  allocating management threads: 3
2015-09-24 11:18:01,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (1/3)
2015-09-24 11:18:01,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1443107256790_0011
2015-09-24 11:18:01,294 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://localhost:56115/proxy/application_1443107256790_0011/
2015-09-24 11:18:24,769 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0011_01_000008
2015-09-24 11:18:46,824 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000005 is : 143
2015-09-24 11:18:46,947 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000002 is : 143
2015-09-24 11:18:46,995 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000003 is : 143
2015-09-24 11:18:47,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000004 is : 143
2015-09-24 11:18:47,100 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000006 is : 143
2015-09-24 11:19:09,656 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000010 is : 143
2015-09-24 11:19:09,794 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000009 is : 143
2015-09-24 11:19:10,089 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0011_01_000011 is : 143
2015-09-24 11:19:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (2/3) ...rm/testSplitOut/splitout2
2015-09-24 11:19:11,302 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] starting step: (3/3) ...rm/testSplitOut/splitout1
2015-09-24 11:19:11,511 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1443107256790_0012
2015-09-24 11:19:11,511 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://localhost:56115/proxy/application_1443107256790_0012/
2015-09-24 11:19:11,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] submitted hadoop job: job_1443107256790_0013
2015-09-24 11:19:11,531 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2] tracking url: http://localhost:56115/proxy/application_1443107256790_0013/
2015-09-24 11:19:35,854 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0013_01_000006
2015-09-24 11:20:00,574 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0013_01_000002 is : 143
2015-09-24 11:20:00,856 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0013_01_000004 is : 143
2015-09-24 11:20:00,892 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0013_01_000003 is : 143
2015-09-24 11:20:00,961 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0012_01_000004 is : 143
2015-09-24 11:20:01,235 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0012_01_000003 is : 143
2015-09-24 11:20:01,292 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0012_01_000002 is : 143
2015-09-24 11:20:23,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0012_01_000006 is : 143
2015-09-24 11:20:23,347 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0012_01_000007 is : 143
2015-09-24 11:20:23,624 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0012_01_000005 is : 143
2015-09-24 11:20:24,869 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/fieldedpipesplatform/testSplitOut/splitout2/_temporary
2015-09-24 11:20:24,875 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/fieldedpipesplatform/testSplitOut/splitout1/_temporary
2015-09-24 11:20:24,879 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [output1+output2]  completed in: 02:23.718
2015-09-24 11:20:24,980 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/fieldedpipesplatform/testSplitOut/splitout1
2015-09-24 11:20:24,994 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/fieldedpipesplatform/testSplitOut/splitout2
2015-09-24 11:20:25,033 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:20:25,033 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:20:25,093 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.054
2015-09-24 11:20:25,094 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 2
2015-09-24 11:20:25,095 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:20:25,112 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2015-09-24 11:20:25,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  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 11:20:25,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split1"]
2015-09-24 11:20:25,113 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplit/split2"]
2015-09-24 11:20:25,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2015-09-24 11:20:25,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 2
2015-09-24 11:20:25,114 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 2
2015-09-24 11:20:25,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/2) ...platform/testSplit/split1
2015-09-24 11:20:25,116 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/2) ...platform/testSplit/split2
2015-09-24 11:20:25,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0014
2015-09-24 11:20:25,307 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0014/
2015-09-24 11:20:25,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0015
2015-09-24 11:20:25,324 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0015/
2015-09-24 11:20:50,314 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0014_01_000007
2015-09-24 11:20:50,699 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0015_01_000009
2015-09-24 11:21:23,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0014_01_000002 is : 143
2015-09-24 11:21:23,807 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0014_01_000005 is : 143
2015-09-24 11:21:24,055 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0015_01_000003 is : 143
2015-09-24 11:21:24,148 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0015_01_000002 is : 143
2015-09-24 11:21:24,193 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0014_01_000006 is : 143
2015-09-24 11:21:24,297 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0015_01_000005 is : 143
2015-09-24 11:21:24,536 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0015_01_000004 is : 143
2015-09-24 11:21:24,616 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0014_01_000004 is : 143
2015-09-24 11:21:24,743 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0015_01_000008 is : 143
2015-09-24 11:21:24,834 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0014_01_000003 is : 143
2015-09-24 11:21:26,150 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/fieldedpipesplatform/testSplit/split1/_temporary
2015-09-24 11:21:26,152 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/fieldedpipesplatform/testSplit/split2/_temporary
2015-09-24 11:21:26,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 01:01.034
2015-09-24 11:21:26,201 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/fieldedpipesplatform/testSplit/split2
2015-09-24 11:21:26,215 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/fieldedpipesplatform/testSplit/split1
2015-09-24 11:21:26,244 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:21:26,245 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:21:26,295 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.045
2015-09-24 11:21:26,296 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:21:26,297 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:21:26,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2015-09-24 11:21:26,311 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 11:21:26,312 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged"]
2015-09-24 11:21:26,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2015-09-24 11:21:26,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2015-09-24 11:21:26,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2015-09-24 11:21:26,314 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...eMerged/splitsourcemerged
2015-09-24 11:21:26,471 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1443107256790_0016
2015-09-24 11:21:26,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://localhost:56115/proxy/application_1443107256790_0016/
2015-09-24 11:22:09,112 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000002 is : 143
2015-09-24 11:22:09,259 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000004 is : 143
2015-09-24 11:22:09,283 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000005 is : 143
2015-09-24 11:22:09,429 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000006 is : 143
2015-09-24 11:22:09,435 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000003 is : 143
2015-09-24 11:22:32,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000008 is : 143
2015-09-24 11:22:32,282 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000007 is : 143
2015-09-24 11:22:32,295 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0016_01_000009 is : 143
2015-09-24 11:22:33,590 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/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged/_temporary
2015-09-24 11:22:33,594 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 01:07.275
2015-09-24 11:22:33,627 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/fieldedpipesplatform/testSplitSameSourceMerged/splitsourcemerged
2015-09-24 11:22:33,664 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:22:33,664 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:22:33,689 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.020
2015-09-24 11:22:33,691 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:22:33,691 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 11:22:33,701 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:22:33,701 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 11:22:33,702 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testCopy/copy"]
2015-09-24 11:22:33,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:22:33,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:22:33,703 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:22:33,705 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testCopy/copy
2015-09-24 11:22:33,933 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0017
2015-09-24 11:22:33,934 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0017/
2015-09-24 11:23:18,111 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0017_01_000006 is : 143
2015-09-24 11:23:18,340 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0017_01_000002 is : 143
2015-09-24 11:23:18,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0017_01_000004 is : 143
2015-09-24 11:23:18,490 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0017_01_000005 is : 143
2015-09-24 11:23:18,621 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0017_01_000003 is : 143
2015-09-24 11:23:19,858 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/fieldedpipesplatform/testCopy/copy/_temporary
2015-09-24 11:23:19,862 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:46.154
2015-09-24 11:23:19,897 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/fieldedpipesplatform/testCopy/copy
2015-09-24 11:23:19,935 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:23:19,936 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:23:19,980 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-09-24 11:23:19,981 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:23:19,982 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 11:23:19,999 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:23:20,000 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 11:23:20,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ip']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNone/none"]
2015-09-24 11:23:20,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:23:20,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:23:20,003 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:23:20,004 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testNone/none
2015-09-24 11:23:20,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0018
2015-09-24 11:23:20,158 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0018/
2015-09-24 11:23:41,686 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0018_01_000007
2015-09-24 11:24:03,016 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000004 is : 143
2015-09-24 11:24:03,094 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000005 is : 143
2015-09-24 11:24:03,170 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000006 is : 143
2015-09-24 11:24:03,229 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000003 is : 143
2015-09-24 11:24:03,355 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000002 is : 143
2015-09-24 11:24:25,808 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000008 is : 143
2015-09-24 11:24:25,911 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000009 is : 143
2015-09-24 11:24:26,114 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0018_01_000010 is : 143
2015-09-24 11:24:27,375 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/fieldedpipesplatform/testNone/none/_temporary
2015-09-24 11:24:27,377 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:07.373
2015-09-24 11:24:27,409 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/fieldedpipesplatform/testNone/none
2015-09-24 11:24:27,440 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:24:27,440 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:24:27,478 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-09-24 11:24:27,480 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:24:27,481 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 11:24:27,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:24:27,497 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 11:24:27,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->['count', 'ipaddress']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSwap/swap"]
2015-09-24 11:24:27,498 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:24:27,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:24:27,499 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:24:27,500 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...pesplatform/testSwap/swap
2015-09-24 11:24:27,640 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0019
2015-09-24 11:24:27,640 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0019/
2015-09-24 11:24:49,165 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0019_01_000007
2015-09-24 11:25:10,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000005 is : 143
2015-09-24 11:25:10,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000004 is : 143
2015-09-24 11:25:10,689 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000006 is : 143
2015-09-24 11:25:10,794 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000002 is : 143
2015-09-24 11:25:10,884 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000003 is : 143
2015-09-24 11:25:33,187 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000010 is : 143
2015-09-24 11:25:33,296 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000009 is : 143
2015-09-24 11:25:33,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0019_01_000008 is : 143
2015-09-24 11:25:34,881 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/fieldedpipesplatform/testSwap/swap/_temporary
2015-09-24 11:25:34,884 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 01:07.381
2015-09-24 11:25:34,911 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/fieldedpipesplatform/testSwap/swap
2015-09-24 11:25:34,941 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:25:34,941 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:25:34,964 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-09-24 11:25:34,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:25:34,966 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 11:25:34,976 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:25:34,976 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 11:25:34,977 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testLogicFilter/logicfilter"]
2015-09-24 11:25:34,978 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:25:34,978 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:25:34,978 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:25:34,982 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...stLogicFilter/logicfilter
2015-09-24 11:25:35,146 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0020
2015-09-24 11:25:35,147 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0020/
2015-09-24 11:25:56,705 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0020_01_000007
2015-09-24 11:26:19,185 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0020_01_000002 is : 143
2015-09-24 11:26:19,403 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0020_01_000005 is : 143
2015-09-24 11:26:19,405 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0020_01_000006 is : 143
2015-09-24 11:26:19,523 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0020_01_000004 is : 143
2015-09-24 11:26:19,866 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0020_01_000003 is : 143
2015-09-24 11:26:21,144 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/fieldedpipesplatform/testLogicFilter/logicfilter/_temporary
2015-09-24 11:26:21,152 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:46.165
2015-09-24 11:26:21,196 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/fieldedpipesplatform/testLogicFilter/logicfilter
2015-09-24 11:26:21,260 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:26:21,261 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:26:21,299 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.032
2015-09-24 11:26:21,300 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:26:21,300 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 11:26:21,318 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:26:21,318 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/lower+upper.txt"]
2015-09-24 11:26:21,319 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroup/ungrouped"]
2015-09-24 11:26:21,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:26:21,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:26:21,320 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:26:21,322 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...orm/testUnGroup/ungrouped
2015-09-24 11:26:21,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0021
2015-09-24 11:26:21,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0021/
2015-09-24 11:26:45,460 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0021_01_000007
2015-09-24 11:27:09,832 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0021_01_000002 is : 143
2015-09-24 11:27:10,075 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0021_01_000006 is : 143
2015-09-24 11:27:10,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0021_01_000003 is : 143
2015-09-24 11:27:10,451 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0021_01_000004 is : 143
2015-09-24 11:27:10,507 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0021_01_000005 is : 143
2015-09-24 11:27:11,791 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/fieldedpipesplatform/testUnGroup/ungrouped/_temporary
2015-09-24 11:27:11,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:50.470
2015-09-24 11:27:11,823 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/fieldedpipesplatform/testUnGroup/ungrouped
2015-09-24 11:27:11,862 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:27:11,863 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:27:11,937 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2015-09-24 11:27:11,938 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 11:27:11,939 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 11:27:11,965 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:27:11,966 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 11:27:11,966 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilterAll/filterall"]
2015-09-24 11:27:11,967 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:27:11,967 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2015-09-24 11:27:11,967 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 2
2015-09-24 11:27:11,969 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-09-24 11:27:12,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0022
2015-09-24 11:27:12,126 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0022/
2015-09-24 11:27:34,145 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0022_01_000007
2015-09-24 11:27:56,842 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000003 is : 143
2015-09-24 11:27:56,844 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000004 is : 143
2015-09-24 11:27:56,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000002 is : 143
2015-09-24 11:27:57,148 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000005 is : 143
2015-09-24 11:27:57,158 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000006 is : 143
2015-09-24 11:28:20,069 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000009 is : 143
2015-09-24 11:28:20,402 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000008 is : 143
2015-09-24 11:28:20,442 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0022_01_000010 is : 143
2015-09-24 11:28:21,635 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...m/testFilterAll/filterall
2015-09-24 11:28:21,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0023
2015-09-24 11:28:21,793 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0023/
2015-09-24 11:29:00,571 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0023_01_000003 is : 143
2015-09-24 11:29:00,648 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0023_01_000002 is : 143
2015-09-24 11:29:00,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0023_01_000004 is : 143
2015-09-24 11:29:23,234 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0023_01_000005 is : 143
2015-09-24 11:29:23,267 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0023_01_000007 is : 143
2015-09-24 11:29:23,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0023_01_000006 is : 143
2015-09-24 11:29:24,573 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/fieldedpipesplatform/testFilterAll/filterall/_temporary
2015-09-24 11:29:24,577 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 02:12.604
2015-09-24 11:29:24,596 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/fieldedpipesplatform/testFilterAll/filterall
2015-09-24 11:29:24,626 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:29:24,627 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:29:24,666 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-09-24 11:29:24,667 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:29:24,668 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:29:24,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting
2015-09-24 11:29:24,680 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 11:29:24,681 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename"]
2015-09-24 11:29:24,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  parallel execution of steps is enabled: true
2015-09-24 11:29:24,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  executing total steps: 1
2015-09-24 11:29:24,682 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  allocating management threads: 1
2015-09-24 11:29:24,683 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] starting step: (1/1) ...splitsourcemergedsamename
2015-09-24 11:29:24,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] submitted hadoop job: job_1443107256790_0024
2015-09-24 11:29:24,836 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged] tracking url: http://localhost:56115/proxy/application_1443107256790_0024/
2015-09-24 11:29:46,829 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0024_01_000007
2015-09-24 11:30:09,052 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000002 is : 143
2015-09-24 11:30:09,179 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000003 is : 143
2015-09-24 11:30:09,317 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000005 is : 143
2015-09-24 11:30:09,352 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000004 is : 143
2015-09-24 11:30:09,444 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000006 is : 143
2015-09-24 11:30:32,625 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000008 is : 143
2015-09-24 11:30:32,693 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000009 is : 143
2015-09-24 11:30:32,769 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0024_01_000010 is : 143
2015-09-24 11:30:34,058 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/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename/_temporary
2015-09-24 11:30:34,061 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [merged]  completed in: 01:09.371
2015-09-24 11:30:34,090 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/fieldedpipesplatform/testSplitSameSourceMergedSameName/splitsourcemergedsamename
2015-09-24 11:30:34,126 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:30:34,127 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:30:34,167 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.036
2015-09-24 11:30:34,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:30:34,169 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:30:34,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting
2015-09-24 11:30:34,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 11:30:34,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  source: Hfs["TextDelimited[['num', 'char']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:30:34,192 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic"]
2015-09-24 11:30:34,193 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  parallel execution of steps is enabled: true
2015-09-24 11:30:34,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  executing total steps: 1
2015-09-24 11:30:34,194 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  allocating management threads: 1
2015-09-24 11:30:34,195 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] starting step: (1/1) ...grouping-nondeterministic
2015-09-24 11:30:34,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] submitted hadoop job: job_1443107256790_0025
2015-09-24 11:30:34,372 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby] tracking url: http://localhost:56115/proxy/application_1443107256790_0025/
2015-09-24 11:30:56,687 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0025_01_000011
2015-09-24 11:30:56,749 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0025_01_000012
2015-09-24 11:30:56,852 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0025_01_000013
2015-09-24 11:31:26,164 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000006 is : 143
2015-09-24 11:31:26,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000008 is : 143
2015-09-24 11:31:26,486 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000003 is : 143
2015-09-24 11:31:26,529 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000009 is : 143
2015-09-24 11:31:26,696 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000002 is : 143
2015-09-24 11:31:26,798 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000005 is : 143
2015-09-24 11:31:26,849 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000007 is : 143
2015-09-24 11:31:26,929 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000004 is : 143
2015-09-24 11:31:50,200 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000014 is : 143
2015-09-24 11:31:50,346 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000016 is : 143
2015-09-24 11:31:50,682 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0025_01_000015 is : 143
2015-09-24 11:31:51,917 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/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic/_temporary
2015-09-24 11:31:51,920 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [groupby]  completed in: 01:17.724
2015-09-24 11:31:51,952 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/fieldedpipesplatform/testGroupByInsensitive/insensitivegrouping-nondeterministic
2015-09-24 11:31:51,985 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:31:51,985 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:31:52,014 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-09-24 11:31:52,015 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:31:52,016 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 11:31:52,026 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:31:52,027 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/lower+upper.txt"]
2015-09-24 11:31:52,027 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupAnon/ungroupedanon"]
2015-09-24 11:31:52,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:31:52,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:31:52,028 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:31:52,030 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...UnGroupAnon/ungroupedanon
2015-09-24 11:31:52,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0026
2015-09-24 11:31:52,178 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0026/
2015-09-24 11:32:13,742 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0026_01_000007
2015-09-24 11:32:35,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0026_01_000006 is : 143
2015-09-24 11:32:36,003 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0026_01_000004 is : 143
2015-09-24 11:32:36,138 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0026_01_000005 is : 143
2015-09-24 11:32:36,400 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0026_01_000003 is : 143
2015-09-24 11:32:36,462 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0026_01_000002 is : 143
2015-09-24 11:32:37,687 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/fieldedpipesplatform/testUnGroupAnon/ungroupedanon/_temporary
2015-09-24 11:32:37,690 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:45.658
2015-09-24 11:32:37,733 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/fieldedpipesplatform/testUnGroupAnon/ungroupedanon
2015-09-24 11:32:37,767 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:32:37,767 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:32:37,823 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.052
2015-09-24 11:32:37,825 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 11:32:37,825 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 11:32:37,847 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:32:37,848 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 11:32:37,848 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testGroupGroup/groupgroup"]
2015-09-24 11:32:37,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:32:37,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 2
2015-09-24 11:32:37,849 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 2
2015-09-24 11:32:37,851 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/2)
2015-09-24 11:32:37,924 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-09-24 11:32:37,924 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-09-24 11:32:37,925 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-09-24 11:32:38,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0027
2015-09-24 11:32:38,002 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0027/
2015-09-24 11:33:00,074 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0027_01_000007
2015-09-24 11:33:21,752 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000006 is : 143
2015-09-24 11:33:21,859 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000003 is : 143
2015-09-24 11:33:21,869 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000004 is : 143
2015-09-24 11:33:21,980 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000005 is : 143
2015-09-24 11:33:22,000 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000002 is : 143
2015-09-24 11:33:45,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000008 is : 143
2015-09-24 11:33:45,711 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000010 is : 143
2015-09-24 11:33:45,968 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0027_01_000009 is : 143
2015-09-24 11:33:47,155 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (2/2) ...testGroupGroup/groupgroup
2015-09-24 11:33:47,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0028
2015-09-24 11:33:47,313 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0028/
2015-09-24 11:34:25,831 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0028_01_000004 is : 143
2015-09-24 11:34:25,918 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0028_01_000002 is : 143
2015-09-24 11:34:25,985 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0028_01_000003 is : 143
2015-09-24 11:34:48,999 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0028_01_000007 is : 143
2015-09-24 11:34:49,098 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0028_01_000006 is : 143
2015-09-24 11:34:49,427 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0028_01_000005 is : 143
2015-09-24 11:34:50,666 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/fieldedpipesplatform/testGroupGroup/groupgroup/_temporary
2015-09-24 11:34:50,669 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 02:12.814
2015-09-24 11:34:50,704 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/fieldedpipesplatform/testGroupGroup/groupgroup
2015-09-24 11:34:50,737 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:34:50,737 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:34:50,811 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.070
2015-09-24 11:34:50,813 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 2, nodes: 4
2015-09-24 11:34:50,813 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:34:50,839 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting
2015-09-24 11:34:50,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 11:34:50,840 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup"]
2015-09-24 11:34:50,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  parallel execution of steps is enabled: true
2015-09-24 11:34:50,841 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  executing total steps: 2
2015-09-24 11:34:50,842 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  allocating management threads: 2
2015-09-24 11:34:50,843 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (1/2)
2015-09-24 11:34:51,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_1443107256790_0029
2015-09-24 11:34:51,000 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://localhost:56115/proxy/application_1443107256790_0029/
2015-09-24 11:35:13,062 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0029_01_000009
2015-09-24 11:35:13,072 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0029_01_000010
2015-09-24 11:35:13,487 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0029_01_000012
2015-09-24 11:35:39,907 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000003 is : 143
2015-09-24 11:35:40,108 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000005 is : 143
2015-09-24 11:35:40,260 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000002 is : 143
2015-09-24 11:35:40,336 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000006 is : 143
2015-09-24 11:35:40,393 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000008 is : 143
2015-09-24 11:35:40,452 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000004 is : 143
2015-09-24 11:35:40,552 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000007 is : 143
2015-09-24 11:36:03,653 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000013 is : 143
2015-09-24 11:36:03,785 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000015 is : 143
2015-09-24 11:36:04,020 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0029_01_000014 is : 143
2015-09-24 11:36:05,218 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] starting step: (2/2) .../samemergethreechaingroup
2015-09-24 11:36:05,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] submitted hadoop job: job_1443107256790_0030
2015-09-24 11:36:05,375 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset] tracking url: http://localhost:56115/proxy/application_1443107256790_0030/
2015-09-24 11:36:27,065 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0030_01_000010
2015-09-24 11:36:27,698 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0030_01_000012
2015-09-24 11:36:27,845 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0030_01_000013
2015-09-24 11:36:56,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000003 is : 143
2015-09-24 11:36:56,450 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000004 is : 143
2015-09-24 11:36:56,665 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000009 is : 143
2015-09-24 11:36:56,872 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000005 is : 143
2015-09-24 11:36:56,959 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000007 is : 143
2015-09-24 11:36:57,047 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000006 is : 143
2015-09-24 11:36:57,087 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000002 is : 143
2015-09-24 11:36:57,137 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000008 is : 143
2015-09-24 11:37:18,966 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000014 is : 143
2015-09-24 11:37:19,253 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000016 is : 143
2015-09-24 11:37:19,475 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0030_01_000015 is : 143
2015-09-24 11:37:20,710 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/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup/_temporary
2015-09-24 11:37:20,713 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [lower+upper+offset]  completed in: 02:29.866
2015-09-24 11:37:20,736 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/fieldedpipesplatform/testSameSourceMergeThreeChainGroup/samemergethreechaingroup
2015-09-24 11:37:20,765 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:37:20,766 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:37:20,794 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.025
2015-09-24 11:37:20,795 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:37:20,795 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 11:37:20,804 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:37:20,805 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 11:37:20,805 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace"]
2015-09-24 11:37:20,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:37:20,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:37:20,806 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:37:20,808 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testReplace/replace
2015-09-24 11:37:20,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0031
2015-09-24 11:37:20,960 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0031/
2015-09-24 11:37:42,534 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0031_01_000007
2015-09-24 11:38:03,642 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0031_01_000005 is : 143
2015-09-24 11:38:03,926 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0031_01_000004 is : 143
2015-09-24 11:38:04,063 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0031_01_000003 is : 143
2015-09-24 11:38:04,287 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0031_01_000002 is : 143
2015-09-24 11:38:04,371 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0031_01_000006 is : 143
2015-09-24 11:38:05,619 INFO  util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testReplace/replace/_temporary
2015-09-24 11:38:05,622 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:44.811
2015-09-24 11:38:05,653 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/fieldedpipesplatform/testReplace/replace
2015-09-24 11:38:05,702 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:38:05,702 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:38:05,727 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.022
2015-09-24 11:38:05,728 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:38:05,729 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 11:38:05,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:38:05,739 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/extra+lower+upper.txt"]
2015-09-24 11:38:05,739 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size"]
2015-09-24 11:38:05,740 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:38:05,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:38:05,741 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:38:05,743 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...roupBySize/ungrouped_size
2015-09-24 11:38:05,904 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0032
2015-09-24 11:38:05,905 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0032/
2015-09-24 11:38:48,425 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0032_01_000006 is : 143
2015-09-24 11:38:48,535 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0032_01_000004 is : 143
2015-09-24 11:38:48,596 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0032_01_000003 is : 143
2015-09-24 11:38:48,649 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0032_01_000002 is : 143
2015-09-24 11:38:48,868 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0032_01_000005 is : 143
2015-09-24 11:38:50,095 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/fieldedpipesplatform/testUnGroupBySize/ungrouped_size/_temporary
2015-09-24 11:38:50,100 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:44.352
2015-09-24 11:38:50,133 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/testUnGroupBySize/ungrouped_size
2015-09-24 11:38:50,173 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:38:50,173 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:38:50,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.019
2015-09-24 11:38:50,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:38:50,198 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 11:38:50,206 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:38:50,207 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 11:38:50,207 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testFilter/filter"]
2015-09-24 11:38:50,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:38:50,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:38:50,208 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:38:50,210 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...latform/testFilter/filter
2015-09-24 11:38:50,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0033
2015-09-24 11:38:50,345 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0033/
2015-09-24 11:39:11,924 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0033_01_000007
2015-09-24 11:39:32,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0033_01_000004 is : 143
2015-09-24 11:39:33,240 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0033_01_000003 is : 143
2015-09-24 11:39:33,279 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0033_01_000006 is : 143
2015-09-24 11:39:33,357 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0033_01_000005 is : 143
2015-09-24 11:39:33,383 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0033_01_000002 is : 143
2015-09-24 11:39:34,639 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/fieldedpipesplatform/testFilter/filter/_temporary
2015-09-24 11:39:34,643 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:44.430
2015-09-24 11:39:34,680 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/fieldedpipesplatform/testFilter/filter
2015-09-24 11:39:34,713 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:39:34,713 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:39:34,815 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.097
2015-09-24 11:39:34,817 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 5, nodes: 7
2015-09-24 11:39:34,818 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:39:34,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting
2015-09-24 11:39:34,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  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 11:39:34,863 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/left"]
2015-09-24 11:39:34,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightright"]
2015-09-24 11:39:34,864 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitMultiple/rightleft"]
2015-09-24 11:39:34,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  parallel execution of steps is enabled: true
2015-09-24 11:39:34,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  executing total steps: 5
2015-09-24 11:39:34,865 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  allocating management threads: 5
2015-09-24 11:39:34,867 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (1/5)
2015-09-24 11:39:35,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1443107256790_0034
2015-09-24 11:39:35,019 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:56115/proxy/application_1443107256790_0034/
2015-09-24 11:39:56,998 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0034_01_000007
2015-09-24 11:40:17,819 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000004 is : 143
2015-09-24 11:40:17,914 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000006 is : 143
2015-09-24 11:40:17,974 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000002 is : 143
2015-09-24 11:40:17,988 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000005 is : 143
2015-09-24 11:40:18,036 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000003 is : 143
2015-09-24 11:40:40,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000010 is : 143
2015-09-24 11:40:40,901 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000008 is : 143
2015-09-24 11:40:41,083 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0034_01_000009 is : 143
2015-09-24 11:40:42,276 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (2/5)
2015-09-24 11:40:42,277 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (3/5) ...rm/testSplitMultiple/left
2015-09-24 11:40:42,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1443107256790_0035
2015-09-24 11:40:42,472 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:56115/proxy/application_1443107256790_0035/
2015-09-24 11:40:42,496 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1443107256790_0036
2015-09-24 11:40:42,497 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:56115/proxy/application_1443107256790_0036/
2015-09-24 11:41:06,134 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0036_01_000006
2015-09-24 11:41:29,623 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0036_01_000004 is : 143
2015-09-24 11:41:29,880 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0036_01_000002 is : 143
2015-09-24 11:41:30,054 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0035_01_000004 is : 143
2015-09-24 11:41:30,146 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0036_01_000003 is : 143
2015-09-24 11:41:30,243 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0035_01_000003 is : 143
2015-09-24 11:41:30,323 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0035_01_000002 is : 143
2015-09-24 11:41:51,299 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0035_01_000007 is : 143
2015-09-24 11:41:51,470 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0035_01_000005 is : 143
2015-09-24 11:41:51,654 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0035_01_000006 is : 143
2015-09-24 11:41:52,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (4/5) ...stSplitMultiple/rightleft
2015-09-24 11:41:52,822 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] starting step: (5/5) ...tSplitMultiple/rightright
2015-09-24 11:41:52,991 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1443107256790_0037
2015-09-24 11:41:52,992 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:56115/proxy/application_1443107256790_0037/
2015-09-24 11:41:53,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] submitted hadoop job: job_1443107256790_0038
2015-09-24 11:41:53,022 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight] tracking url: http://localhost:56115/proxy/application_1443107256790_0038/
2015-09-24 11:42:16,523 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0037_01_000007
2015-09-24 11:42:16,719 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0038_01_000005
2015-09-24 11:42:38,625 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0037_01_000003 is : 143
2015-09-24 11:42:38,626 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0037_01_000002 is : 143
2015-09-24 11:42:38,759 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0037_01_000004 is : 143
2015-09-24 11:42:38,846 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0038_01_000002 is : 143
2015-09-24 11:42:38,846 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0038_01_000003 is : 143
2015-09-24 11:42:38,963 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0038_01_000004 is : 143
2015-09-24 11:42:40,200 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/fieldedpipesplatform/testSplitMultiple/left/_temporary
2015-09-24 11:42:40,203 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/fieldedpipesplatform/testSplitMultiple/rightleft/_temporary
2015-09-24 11:42:40,206 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/fieldedpipesplatform/testSplitMultiple/rightright/_temporary
2015-09-24 11:42:40,211 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+rightLeft+rightRight]  completed in: 03:05.332
2015-09-24 11:42:40,265 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/fieldedpipesplatform/testSplitMultiple/rightright
2015-09-24 11:42:40,273 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/fieldedpipesplatform/testSplitMultiple/rightleft
2015-09-24 11:42:40,282 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/fieldedpipesplatform/testSplitMultiple/left
2015-09-24 11:42:40,305 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:42:40,306 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:42:40,340 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-09-24 11:42:40,342 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 11:42:40,342 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:42:40,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting
2015-09-24 11:42:40,355 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  source: MultiSourceTap[2:[Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"], Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]]]
2015-09-24 11:42:40,356 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testConcatenation/complexconcat"]
2015-09-24 11:42:40,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  parallel execution of steps is enabled: true
2015-09-24 11:42:40,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  executing total steps: 1
2015-09-24 11:42:40,357 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  allocating management threads: 1
2015-09-24 11:42:40,358 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] starting step: (1/1) ...ncatenation/complexconcat
2015-09-24 11:42:40,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] submitted hadoop job: job_1443107256790_0039
2015-09-24 11:42:40,483 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat] tracking url: http://localhost:56115/proxy/application_1443107256790_0039/
2015-09-24 11:43:01,811 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0039_01_000009
2015-09-24 11:43:01,890 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0039_01_000010
2015-09-24 11:43:23,387 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000006 is : 143
2015-09-24 11:43:23,555 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000007 is : 143
2015-09-24 11:43:23,615 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000003 is : 143
2015-09-24 11:43:23,678 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000002 is : 143
2015-09-24 11:43:23,733 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000005 is : 143
2015-09-24 11:43:23,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000004 is : 143
2015-09-24 11:43:44,459 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000011 is : 143
2015-09-24 11:43:44,826 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000012 is : 143
2015-09-24 11:43:44,827 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0039_01_000013 is : 143
2015-09-24 11:43:46,056 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/fieldedpipesplatform/testConcatenation/complexconcat/_temporary
2015-09-24 11:43:46,058 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [concat]  completed in: 01:05.697
2015-09-24 11:43:46,080 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/fieldedpipesplatform/testConcatenation/complexconcat
2015-09-24 11:43:46,108 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:43:46,109 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:43:46,170 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.056
2015-09-24 11:43:46,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 3, nodes: 4
2015-09-24 11:43:46,173 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 11:43:46,196 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting
2015-09-24 11:43:46,197 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  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 11:43:46,197 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp1"]
2015-09-24 11:43:46,197 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2"]
2015-09-24 11:43:46,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  parallel execution of steps is enabled: true
2015-09-24 11:43:46,198 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  executing total steps: 3
2015-09-24 11:43:46,199 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  allocating management threads: 3
2015-09-24 11:43:46,203 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (1/3)
2015-09-24 11:43:46,338 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0040
2015-09-24 11:43:46,338 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0040/
2015-09-24 11:44:07,881 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0040_01_000008
2015-09-24 11:44:28,198 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000002 is : 143
2015-09-24 11:44:28,416 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000005 is : 143
2015-09-24 11:44:28,463 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000003 is : 143
2015-09-24 11:44:28,547 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000004 is : 143
2015-09-24 11:44:28,597 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000006 is : 143
2015-09-24 11:44:49,702 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000009 is : 143
2015-09-24 11:44:49,866 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000010 is : 143
2015-09-24 11:44:49,952 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0040_01_000011 is : 143
2015-09-24 11:44:51,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (2/3) ...stSplitComplex/splitcomp2
2015-09-24 11:44:51,150 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] starting step: (3/3) ...stSplitComplex/splitcomp1
2015-09-24 11:44:51,342 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0041
2015-09-24 11:44:51,342 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0041/
2015-09-24 11:44:51,363 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] submitted hadoop job: job_1443107256790_0042
2015-09-24 11:44:51,363 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right] tracking url: http://localhost:56115/proxy/application_1443107256790_0042/
2015-09-24 11:45:14,918 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0041_01_000007
2015-09-24 11:45:15,017 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0042_01_000005
2015-09-24 11:45:36,498 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0041_01_000003 is : 143
2015-09-24 11:45:36,501 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0041_01_000004 is : 143
2015-09-24 11:45:36,722 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0042_01_000002 is : 143
2015-09-24 11:45:36,801 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0042_01_000003 is : 143
2015-09-24 11:45:36,938 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0042_01_000004 is : 143
2015-09-24 11:45:37,059 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0041_01_000002 is : 143
2015-09-24 11:45:38,288 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/fieldedpipesplatform/testSplitComplex/splitcomp2/_temporary
2015-09-24 11:45:38,290 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/fieldedpipesplatform/testSplitComplex/splitcomp1/_temporary
2015-09-24 11:45:38,297 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [left+right]  completed in: 01:52.088
2015-09-24 11:45:38,342 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/fieldedpipesplatform/testSplitComplex/splitcomp1
2015-09-24 11:45:38,350 INFO  cascading.PlatformTestCase (PlatformTestCase.java:tearDown(189)) - copying to local /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output//hadoop2-mr1/fieldedpipesplatform/testSplitComplex/splitcomp2
2015-09-24 11:45:38,372 INFO  util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 11:45:38,372 INFO  planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 11:45:38,391 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.016
2015-09-24 11:45:38,392 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 11:45:38,393 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 11:45:38,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 11:45:38,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  source: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 11:45:38,402 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/fieldedpipesplatform/testNoGroup/nogroup"]
2015-09-24 11:45:38,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  parallel execution of steps is enabled: true
2015-09-24 11:45:38,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  executing total steps: 1
2015-09-24 11:45:38,404 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  allocating management threads: 1
2015-09-24 11:45:38,406 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tform/testNoGroup/nogroup
2015-09-24 11:45:38,537 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443107256790_0043
2015-09-24 11:45:38,538 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:56115/proxy/application_1443107256790_0043/
2015-09-24 11:45:59,995 WARN  containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443107256790_0043_01_000008
2015-09-24 11:46:19,591 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0043_01_000002 is : 143
2015-09-24 11:46:19,636 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0043_01_000003 is : 143
2015-09-24 11:46:19,792 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0043_01_000005 is : 143
2015-09-24 11:46:19,977 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0043_01_000006 is : 143
2015-09-24 11:46:20,028 WARN  nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443107256790_0043_01_000004 is : 143
2015-09-24 11:46:21,234 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/fieldedpipesplatform/testNoGroup/nogroup/_temporary
2015-09-24 11:46:21,236 INFO  flow.Flow (BaseFlow.java:logInfo(1433)) - [test]  completed in: 00:42.828
2015-09-24 11:46:21,298 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/fieldedpipesplatform/testNoGroup/nogroup

Standard error

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