2015-08-14 05:46:12,642 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 05:46:12,717 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 05:46:12,717 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.hadoop.RiffleCascadePlatformTest
2015-08-14 05:46:12,770 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 05:46:13,716 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 05:46:14,616 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 05:46:15,236 WARN server.AuthenticationFilter (AuthenticationFilter.java:init(162)) - 'signature.secret' configuration not set, using a random value as secret
2015-08-14 05:46:19,117 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 05:46:19,338 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 05:46:19,512 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 05:46:19,696 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 05:46:36,808 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 05:46:36,933 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 84AC92CBB58549CA923C614C86A97F15
2015-08-14 05:46:37,004 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/children/first
2015-08-14 05:46:37,043 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/stopException/first
2015-08-14 05:46:37,096 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:46:37,099 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 05:46:37,311 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:46:37,312 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 05:46:37,364 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:46:37,365 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 05:46:37,415 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:46:37,416 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 05:46:37,510 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 05:46:37,511 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 05:46:37,511 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/ips.20.txt"]
2015-08-14 05:46:37,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first"]
2015-08-14 05:46:37,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 05:46:37,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 05:46:37,512 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 05:46:37,514 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...eplatform/perpetual/first
2015-08-14 05:46:38,557 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439531191306_0001
2015-08-14 05:46:38,558 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0001/
2015-08-14 05:46:52,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0001_01_000004 is : 143
2015-08-14 05:46:53,160 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0001_01_000005 is : 143
2015-08-14 05:46:53,192 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0001_01_000003 is : 143
2015-08-14 05:46:53,250 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0001_01_000002 is : 143
2015-08-14 05:46:54,707 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first/_temporary
2015-08-14 05:46:54,712 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 05:46:54,712 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/first"]
2015-08-14 05:46:54,713 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second"]
2015-08-14 05:46:54,713 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 05:46:54,713 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 05:46:54,713 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 05:46:54,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...platform/perpetual/second
2015-08-14 05:46:54,971 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439531191306_0002
2015-08-14 05:46:54,972 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0002/
2015-08-14 05:47:09,169 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0002_01_000002 is : 143
2015-08-14 05:47:09,223 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0002_01_000003 is : 143
2015-08-14 05:47:09,691 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0002_01_000004 is : 143
2015-08-14 05:47:09,842 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0002_01_000005 is : 143
2015-08-14 05:47:10,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0002_01_000006 is : 143
2015-08-14 05:47:11,922 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second/_temporary
2015-08-14 05:47:11,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 05:47:11,927 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/second"]
2015-08-14 05:47:11,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third"]
2015-08-14 05:47:11,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 05:47:11,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-08-14 05:47:11,928 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-08-14 05:47:11,929 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...eplatform/perpetual/third
2015-08-14 05:47:12,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439531191306_0003
2015-08-14 05:47:12,526 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0003/
2015-08-14 05:47:28,032 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0003_01_000007 is : 143
2015-08-14 05:47:28,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0003_01_000006 is : 143
2015-08-14 05:47:28,352 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0003_01_000003 is : 143
2015-08-14 05:47:28,447 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0003_01_000004 is : 143
2015-08-14 05:47:28,504 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0003_01_000005 is : 143
2015-08-14 05:47:29,203 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0003_01_000002 is : 143
2015-08-14 05:47:30,525 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third/_temporary
2015-08-14 05:47:30,528 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 05:47:30,529 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/third"]
2015-08-14 05:47:30,529 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/fourth"]
2015-08-14 05:47:30,529 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-08-14 05:47:30,529 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-08-14 05:47:30,529 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-08-14 05:47:30,530 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...platform/perpetual/fourth
2015-08-14 05:47:30,780 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1439531191306_0004
2015-08-14 05:47:30,781 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0004/
2015-08-14 05:47:46,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000003 is : 143
2015-08-14 05:47:46,960 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000002 is : 143
2015-08-14 05:47:47,317 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000008 is : 143
2015-08-14 05:47:47,354 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000006 is : 143
2015-08-14 05:47:47,402 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000007 is : 143
2015-08-14 05:47:47,654 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000005 is : 143
2015-08-14 05:47:47,696 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0004_01_000004 is : 143
2015-08-14 05:47:49,022 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetual/fourth/_temporary
2015-08-14 05:47:49,078 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/first
2015-08-14 05:47:49,097 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/fourth
2015-08-14 05:47:49,118 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/second
2015-08-14 05:47:49,136 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetual/third
2015-08-14 05:47:49,180 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:47:49,181 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 05:47:49,221 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:47:49,222 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 05:47:49,278 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:47:49,279 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 05:47:49,319 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 05:47:49,319 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 05:47:49,417 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting
2015-08-14 05:47:49,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] parallel execution is enabled: false
2015-08-14 05:47:49,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flows: 4
2015-08-14 05:47:49,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] allocating threads: 1
2015-08-14 05:47:49,421 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: first
2015-08-14 05:47:49,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 05:47:49,422 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 05:47:49,432 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 05:47:49,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/classes/test/data/ips.20.txt"]
2015-08-14 05:47:49,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first"]
2015-08-14 05:47:49,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 05:47:49,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 05:47:49,433 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 05:47:49,434 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...rm/perpetualcascade/first
2015-08-14 05:47:49,679 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439531191306_0005
2015-08-14 05:47:49,679 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0005/
2015-08-14 05:48:03,573 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0005_01_000004 is : 143
2015-08-14 05:48:03,617 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0005_01_000002 is : 143
2015-08-14 05:48:03,662 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0005_01_000003 is : 143
2015-08-14 05:48:03,719 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0005_01_000005 is : 143
2015-08-14 05:48:05,050 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first/_temporary
2015-08-14 05:48:05,051 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: first
2015-08-14 05:48:05,051 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: second
2015-08-14 05:48:05,052 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 05:48:05,052 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 05:48:05,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 05:48:05,057 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first"]
2015-08-14 05:48:05,058 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second"]
2015-08-14 05:48:05,058 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 05:48:05,058 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 05:48:05,058 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 05:48:05,059 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...m/perpetualcascade/second
2015-08-14 05:48:05,257 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439531191306_0006
2015-08-14 05:48:05,257 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0006/
2015-08-14 05:48:18,958 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0006_01_000002 is : 143
2015-08-14 05:48:19,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0006_01_000006 is : 143
2015-08-14 05:48:19,729 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0006_01_000005 is : 143
2015-08-14 05:48:19,764 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0006_01_000004 is : 143
2015-08-14 05:48:20,059 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0006_01_000003 is : 143
2015-08-14 05:48:21,347 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second/_temporary
2015-08-14 05:48:21,348 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: second
2015-08-14 05:48:21,349 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: third
2015-08-14 05:48:21,349 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-08-14 05:48:21,349 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 05:48:21,354 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 05:48:21,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second"]
2015-08-14 05:48:21,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third"]
2015-08-14 05:48:21,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 05:48:21,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-08-14 05:48:21,355 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-08-14 05:48:21,356 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...rm/perpetualcascade/third
2015-08-14 05:48:21,542 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439531191306_0007
2015-08-14 05:48:21,543 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0007/
2015-08-14 05:48:36,464 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0007_01_000002 is : 143
2015-08-14 05:48:36,652 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0007_01_000003 is : 143
2015-08-14 05:48:36,786 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0007_01_000006 is : 143
2015-08-14 05:48:37,057 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0007_01_000005 is : 143
2015-08-14 05:48:37,124 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0007_01_000004 is : 143
2015-08-14 05:48:37,847 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0007_01_000007 is : 143
2015-08-14 05:48:39,147 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third/_temporary
2015-08-14 05:48:39,148 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: third
2015-08-14 05:48:39,149 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] starting flow: fourth
2015-08-14 05:48:39,149 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-08-14 05:48:39,149 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 05:48:39,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 05:48:39,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third"]
2015-08-14 05:48:39,154 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth"]
2015-08-14 05:48:39,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-08-14 05:48:39,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-08-14 05:48:39,155 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-08-14 05:48:39,157 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...m/perpetualcascade/fourth
2015-08-14 05:48:39,341 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1439531191306_0008
2015-08-14 05:48:39,342 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://ip-10-235-34-50:33029/proxy/application_1439531191306_0008/
2015-08-14 05:48:55,306 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000002 is : 143
2015-08-14 05:48:55,489 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000003 is : 143
2015-08-14 05:48:55,765 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000006 is : 143
2015-08-14 05:48:55,802 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000007 is : 143
2015-08-14 05:48:55,887 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000004 is : 143
2015-08-14 05:48:55,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000008 is : 143
2015-08-14 05:48:56,069 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439531191306_0008_01_000005 is : 143
2015-08-14 05:48:57,418 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output/hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth/_temporary
2015-08-14 05:48:57,419 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+first+third] completed flow: fourth
2015-08-14 05:48:57,459 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/second
2015-08-14 05:48:57,475 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/fourth
2015-08-14 05:48:57,495 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/first
2015-08-14 05:48:57,510 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/perpetualcascade/third
2015-08-14 05:48:57,549 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/counter/first
2015-08-14 05:48:57,569 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/completeException/first
2015-08-14 05:48:57,589 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.4.x/build/test/output//hadoop2-mr1/rifflecascadeplatform/startException/first