2015-08-14 03:52:57,750 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 03:52:57,813 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 03:52:57,813 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.hadoop.RiffleCascadePlatformTest
2015-08-14 03:52:57,853 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 03:52:58,730 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-08-14 03:52:59,493 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 03:53:00,114 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(158)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 03:53:03,825 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-08-14 03:53:04,074 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-08-14 03:53:04,250 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-08-14 03:53:04,439 WARN containermanager.AuxServices (AuxServices.java:serviceInit(114)) - 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-08-14 03:53:21,555 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 03:53:21,678 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: BC5EC9FF7398439DAD6ACE4E16B76948
2015-08-14 03:53:21,751 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/children/first
2015-08-14 03:53:21,788 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/stopException/first
2015-08-14 03:53:21,838 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:53:21,841 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:53:22,024 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:53:22,025 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:53:22,087 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:53:22,088 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:53:22,176 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:53:22,177 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:53:22,269 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 03:53:22,271 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 03:53:22,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 03:53:22,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first"]
2015-08-14 03:53:22,272 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 03:53:22,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 03:53:22,273 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 03:53:22,274 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...eplatform/perpetual/first
2015-08-14 03:53:23,287 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439524396051_0001
2015-08-14 03:53:23,288 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0001/
2015-08-14 03:53:37,406 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0001_01_000003 is : 143
2015-08-14 03:53:37,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0001_01_000005 is : 143
2015-08-14 03:53:37,707 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0001_01_000002 is : 143
2015-08-14 03:53:37,747 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0001_01_000004 is : 143
2015-08-14 03:53:39,144 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first/_temporary
2015-08-14 03:53:39,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 03:53:39,150 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first"]
2015-08-14 03:53:39,151 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second"]
2015-08-14 03:53:39,151 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 03:53:39,151 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 03:53:39,151 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 03:53:39,152 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...platform/perpetual/second
2015-08-14 03:53:39,452 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439524396051_0002
2015-08-14 03:53:39,452 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0002/
2015-08-14 03:53:53,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0002_01_000006 is : 143
2015-08-14 03:53:54,168 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0002_01_000005 is : 143
2015-08-14 03:53:54,207 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0002_01_000004 is : 143
2015-08-14 03:53:54,344 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0002_01_000003 is : 143
2015-08-14 03:53:54,382 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0002_01_000002 is : 143
2015-08-14 03:53:55,698 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second/_temporary
2015-08-14 03:53:55,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 03:53:55,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second"]
2015-08-14 03:53:55,703 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third"]
2015-08-14 03:53:55,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 03:53:55,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-08-14 03:53:55,704 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-08-14 03:53:55,705 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...eplatform/perpetual/third
2015-08-14 03:53:55,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439524396051_0003
2015-08-14 03:53:55,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0003/
2015-08-14 03:54:10,679 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0003_01_000003 is : 143
2015-08-14 03:54:10,738 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0003_01_000002 is : 143
2015-08-14 03:54:11,154 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0003_01_000006 is : 143
2015-08-14 03:54:11,283 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0003_01_000005 is : 143
2015-08-14 03:54:11,316 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0003_01_000004 is : 143
2015-08-14 03:54:11,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0003_01_000007 is : 143
2015-08-14 03:54:12,650 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third/_temporary
2015-08-14 03:54:12,654 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 03:54:12,654 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third"]
2015-08-14 03:54:12,654 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/fourth"]
2015-08-14 03:54:12,654 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-08-14 03:54:12,655 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-08-14 03:54:12,655 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-08-14 03:54:12,656 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...platform/perpetual/fourth
2015-08-14 03:54:12,881 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1439524396051_0004
2015-08-14 03:54:12,881 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0004/
2015-08-14 03:54:29,441 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000003 is : 143
2015-08-14 03:54:29,552 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000002 is : 143
2015-08-14 03:54:29,988 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000007 is : 143
2015-08-14 03:54:30,060 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000006 is : 143
2015-08-14 03:54:30,116 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000004 is : 143
2015-08-14 03:54:30,151 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000005 is : 143
2015-08-14 03:54:30,185 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0004_01_000008 is : 143
2015-08-14 03:54:31,524 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/fourth/_temporary
2015-08-14 03:54:31,582 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/third
2015-08-14 03:54:31,603 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/first
2015-08-14 03:54:31,620 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/second
2015-08-14 03:54:31,638 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/fourth
2015-08-14 03:54:31,684 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:54:31,684 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:54:31,725 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:54:31,726 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:54:31,766 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:54:31,767 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:54:31,806 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 03:54:31,807 INFO planner.HadoopPlanner (HadoopPlanner.java:initialize(226)) - using application jar: /opt/concurrent/home/teamcity/.gradle/caches/modules-2/files-2.1/cascading/cascading-hadoop2-mr1/2.7.1/78a07fbd83388056abdb4b5e48f666735b06cf7c/cascading-hadoop2-mr1-2.7.1.jar
2015-08-14 03:54:31,906 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting
2015-08-14 03:54:31,909 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] parallel execution is enabled: false
2015-08-14 03:54:31,909 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flows: 4
2015-08-14 03:54:31,910 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] allocating threads: 1
2015-08-14 03:54:31,911 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: first
2015-08-14 03:54:31,912 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 03:54:31,912 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 03:54:31,921 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 03:54:31,922 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/classes/test/data/ips.20.txt"]
2015-08-14 03:54:31,922 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first"]
2015-08-14 03:54:31,922 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 03:54:31,922 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 03:54:31,923 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 03:54:31,924 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...rm/perpetualcascade/first
2015-08-14 03:54:32,186 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439524396051_0005
2015-08-14 03:54:32,187 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0005/
2015-08-14 03:54:46,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0005_01_000005 is : 143
2015-08-14 03:54:46,153 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0005_01_000003 is : 143
2015-08-14 03:54:46,199 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0005_01_000004 is : 143
2015-08-14 03:54:46,276 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0005_01_000002 is : 143
2015-08-14 03:54:47,571 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first/_temporary
2015-08-14 03:54:47,572 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: first
2015-08-14 03:54:47,573 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: second
2015-08-14 03:54:47,573 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 03:54:47,573 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 03:54:47,578 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 03:54:47,579 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first"]
2015-08-14 03:54:47,580 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second"]
2015-08-14 03:54:47,580 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 03:54:47,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 03:54:47,581 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 03:54:47,582 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...m/perpetualcascade/second
2015-08-14 03:54:47,783 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439524396051_0006
2015-08-14 03:54:47,783 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0006/
2015-08-14 03:55:01,942 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0006_01_000002 is : 143
2015-08-14 03:55:02,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0006_01_000003 is : 143
2015-08-14 03:55:02,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0006_01_000005 is : 143
2015-08-14 03:55:02,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0006_01_000006 is : 143
2015-08-14 03:55:02,746 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0006_01_000004 is : 143
2015-08-14 03:55:04,026 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second/_temporary
2015-08-14 03:55:04,027 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: second
2015-08-14 03:55:04,027 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: third
2015-08-14 03:55:04,028 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-08-14 03:55:04,028 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 03:55:04,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 03:55:04,033 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second"]
2015-08-14 03:55:04,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third"]
2015-08-14 03:55:04,034 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 03:55:04,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-08-14 03:55:04,035 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-08-14 03:55:04,037 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...rm/perpetualcascade/third
2015-08-14 03:55:04,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439524396051_0007
2015-08-14 03:55:04,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0007/
2015-08-14 03:55:19,177 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0007_01_000003 is : 143
2015-08-14 03:55:19,415 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0007_01_000002 is : 143
2015-08-14 03:55:19,872 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0007_01_000007 is : 143
2015-08-14 03:55:19,912 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0007_01_000005 is : 143
2015-08-14 03:55:19,947 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0007_01_000006 is : 143
2015-08-14 03:55:20,253 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0007_01_000004 is : 143
2015-08-14 03:55:21,549 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third/_temporary
2015-08-14 03:55:21,550 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: third
2015-08-14 03:55:21,551 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: fourth
2015-08-14 03:55:21,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-08-14 03:55:21,551 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 03:55:21,556 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 03:55:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third"]
2015-08-14 03:55:21,557 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth"]
2015-08-14 03:55:21,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-08-14 03:55:21,558 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-08-14 03:55:21,559 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-08-14 03:55:21,560 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...m/perpetualcascade/fourth
2015-08-14 03:55:21,741 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1439524396051_0008
2015-08-14 03:55:21,741 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://ip-10-235-34-50.ec2.internal:59892/proxy/application_1439524396051_0008/
2015-08-14 03:55:38,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000003 is : 143
2015-08-14 03:55:38,099 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000006 is : 143
2015-08-14 03:55:38,123 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000002 is : 143
2015-08-14 03:55:38,434 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000004 is : 143
2015-08-14 03:55:38,468 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000005 is : 143
2015-08-14 03:55:38,496 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000008 is : 143
2015-08-14 03:55:38,664 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439524396051_0008_01_000007 is : 143
2015-08-14 03:55:39,977 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth/_temporary
2015-08-14 03:55:39,978 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: fourth
2015-08-14 03:55:40,018 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second
2015-08-14 03:55:40,035 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third
2015-08-14 03:55:40,054 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth
2015-08-14 03:55:40,074 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first
2015-08-14 03:55:40,111 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/counter/first
2015-08-14 03:55:40,132 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/completeException/first
2015-08-14 03:55:40,152 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.3.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/startException/first