2015-09-24 14:40:37,207 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(195)) - found 1 test platforms from classpath
2015-09-24 14:40:37,239 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(244)) - adding test: cascading.tap.hadoop.HadoopTapPlatformTest, with platform: hadoop2-mr1
2015-09-24 14:40:37,259 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(136)) - using cluster
2015-09-24 14:40:49,149 WARN util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
Formatting using clusterid: testClusterID
2015-09-24 14:40:49,725 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-09-24 14:40:53,890 WARN fair.AllocationFileLoaderService (AllocationFileLoaderService.java:getAllocationFile(179)) - fair-scheduler.xml not found on the classpath.
2015-09-24 14:40:54,202 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:40:54,456 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:40:54,686 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:40:54,960 WARN containermanager.AuxServices (AuxServices.java:serviceInit(130)) - The Auxilurary Service named 'mapreduce_shuffle' in the configuration is for class class org.apache.hadoop.mapred.ShuffleHandler which has a name of 'httpshuffle'. Because these are not the same tools trying to send ServiceData and read Service Meta Data may have issues unless the refer to the name in the config.
2015-09-24 14:41:12,095 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(73)) - platform property overrides:
2015-09-24 14:41:12,207 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:41:12,208 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:41:12,267 INFO property.AppProps (AppProps.java:getAppID(177)) - using app.id: 4893776C232B4C68876CB883AEE28511
2015-09-24 14:41:12,376 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.069
2015-09-24 14:41:12,380 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:41:12,381 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:41:12,491 INFO util.Version (Version.java:printBanner(82)) - Concurrent, Inc - Cascading 3.0.2
2015-09-24 14:41:12,492 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:41:12,493 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["CommentScheme[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/comments+lower.txt"]
2015-09-24 14:41:12,493 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/hadooptapplatform/testNullsFromScheme/testnulls"]
2015-09-24 14:41:12,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:41:12,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:41:12,494 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:41:12,496 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...NullsFromScheme/testnulls
2015-09-24 14:41:13,402 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120066575_0001
2015-09-24 14:41:13,403 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:51532/proxy/application_1443120066575_0001/
2015-09-24 14:41:47,417 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0001_01_000002 is : 143
2015-09-24 14:41:48,748 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/hadooptapplatform/testNullsFromScheme/testnulls/_temporary
2015-09-24 14:41:48,751 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:36.251
2015-09-24 14:41:48,839 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/hadooptapplatform/testNullsFromScheme/testnulls
2015-09-24 14:41:48,913 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:41:48,913 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:41:48,979 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.059
2015-09-24 14:41:48,982 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:41:48,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 14:41:48,986 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/hadooptapplatform/testMissingInputFormat/missinginputformat
2015-09-24 14:41:49,177 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:41:49,249 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:41:49,351 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:41:49,388 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:41:49,428 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:41:49,429 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:41:49,465 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.030
2015-09-24 14:41:49,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:41:49,467 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:41:49,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:41:49,487 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/lower.txt"]
2015-09-24 14:41:49,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["ResolvedScheme[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testResolvedSinkFields/resolvedfields"]
2015-09-24 14:41:49,487 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:41:49,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:41:49,488 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:41:49,489 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...SinkFields/resolvedfields
2015-09-24 14:41:49,724 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120066575_0002
2015-09-24 14:41:49,725 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:51532/proxy/application_1443120066575_0002/
2015-09-24 14:42:11,478 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0002_01_000008
2015-09-24 14:42:31,165 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0002_01_000006 is : 143
2015-09-24 14:42:31,357 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0002_01_000002 is : 143
2015-09-24 14:42:31,396 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0002_01_000004 is : 143
2015-09-24 14:42:31,618 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0002_01_000003 is : 143
2015-09-24 14:42:31,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0002_01_000005 is : 143
2015-09-24 14:42:32,947 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/hadooptapplatform/testResolvedSinkFields/resolvedfields/_temporary
2015-09-24 14:42:32,950 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:43.457
2015-09-24 14:42:33,004 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/hadooptapplatform/testResolvedSinkFields/resolvedfields
2015-09-24 14:42:33,084 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:42:33,085 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:42:33,112 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.023
2015-09-24 14:42:33,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:42:33,113 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:42:33,115 INFO hadoop.Hfs (Hfs.java:makeLocal(428)) - forcing job to local mode, via source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:42:33,142 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:42:33,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 14:42:33,173 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.026
2015-09-24 14:42:33,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:42:33,175 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:42:33,222 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting
2015-09-24 14:42:33,224 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] parallel execution of flows is enabled: true
2015-09-24 14:42:33,225 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] executing total flows: 2
2015-09-24 14:42:33,225 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] allocating management threads: 2
2015-09-24 14:42:33,226 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: first
2015-09-24 14:42:33,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2015-09-24 14:42:33,226 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 18:59:59 EST 1969
2015-09-24 14:42:33,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2015-09-24 14:42:33,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] source: GlobHfs[/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/?{ppe[_r],owe?}.txt]
2015-09-24 14:42:33,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testGlobHfs/glob"]
2015-09-24 14:42:33,231 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2015-09-24 14:42:33,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2015-09-24 14:42:33,232 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2015-09-24 14:42:33,233 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...platform/testGlobHfs/glob
2015-09-24 14:42:33,516 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_local779730999_0001
2015-09-24 14:42:33,517 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://localhost:8080/
2015-09-24 14:42:33,566 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt
2015-09-24 14:42:33,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 14:42:33,582 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx512m
2015-09-24 14:42:33,592 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B80E0BE045B44A34B57F2C968D26A83A, ordinal: 0
2015-09-24 14:42:33,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: GlobHfs[/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/?{ppe[_r],owe?}.txt]
2015-09-24 14:42:33,619 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testGlobHfs/glob"]
2015-09-24 14:42:33,620 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B80E0BE045B44A34B57F2C968D26A83A, mem on start (mb), free: 112, total: 312, max: 672
2015-09-24 14:42:33,628 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B80E0BE045B44A34B57F2C968D26A83A, mem on close (mb), free: 111, total: 312, max: 672
2015-09-24 14:42:33,675 INFO io.MultiInputSplit (MultiInputSplit.java:readFields(161)) - current split input path: file:/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt
2015-09-24 14:42:33,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(75)) - cascading version: 3.0.2
2015-09-24 14:42:33,682 INFO hadoop.FlowMapper (FlowMapper.java:configure(76)) - child jvm opts: -Xmx512m
2015-09-24 14:42:33,691 INFO hadoop.FlowMapper (FlowMapper.java:configure(87)) - flow node id: B80E0BE045B44A34B57F2C968D26A83A, ordinal: 0
2015-09-24 14:42:33,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(94)) - sourcing from: GlobHfs[/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/?{ppe[_r],owe?}.txt]
2015-09-24 14:42:33,692 INFO hadoop.FlowMapper (FlowMapper.java:configure(97)) - sinking to: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testGlobHfs/glob"]
2015-09-24 14:42:33,692 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B80E0BE045B44A34B57F2C968D26A83A, mem on start (mb), free: 109, total: 312, max: 672
2015-09-24 14:42:33,694 INFO hadoop.FlowMapper (LogUtil.java:logMemory(59)) - flow node id: B80E0BE045B44A34B57F2C968D26A83A, mem on close (mb), free: 109, total: 312, max: 672
2015-09-24 14:42:33,778 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/hadooptapplatform/testGlobHfs/glob/_temporary
2015-09-24 14:42:33,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:00.545
2015-09-24 14:42:33,780 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: first
2015-09-24 14:42:33,780 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: second
2015-09-24 14:42:33,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] at least one sink is marked for delete
2015-09-24 14:42:33,781 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink oldest modified date: Wed Dec 31 18:59:59 EST 1969
2015-09-24 14:42:33,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2015-09-24 14:42:33,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testGlobHfs/glob"]
2015-09-24 14:42:33,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testGlobHfs/glob2"]
2015-09-24 14:42:33,786 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] parallel execution of steps is enabled: true
2015-09-24 14:42:33,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executing total steps: 1
2015-09-24 14:42:33,787 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] allocating management threads: 1
2015-09-24 14:42:33,789 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...latform/testGlobHfs/glob2
2015-09-24 14:42:34,008 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted hadoop job: job_1443120066575_0003
2015-09-24 14:42:34,008 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tracking url: http://localhost:51532/proxy/application_1443120066575_0003/
2015-09-24 14:43:13,350 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0003_01_000002 is : 143
2015-09-24 14:43:13,474 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0003_01_000005 is : 143
2015-09-24 14:43:13,481 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0003_01_000004 is : 143
2015-09-24 14:43:13,732 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0003_01_000003 is : 143
2015-09-24 14:43:15,024 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testGlobHfs/glob2/_temporary
2015-09-24 14:43:15,027 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] completed in: 00:41.235
2015-09-24 14:43:15,028 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: second
2015-09-24 14:43:15,051 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/hadooptapplatform/testGlobHfs/glob
2015-09-24 14:43:15,065 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/hadooptapplatform/testGlobHfs/glob2
2015-09-24 14:43:15,108 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:43:15,108 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:43:15,156 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-09-24 14:43:15,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:43:15,158 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:43:15,185 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:43:15,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: ["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:43:15,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testPrepareResource/preparetap"]
2015-09-24 14:43:15,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:43:15,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:43:15,186 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:43:15,188 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...repareResource/preparetap
2015-09-24 14:43:15,343 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120066575_0004
2015-09-24 14:43:15,344 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:51532/proxy/application_1443120066575_0004/
2015-09-24 14:43:54,633 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0004_01_000005 is : 143
2015-09-24 14:43:54,762 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0004_01_000003 is : 143
2015-09-24 14:43:54,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0004_01_000002 is : 143
2015-09-24 14:43:54,941 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0004_01_000004 is : 143
2015-09-24 14:44:12,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0004_01_000006 is : 143
2015-09-24 14:44:13,939 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/hadooptapplatform/testPrepareResource/preparetap/_temporary
2015-09-24 14:44:13,941 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:58.752
2015-09-24 14:44:13,962 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/hadooptapplatform/testPrepareResource/preparetap
2015-09-24 14:44:13,993 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:44:13,994 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:44:14,048 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.050
2015-09-24 14:44:14,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:44:14,052 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:44:14,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting
2015-09-24 14:44:14,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["DupeConfigScheme[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/upper.txt"]
2015-09-24 14:44:14,069 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/lower.txt"]
2015-09-24 14:44:14,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] sink: Hfs["TextLine[['line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testDupeConfigFromScheme/dupeconfig"]
2015-09-24 14:44:14,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] parallel execution of steps is enabled: true
2015-09-24 14:44:14,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] executing total steps: 1
2015-09-24 14:44:14,070 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] allocating management threads: 1
2015-09-24 14:44:14,071 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] starting step: (1/1) ...nfigFromScheme/dupeconfig
2015-09-24 14:44:14,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] submitted hadoop job: job_1443120066575_0005
2015-09-24 14:44:14,266 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] tracking url: http://localhost:51532/proxy/application_1443120066575_0005/
2015-09-24 14:44:35,762 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0005_01_000008
2015-09-24 14:44:55,658 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0005_01_000002 is : 143
2015-09-24 14:44:55,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0005_01_000004 is : 143
2015-09-24 14:44:56,014 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0005_01_000006 is : 143
2015-09-24 14:44:56,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0005_01_000005 is : 143
2015-09-24 14:44:56,242 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0005_01_000003 is : 143
2015-09-24 14:44:57,462 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/hadooptapplatform/testDupeConfigFromScheme/dupeconfig/_temporary
2015-09-24 14:44:57,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [lower*upper] completed in: 00:43.390
2015-09-24 14:44:57,532 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/hadooptapplatform/testDupeConfigFromScheme/dupeconfig
2015-09-24 14:44:57,572 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:44:57,572 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:44:57,616 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.040
2015-09-24 14:44:57,618 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:44:57,619 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:44:57,650 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:44:57,650 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:44:57,675 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.021
2015-09-24 14:44:57,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 1
2015-09-24 14:44:57,677 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:44:57,739 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting
2015-09-24 14:44:57,740 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] parallel execution of flows is enabled: true
2015-09-24 14:44:57,741 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] executing total flows: 2
2015-09-24 14:44:57,741 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] allocating management threads: 2
2015-09-24 14:44:57,741 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: first
2015-09-24 14:44:57,742 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] at least one sink is marked for delete
2015-09-24 14:44:57,742 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink oldest modified date: Wed Dec 31 18:59:59 EST 1969
2015-09-24 14:44:57,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting
2015-09-24 14:44:57,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] source: MultiSourceTap[2:[GlobHfs[/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/?{ppe[_r]}.txt], GlobHfs[/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/?{owe?}.txt]]]
2015-09-24 14:44:57,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource"]
2015-09-24 14:44:57,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] parallel execution of steps is enabled: true
2015-09-24 14:44:57,746 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] executing total steps: 1
2015-09-24 14:44:57,747 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] allocating management threads: 1
2015-09-24 14:44:57,748 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] starting step: (1/1) ...ceGlobHfs/globmultisource
2015-09-24 14:44:57,891 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] submitted hadoop job: job_1443120066575_0006
2015-09-24 14:44:57,891 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] tracking url: http://localhost:51532/proxy/application_1443120066575_0006/
2015-09-24 14:45:19,064 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0006_01_000009
2015-09-24 14:45:19,259 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0006_01_000010
2015-09-24 14:45:41,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0006_01_000007 is : 143
2015-09-24 14:45:41,595 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0006_01_000003 is : 143
2015-09-24 14:45:41,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0006_01_000006 is : 143
2015-09-24 14:45:41,945 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0006_01_000002 is : 143
2015-09-24 14:45:41,965 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0006_01_000005 is : 143
2015-09-24 14:45:42,531 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0006_01_000004 is : 143
2015-09-24 14:45:43,766 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/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource/_temporary
2015-09-24 14:45:43,771 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [first] completed in: 00:46.016
2015-09-24 14:45:43,772 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: first
2015-09-24 14:45:43,772 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] starting flow: second
2015-09-24 14:45:43,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] at least one sink is marked for delete
2015-09-24 14:45:43,773 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink oldest modified date: Wed Dec 31 18:59:59 EST 1969
2015-09-24 14:45:43,777 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting
2015-09-24 14:45:43,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource"]
2015-09-24 14:45:43,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultiource2"]
2015-09-24 14:45:43,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] parallel execution of steps is enabled: true
2015-09-24 14:45:43,778 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] executing total steps: 1
2015-09-24 14:45:43,779 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] allocating management threads: 1
2015-09-24 14:45:43,780 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] starting step: (1/1) ...ceGlobHfs/globmultiource2
2015-09-24 14:45:43,939 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] submitted hadoop job: job_1443120066575_0007
2015-09-24 14:45:43,940 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] tracking url: http://localhost:51532/proxy/application_1443120066575_0007/
2015-09-24 14:46:05,016 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0007_01_000011
2015-09-24 14:46:05,573 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0007_01_000012
2015-09-24 14:46:05,634 WARN containermanager.ContainerManagerImpl (ContainerManagerImpl.java:handle(1065)) - Event EventType: KILL_CONTAINER sent to absent container container_1443120066575_0007_01_000013
2015-09-24 14:46:30,545 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000007 is : 143
2015-09-24 14:46:30,928 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000008 is : 143
2015-09-24 14:46:30,973 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000005 is : 143
2015-09-24 14:46:31,120 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000002 is : 143
2015-09-24 14:46:31,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000009 is : 143
2015-09-24 14:46:31,281 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000004 is : 143
2015-09-24 14:46:31,298 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000006 is : 143
2015-09-24 14:46:31,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0007_01_000003 is : 143
2015-09-24 14:46:32,634 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/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultiource2/_temporary
2015-09-24 14:46:32,636 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [second] completed in: 00:48.853
2015-09-24 14:46:32,636 INFO cascade.Cascade (BaseCascade.java:logInfo(860)) - [first+second] completed flow: second
2015-09-24 14:46:32,666 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/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultisource
2015-09-24 14:46:32,689 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/hadooptapplatform/testNestedMultiSourceGlobHfs/globmultiource2
2015-09-24 14:46:32,762 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:46:32,763 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:46:32,808 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.041
2015-09-24 14:46:32,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:46:32,810 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:46:32,827 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:46:32,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:46:32,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testPrepareResourceForWriteFails/preparewritetapfail"]
2015-09-24 14:46:32,828 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:46:32,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:46:32,829 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:46:32,831 ERROR flow.Flow (BaseFlow.java:logError(1469)) - [test] unable to prepare tap for write: hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testPrepareResourceForWriteFails/preparewritetapfail
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$7.prepareResourceForWrite(HadoopTapPlatformTest.java:774)
at cascading.tap.hadoop.HadoopTapPlatformTest$7.prepareResourceForWrite(HadoopTapPlatformTest.java:770)
at cascading.flow.planner.BaseFlowStep.prepareResource(BaseFlowStep.java:567)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:549)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:535)
at cascading.flow.planner.FlowStepJob.prepareResources(FlowStepJob.java:217)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:180)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2015-09-24 14:46:32,835 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-09-24 14:46:32,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...Fails/preparewritetapfail
2015-09-24 14:46:32,836 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-09-24 14:46:32,838 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.009
2015-09-24 14:46:32,838 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/hadooptapplatform/testPrepareResourceForWriteFails/preparewritetapfail
2015-09-24 14:46:32,855 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:46:32,855 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:46:32,907 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.035
2015-09-24 14:46:32,908 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:46:32,909 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:46:32,924 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:46:32,924 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: ["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:46:32,924 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: Hfs["TextDelimited[['ip', 'count']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testPrepareResourceForReadFails/preparereadtapfail"]
2015-09-24 14:46:32,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:46:32,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:46:32,925 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:46:32,926 ERROR flow.Flow (BaseFlow.java:logError(1469)) - [test] unable to prepare tap for read: hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$6.prepareResourceForRead(HadoopTapPlatformTest.java:726)
at cascading.tap.hadoop.HadoopTapPlatformTest$6.prepareResourceForRead(HadoopTapPlatformTest.java:722)
at cascading.flow.planner.BaseFlowStep.prepareResource(BaseFlowStep.java:569)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:549)
at cascading.flow.planner.BaseFlowStep.prepareResources(BaseFlowStep.java:532)
at cascading.flow.planner.FlowStepJob.prepareResources(FlowStepJob.java:217)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:180)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2015-09-24 14:46:32,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-09-24 14:46:32,927 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...dFails/preparereadtapfail
2015-09-24 14:46:32,928 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-09-24 14:46:32,929 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:00.004
2015-09-24 14:46:32,930 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/hadooptapplatform/testPrepareResourceForReadFails/preparereadtapfail
2015-09-24 14:46:32,945 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:46:32,945 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:46:32,980 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.031
2015-09-24 14:46:32,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:46:32,981 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:46:32,995 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:46:32,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:46:32,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testCommitResourceFails/committapfail"]
2015-09-24 14:46:32,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:46:32,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:46:32,996 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:46:32,998 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...sourceFails/committapfail
2015-09-24 14:46:33,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120066575_0008
2015-09-24 14:46:33,144 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:51532/proxy/application_1443120066575_0008/
2015-09-24 14:47:11,480 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0008_01_000005 is : 143
2015-09-24 14:47:11,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0008_01_000002 is : 143
2015-09-24 14:47:11,611 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0008_01_000004 is : 143
2015-09-24 14:47:11,659 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0008_01_000003 is : 143
2015-09-24 14:47:29,158 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0008_01_000006 is : 143
2015-09-24 14:47:30,335 ERROR flow.Flow (BaseFlow.java:logError(1469)) - [test] unable to commit sink: hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testCommitResourceFails/committapfail
java.io.IOException: failed intentionally
at cascading.tap.hadoop.HadoopTapPlatformTest$2.commitResource(HadoopTapPlatformTest.java:400)
at cascading.tap.hadoop.HadoopTapPlatformTest$2.commitResource(HadoopTapPlatformTest.java:396)
at cascading.flow.planner.BaseFlowStep.commitResource(BaseFlowStep.java:613)
at cascading.flow.planner.BaseFlowStep.commitSinks(BaseFlowStep.java:601)
at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:297)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:184)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:146)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:48)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
2015-09-24 14:47:30,369 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping all jobs
2015-09-24 14:47:30,370 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopping: (1/1) ...sourceFails/committapfail
2015-09-24 14:47:30,372 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] stopped all jobs
2015-09-24 14:47:30,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/hadooptapplatform/testCommitResourceFails/committapfail/_temporary
2015-09-24 14:47:30,377 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:57.377
2015-09-24 14:47:30,378 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/hadooptapplatform/testCommitResourceFails/committapfail
2015-09-24 14:47:30,409 INFO util.Util (Util.java:findMainClass(1327)) - using default application jar, may cause class not found exceptions on the cluster
2015-09-24 14:47:30,409 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(174)) - using application jar: /Users/ryan/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/3.0.2/a7e0a109fe1f98639fc92e32694f202ce66d81a8/cascading-hadoop2-mr1-3.0.2.jar
2015-09-24 14:47:30,447 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executed rule registry: MapReduceHadoopRuleRegistry, completed as: SUCCESS, in: 00:00.034
2015-09-24 14:47:30,449 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, supports assembly with steps: 1, nodes: 2
2015-09-24 14:47:30,449 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] rule registry: MapReduceHadoopRuleRegistry, result was selected using: 'default comparator: selects plan with fewest steps and fewest nodes'
2015-09-24 14:47:30,463 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting
2015-09-24 14:47:30,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/classes/test/data/apache.10.txt"]
2015-09-24 14:47:30,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] sink: ["TextDelimited[['ip', 'count']]"]["/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testCommitResource/committap"]
2015-09-24 14:47:30,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] parallel execution of steps is enabled: true
2015-09-24 14:47:30,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] executing total steps: 1
2015-09-24 14:47:30,464 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] allocating management threads: 1
2015-09-24 14:47:30,466 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] starting step: (1/1) ...tCommitResource/committap
2015-09-24 14:47:30,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] submitted hadoop job: job_1443120066575_0009
2015-09-24 14:47:30,642 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] tracking url: http://localhost:51532/proxy/application_1443120066575_0009/
2015-09-24 14:48:09,623 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0009_01_000002 is : 143
2015-09-24 14:48:09,720 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0009_01_000003 is : 143
2015-09-24 14:48:09,780 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0009_01_000005 is : 143
2015-09-24 14:48:09,852 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0009_01_000004 is : 143
2015-09-24 14:48:27,094 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1443120066575_0009_01_000006 is : 143
2015-09-24 14:48:28,308 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/hadooptapplatform/testCommitResource/committap/_temporary
2015-09-24 14:48:28,311 INFO flow.Flow (BaseFlow.java:logInfo(1433)) - [test] completed in: 00:57.842
2015-09-24 14:48:28,329 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/hadooptapplatform/testCommitResource/committap
2015-09-24 14:48:28,366 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,367 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-09-24 14:48:28,369 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/A/part-00000
2015-09-24 14:48:28,387 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,396 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/A
2015-09-24 14:48:28,398 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/A/_temporary
2015-09-24 14:48:28,405 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,406 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-09-24 14:48:28,409 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/B/part-00000
2015-09-24 14:48:28,429 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,438 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/B
2015-09-24 14:48:28,440 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/multifiles/B/_temporary
2015-09-24 14:48:28,487 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,487 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-09-24 14:48:28,490 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/part-00000
2015-09-24 14:48:28,506 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,515 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/A
2015-09-24 14:48:28,516 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/A/_temporary
2015-09-24 14:48:28,522 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,522 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-09-24 14:48:28,526 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/part-00000
2015-09-24 14:48:28,542 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,551 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/B
2015-09-24 14:48:28,552 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/B/_temporary
2015-09-24 14:48:28,557 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:setupTask(105)) - setting up task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,557 INFO io.TapOutputCollector (TapOutputCollector.java:initialize(117)) - creating path: part-00000
2015-09-24 14:48:28,560 INFO io.TapOutputCollector (TapOutputCollector.java:close(150)) - closing tap collector for: /Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/part-00000
2015-09-24 14:48:28,576 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(162)) - committing task: 'attempt_002147483647_0000_m_000000_0' - hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/_temporary/_attempt_002147483647_0000_m_000000_0
2015-09-24 14:48:28,590 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:commitTask(179)) - saved output of task 'attempt_002147483647_0000_m_000000_0' to hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden
2015-09-24 14:48:28,591 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(226)) - deleting temp path hdfs://localhost:51504/Users/ryan/concurrent_2015/compat_suite/new/cascading.compatibility/cloudera/build/test/output/hadoop2-mr1/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden/_temporary
2015-09-24 14:48:28,612 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/hadooptapplatform/testChildIdentifiers/hiddenfiles/B
2015-09-24 14:48:28,618 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/hadooptapplatform/testChildIdentifiers/hiddenfiles
2015-09-24 14:48:28,634 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/hadooptapplatform/testChildIdentifiers/hiddenfiles/A
2015-09-24 14:48:28,642 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/hadooptapplatform/testChildIdentifiers/multifiles
2015-09-24 14:48:28,656 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/hadooptapplatform/testChildIdentifiers/multifiles/A
2015-09-24 14:48:28,665 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/hadooptapplatform/testChildIdentifiers/multifiles/B
2015-09-24 14:48:28,672 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/hadooptapplatform/testChildIdentifiers/hiddenfiles/.hidden