2015-08-14 09:28:51,054 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 09:28:51,121 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 09:28:51,122 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.CascadePlatformTest
2015-08-14 09:28:51,160 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 09:28:52,352 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 09:28:53,237 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 09:28:58,829 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-08-14 09:28:59,173 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-08-14 09:28:59,462 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-08-14 09:28:59,762 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-08-14 09:29:16,916 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 09:29:17,060 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,061 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 09:29:17,072 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: F828F907FDA94FC2AA356FBDD08A498C
2015-08-14 09:29:17,252 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,252 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 09:29:17,311 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,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 09:29:17,364 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,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 09:29:17,407 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 09:29:17,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-08-14 09:29:17,413 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] parallel execution is enabled: true
2015-08-14 09:29:17,414 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flows: 4
2015-08-14 09:29:17,414 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] allocating threads: 4
2015-08-14 09:29:17,415 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-08-14 09:29:17,416 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: first
2015-08-14 09:29:17,416 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: second
2015-08-14 09:29:17,418 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: second
2015-08-14 09:29:17,419 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: third
2015-08-14 09:29:17,419 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: third
2015-08-14 09:29:17,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: fourth
2015-08-14 09:29:17,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] skipping flow: fourth
2015-08-14 09:29:17,429 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/skipped/second
2015-08-14 09:29:17,431 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/skipped/fourth
2015-08-14 09:29:17,433 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/skipped/first
2015-08-14 09:29:17,434 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/skipped/third
2015-08-14 09:29:17,470 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,471 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 09:29:17,522 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,522 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 09:29:17,568 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:29:17,569 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 09:29:17,601 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting
2015-08-14 09:29:17,604 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] parallel execution is enabled: true
2015-08-14 09:29:17,604 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flows: 3
2015-08-14 09:29:17,604 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] allocating threads: 3
2015-08-14 09:29:17,605 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: second
2015-08-14 09:29:17,605 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: first
2015-08-14 09:29:17,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 09:29:17,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 09:29:17,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:29:17,608 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:29:17,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 09:29:17,637 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 09:29:17,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2015-08-14 09:29:17,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"]
2015-08-14 09:29:17,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 09:29:17,638 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2015-08-14 09:29:17,639 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 09:29:17,639 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 09:29:17,640 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]
2015-08-14 09:29:17,640 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 09:29:17,640 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...deplatform/multitap/first
2015-08-14 09:29:17,641 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 09:29:17,641 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 09:29:17,645 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...eplatform/multitap/second
2015-08-14 09:29:18,821 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439544551414_0002
2015-08-14 09:29:18,822 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0002/
2015-08-14 09:29:18,822 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439544551414_0001
2015-08-14 09:29:18,822 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0001/
2015-08-14 09:29:39,067 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0001_01_000005 is : 143
2015-08-14 09:29:39,130 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0002_01_000004 is : 143
2015-08-14 09:29:39,227 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0001_01_000002 is : 143
2015-08-14 09:29:39,303 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0001_01_000004 is : 143
2015-08-14 09:29:39,304 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0001_01_000003 is : 143
2015-08-14 09:29:39,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0002_01_000005 is : 143
2015-08-14 09:29:39,487 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0002_01_000003 is : 143
2015-08-14 09:29:39,770 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0002_01_000002 is : 143
2015-08-14 09:29:40,728 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first/_temporary
2015-08-14 09:29:40,729 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: first
2015-08-14 09:29:41,040 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second/_temporary
2015-08-14 09:29:41,042 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: second
2015-08-14 09:29:41,042 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] starting flow: multitap
2015-08-14 09:29:41,043 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] at least one sink is marked for delete
2015-08-14 09:29:41,043 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:29:41,048 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting
2015-08-14 09:29:41,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] source: MultiSourceTap[2:[Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/first"], Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/second"]]]
2015-08-14 09:29:41,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap"]
2015-08-14 09:29:41,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] parallel execution is enabled: true
2015-08-14 09:29:41,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] starting jobs: 1
2015-08-14 09:29:41,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [multitap] allocating threads: 1
2015-08-14 09:29:41,050 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] starting step: (1/1) ...latform/multitap/multitap
2015-08-14 09:29:41,259 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] submitted hadoop job: job_1439544551414_0003
2015-08-14 09:29:41,259 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [multitap] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0003/
2015-08-14 09:30:05,462 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000007 is : 143
2015-08-14 09:30:05,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000005 is : 143
2015-08-14 09:30:05,627 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000006 is : 143
2015-08-14 09:30:05,701 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000003 is : 143
2015-08-14 09:30:05,702 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000008 is : 143
2015-08-14 09:30:06,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000009 is : 143
2015-08-14 09:30:06,551 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000002 is : 143
2015-08-14 09:30:06,587 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0003_01_000004 is : 143
2015-08-14 09:30:07,856 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/multitap/multitap/_temporary
2015-08-14 09:30:07,857 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [multitap+first+second] completed flow: multitap
2015-08-14 09:30:07,926 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/multitap/second
2015-08-14 09:30:07,947 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/multitap/multitap
2015-08-14 09:30:07,979 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/multitap/first
2015-08-14 09:30:08,021 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:30:08,021 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 09:30:08,058 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:30:08,058 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 09:30:08,100 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:30:08,101 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 09:30:08,108 INFO planner.FlowPlanner (FlowPlanner.java:insertTempTapAfter(654)) - found checkpoint: checkpoint, using tap: Hfs["TextDelimited[[UNKNOWN]->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-08-14 09:30:08,149 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:30:08,150 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 09:30:08,170 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting
2015-08-14 09:30:08,174 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] parallel execution is enabled: true
2015-08-14 09:30:08,174 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flows: 4
2015-08-14 09:30:08,174 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] allocating threads: 4
2015-08-14 09:30:08,174 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: first
2015-08-14 09:30:08,175 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 09:30:08,175 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:30:08,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 09:30:08,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2015-08-14 09:30:08,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-08-14 09:30:08,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 09:30:08,180 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 09:30:08,181 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 09:30:08,182 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...platform/checkpoint/first
2015-08-14 09:30:08,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439544551414_0004
2015-08-14 09:30:08,369 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0004/
2015-08-14 09:30:23,225 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0004_01_000002 is : 143
2015-08-14 09:30:23,379 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0004_01_000004 is : 143
2015-08-14 09:30:23,443 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0004_01_000003 is : 143
2015-08-14 09:30:23,581 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0004_01_000005 is : 143
2015-08-14 09:30:24,831 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first/_temporary
2015-08-14 09:30:24,833 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: first
2015-08-14 09:30:24,833 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: second
2015-08-14 09:30:24,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 09:30:24,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:30:24,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 09:30:24,838 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/first"]
2015-08-14 09:30:24,839 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-08-14 09:30:24,839 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 09:30:24,839 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 09:30:24,839 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 09:30:24,841 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...latform/checkpoint/second
2015-08-14 09:30:25,017 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439544551414_0005
2015-08-14 09:30:25,018 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0005/
2015-08-14 09:30:40,113 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0005_01_000003 is : 143
2015-08-14 09:30:40,683 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0005_01_000005 is : 143
2015-08-14 09:30:40,744 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0005_01_000004 is : 143
2015-08-14 09:30:40,781 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0005_01_000006 is : 143
2015-08-14 09:30:41,220 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0005_01_000002 is : 143
2015-08-14 09:30:42,485 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second/_temporary
2015-08-14 09:30:42,486 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: second
2015-08-14 09:30:42,486 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: null
2015-08-14 09:30:42,487 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] at least one sink is marked for delete
2015-08-14 09:30:42,488 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:30:42,494 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting
2015-08-14 09:30:42,494 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/second"]
2015-08-14 09:30:42,495 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath"]
2015-08-14 09:30:42,495 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] parallel execution is enabled: true
2015-08-14 09:30:42,495 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] starting jobs: 2
2015-08-14 09:30:42,495 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [] allocating threads: 2
2015-08-14 09:30:42,498 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (1/2) ...platform/checkpoint/third
2015-08-14 09:30:42,724 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439544551414_0006
2015-08-14 09:30:42,725 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0006/
2015-08-14 09:30:59,375 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0006_01_000003 is : 143
2015-08-14 09:30:59,463 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0006_01_000006 is : 143
2015-08-14 09:30:59,537 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0006_01_000005 is : 143
2015-08-14 09:30:59,603 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0006_01_000007 is : 143
2015-08-14 09:31:00,483 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0006_01_000004 is : 143
2015-08-14 09:31:00,521 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0006_01_000002 is : 143
2015-08-14 09:31:01,748 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] starting step: (2/2) ...ascadeplatform/unusedpath
2015-08-14 09:31:01,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] submitted hadoop job: job_1439544551414_0007
2015-08-14 09:31:01,928 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0007/
2015-08-14 09:31:19,514 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000008 is : 143
2015-08-14 09:31:19,737 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000007 is : 143
2015-08-14 09:31:19,828 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000005 is : 143
2015-08-14 09:31:19,873 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000003 is : 143
2015-08-14 09:31:19,875 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000006 is : 143
2015-08-14 09:31:19,952 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000002 is : 143
2015-08-14 09:31:20,023 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0007_01_000004 is : 143
2015-08-14 09:31:21,296 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third/_temporary
2015-08-14 09:31:21,302 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/unusedpath/_temporary
2015-08-14 09:31:21,304 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: null
2015-08-14 09:31:21,304 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] starting flow: fourth
2015-08-14 09:31:21,305 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-08-14 09:31:21,305 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:31:21,308 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 09:31:21,309 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/third"]
2015-08-14 09:31:21,310 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth"]
2015-08-14 09:31:21,311 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-08-14 09:31:21,311 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-08-14 09:31:21,312 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-08-14 09:31:21,313 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...latform/checkpoint/fourth
2015-08-14 09:31:21,473 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1439544551414_0008
2015-08-14 09:31:21,474 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0008/
2015-08-14 09:31:37,964 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000007 is : 143
2015-08-14 09:31:38,230 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000006 is : 143
2015-08-14 09:31:38,946 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000003 is : 143
2015-08-14 09:31:38,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000008 is : 143
2015-08-14 09:31:39,209 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000002 is : 143
2015-08-14 09:31:39,315 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000004 is : 143
2015-08-14 09:31:39,363 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0008_01_000005 is : 143
2015-08-14 09:31:40,616 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/checkpoint/fourth/_temporary
2015-08-14 09:31:40,618 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second++first] completed flow: fourth
2015-08-14 09:31:40,661 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/first
2015-08-14 09:31:40,678 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/third
2015-08-14 09:31:40,698 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/second
2015-08-14 09:31:40,715 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/checkpoint/fourth
2015-08-14 09:31:40,736 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/unusedpath
2015-08-14 09:31:40,779 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:31:40,780 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 09:31:40,819 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:31:40,819 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 09:31:40,854 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:31:40,855 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 09:31:40,889 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:31:40,890 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 09:31:40,910 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-08-14 09:31:40,913 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] parallel execution is enabled: true
2015-08-14 09:31:40,913 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flows: 4
2015-08-14 09:31:40,913 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] allocating threads: 4
2015-08-14 09:31:40,914 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-08-14 09:31:40,915 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 09:31:40,915 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:31:40,919 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 09:31:40,919 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2015-08-14 09:31:40,920 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail"]
2015-08-14 09:31:40,920 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 09:31:40,920 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 09:31:40,920 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 09:31:40,921 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...irsttestSimpleCascadeFail
2015-08-14 09:31:41,084 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439544551414_0009
2015-08-14 09:31:41,085 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0009/
2015-08-14 09:31:56,155 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000003 is : 143
2015-08-14 09:31:56,243 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000004 is : 143
2015-08-14 09:31:56,425 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000002 is : 143
2015-08-14 09:31:56,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000005 is : 143
2015-08-14 09:32:03,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000009 is : 143
2015-08-14 09:32:03,115 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000006 is : 143
2015-08-14 09:32:03,692 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000007 is : 143
2015-08-14 09:32:03,710 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000008 is : 143
2015-08-14 09:32:09,966 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000012 is : 143
2015-08-14 09:32:10,144 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000013 is : 143
2015-08-14 09:32:10,257 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000011 is : 143
2015-08-14 09:32:10,310 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000010 is : 143
2015-08-14 09:32:16,951 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000017 is : 143
2015-08-14 09:32:16,989 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000016 is : 143
2015-08-14 09:32:16,990 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0009_01_000014 is : 143
2015-08-14 09:32:18,148 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] hadoop job job_1439544551414_0009 state at FAILED
2015-08-14 09:32:18,149 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] failure info: Task failed task_1439544551414_0009_m_000000
Job failed as tasks failed. failedMaps:1 failedReduces:0
2015-08-14 09:32:18,184 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events identify failed tasks
2015-08-14 09:32:18,184 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] task completion events count: 10
2015-08-14 09:32:18,185 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000001_0, Status : FAILED
2015-08-14 09:32:18,185 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000002_0, Status : FAILED
2015-08-14 09:32:18,185 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000000_0, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000003_0, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000003_1, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000001_1, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000002_1, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000000_1, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000002_2, Status : FAILED
2015-08-14 09:32:18,186 WARN flow.FlowStep (BaseFlowStep.java:logWarn(900)) - [first] event = Task Id : attempt_1439544551414_0009_m_000000_2, Status : FAILED
2015-08-14 09:32:18,228 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-08-14 09:32:18,229 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-08-14 09:32:18,231 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-08-14 09:32:18,232 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail/_temporary
2015-08-14 09:32:18,234 WARN cascade.Cascade (Cascade.java:logWarn(1006)) - [fourth+second+third+first] flow failed: first
cascading.flow.FlowException: step failed: (1/1) ...irsttestSimpleCascadeFail, with job id: job_1439544551414_0009, please see cluster logs for failure messages
at cascading.flow.planner.FlowStepJob.blockOnJob(FlowStepJob.java:261)
at cascading.flow.planner.FlowStepJob.start(FlowStepJob.java:162)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:124)
at cascading.flow.planner.FlowStepJob.call(FlowStepJob.java:43)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
at java.lang.Thread.run(Thread.java:662)
2015-08-14 09:32:18,239 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping all flows
2015-08-14 09:32:18,239 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: fourth
2015-08-14 09:32:18,240 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-08-14 09:32:18,240 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...urthtestSimpleCascadeFail
2015-08-14 09:32:18,241 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-08-14 09:32:18,241 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: third
2015-08-14 09:32:18,241 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-08-14 09:32:18,241 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...hirdtestSimpleCascadeFail
2015-08-14 09:32:18,242 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-08-14 09:32:18,242 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: second
2015-08-14 09:32:18,243 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-08-14 09:32:18,243 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...condtestSimpleCascadeFail
2015-08-14 09:32:18,243 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-08-14 09:32:18,243 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopping flow: first
2015-08-14 09:32:18,243 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-08-14 09:32:18,244 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...irsttestSimpleCascadeFail
2015-08-14 09:32:18,245 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-08-14 09:32:18,245 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] stopped all flows
2015-08-14 09:32:18,245 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascadeFail
2015-08-14 09:32:18,246 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascadeFail
2015-08-14 09:32:18,250 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascadeFail
2015-08-14 09:32:18,251 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascadeFail
2015-08-14 09:32:18,275 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:18,275 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 09:32:18,308 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:18,308 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 09:32:18,340 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:18,340 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 09:32:18,371 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:18,372 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
calling start
2015-08-14 09:32:18,390 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting
2015-08-14 09:32:18,393 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] parallel execution is enabled: true
2015-08-14 09:32:18,393 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flows: 4
2015-08-14 09:32:18,393 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] allocating threads: 4
2015-08-14 09:32:18,394 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] starting flow: first
2015-08-14 09:32:18,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 09:32:18,394 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
testing if running
2015-08-14 09:32:18,398 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 09:32:18,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2015-08-14 09:32:18,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic"]
2015-08-14 09:32:18,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 09:32:18,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 09:32:18,399 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 09:32:18,400 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...ed/first-nondeterministic
2015-08-14 09:32:18,571 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439544551414_0010
2015-08-14 09:32:18,572 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0010/
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
testing if running
2015-08-14 09:32:32,836 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0010_01_000002 is : 143
2015-08-14 09:32:32,882 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0010_01_000003 is : 143
calling stop
2015-08-14 09:32:33,416 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping all flows
2015-08-14 09:32:33,417 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: fourth
2015-08-14 09:32:33,418 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopping all jobs
2015-08-14 09:32:33,418 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0010_01_000004 is : 143
2015-08-14 09:32:33,418 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] stopping: (1/1) ...d/fourth-nondeterministic
2015-08-14 09:32:33,418 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] stopped all jobs
2015-08-14 09:32:33,419 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: third
2015-08-14 09:32:33,419 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopping all jobs
2015-08-14 09:32:33,419 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] stopping: (1/1) ...ed/third-nondeterministic
2015-08-14 09:32:33,419 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] stopped all jobs
2015-08-14 09:32:33,420 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: second
2015-08-14 09:32:33,420 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopping all jobs
2015-08-14 09:32:33,420 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] stopping: (1/1) ...d/second-nondeterministic
2015-08-14 09:32:33,421 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] stopped all jobs
2015-08-14 09:32:33,421 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopping flow: first
2015-08-14 09:32:33,421 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopping all jobs
2015-08-14 09:32:33,422 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] stopping: (1/1) ...ed/first-nondeterministic
2015-08-14 09:32:33,472 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0010_01_000005 is : 143
2015-08-14 09:32:35,448 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] stopped all jobs
2015-08-14 09:32:35,448 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutting down job executor
2015-08-14 09:32:35,496 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] shutdown complete
2015-08-14 09:32:35,497 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] stopped all flows
2015-08-14 09:32:35,497 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] completed flow: first
2015-08-14 09:32:35,497 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutting down flow executor
2015-08-14 09:32:35,500 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first+second+third+fourth] shutdown complete
2015-08-14 09:32:35,501 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/stopped/second-nondeterministic
2015-08-14 09:32:35,503 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/stopped/first-nondeterministic
2015-08-14 09:32:35,507 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/stopped/third-nondeterministic
2015-08-14 09:32:35,508 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/stopped/fourth-nondeterministic
2015-08-14 09:32:35,531 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:35,532 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 09:32:35,563 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:35,564 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 09:32:35,595 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:35,595 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 09:32:35,626 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:32:35,626 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 09:32:35,643 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting
2015-08-14 09:32:35,644 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] parallel execution is enabled: true
2015-08-14 09:32:35,645 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flows: 4
2015-08-14 09:32:35,645 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] allocating threads: 4
2015-08-14 09:32:35,646 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: first
2015-08-14 09:32:35,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] at least one sink is marked for delete
2015-08-14 09:32:35,647 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:32:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting
2015-08-14 09:32:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/classes/test/data/ips.20.txt"]
2015-08-14 09:32:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-08-14 09:32:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] parallel execution is enabled: true
2015-08-14 09:32:35,651 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] starting jobs: 1
2015-08-14 09:32:35,652 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first] allocating threads: 1
2015-08-14 09:32:35,652 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] starting step: (1/1) ...le/firsttestSimpleCascade
2015-08-14 09:32:35,817 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] submitted hadoop job: job_1439544551414_0011
2015-08-14 09:32:35,818 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0011/
2015-08-14 09:32:50,490 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0011_01_000005 is : 143
2015-08-14 09:32:50,749 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0011_01_000003 is : 143
2015-08-14 09:32:50,793 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0011_01_000002 is : 143
2015-08-14 09:32:50,841 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0011_01_000004 is : 143
2015-08-14 09:32:52,091 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade/_temporary
2015-08-14 09:32:52,092 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: first
2015-08-14 09:32:52,092 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: second
2015-08-14 09:32:52,093 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] at least one sink is marked for delete
2015-08-14 09:32:52,093 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:32:52,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting
2015-08-14 09:32:52,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade"]
2015-08-14 09:32:52,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] sink: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-08-14 09:32:52,097 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] parallel execution is enabled: true
2015-08-14 09:32:52,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] starting jobs: 1
2015-08-14 09:32:52,098 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second] allocating threads: 1
2015-08-14 09:32:52,100 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] starting step: (1/1) ...e/secondtestSimpleCascade
2015-08-14 09:32:52,255 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] submitted hadoop job: job_1439544551414_0012
2015-08-14 09:32:52,255 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0012/
2015-08-14 09:33:07,670 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0012_01_000003 is : 143
2015-08-14 09:33:08,275 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0012_01_000004 is : 143
2015-08-14 09:33:08,325 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0012_01_000005 is : 143
2015-08-14 09:33:08,753 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0012_01_000002 is : 143
2015-08-14 09:33:09,126 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0012_01_000006 is : 143
2015-08-14 09:33:10,372 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade/_temporary
2015-08-14 09:33:10,373 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: second
2015-08-14 09:33:10,373 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: third
2015-08-14 09:33:10,374 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] at least one sink is marked for delete
2015-08-14 09:33:10,374 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:33:10,378 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting
2015-08-14 09:33:10,379 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] source: Hfs["TextDelimited[['first', 'second', 'third', 'fourth']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade"]
2015-08-14 09:33:10,379 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-08-14 09:33:10,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] parallel execution is enabled: true
2015-08-14 09:33:10,380 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] starting jobs: 1
2015-08-14 09:33:10,381 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [third] allocating threads: 1
2015-08-14 09:33:10,382 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] starting step: (1/1) ...le/thirdtestSimpleCascade
2015-08-14 09:33:10,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] submitted hadoop job: job_1439544551414_0013
2015-08-14 09:33:10,539 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [third] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0013/
2015-08-14 09:33:25,875 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0013_01_000006 is : 143
2015-08-14 09:33:26,066 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0013_01_000007 is : 143
2015-08-14 09:33:27,035 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0013_01_000002 is : 143
2015-08-14 09:33:27,073 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0013_01_000004 is : 143
2015-08-14 09:33:27,245 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0013_01_000005 is : 143
2015-08-14 09:33:27,291 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0013_01_000003 is : 143
2015-08-14 09:33:28,543 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade/_temporary
2015-08-14 09:33:28,544 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: third
2015-08-14 09:33:28,545 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] starting flow: fourth
2015-08-14 09:33:28,545 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] at least one sink is marked for delete
2015-08-14 09:33:28,545 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 09:33:28,552 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting
2015-08-14 09:33:28,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade"]
2015-08-14 09:33:28,553 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade"]
2015-08-14 09:33:28,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] parallel execution is enabled: true
2015-08-14 09:33:28,554 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] starting jobs: 1
2015-08-14 09:33:28,555 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [fourth] allocating threads: 1
2015-08-14 09:33:28,556 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] starting step: (1/1) ...e/fourthtestSimpleCascade
2015-08-14 09:33:28,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] submitted hadoop job: job_1439544551414_0014
2015-08-14 09:33:28,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [fourth] tracking url: http://ip-10-235-34-50:45558/proxy/application_1439544551414_0014/
2015-08-14 09:33:45,322 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000007 is : 143
2015-08-14 09:33:45,533 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000006 is : 143
2015-08-14 09:33:46,090 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000008 is : 143
2015-08-14 09:33:46,450 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000002 is : 143
2015-08-14 09:33:46,486 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000005 is : 143
2015-08-14 09:33:46,523 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000004 is : 143
2015-08-14 09:33:46,566 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(223)) - Exit code from container container_1439544551414_0014_01_000003 is : 143
2015-08-14 09:33:47,798 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output/hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade/_temporary
2015-08-14 09:33:47,799 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [fourth+second+third+first] completed flow: fourth
2015-08-14 09:33:47,855 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/firsttestSimpleCascade
2015-08-14 09:33:47,871 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/secondtestSimpleCascade
2015-08-14 09:33:47,888 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/fourthtestSimpleCascade
2015-08-14 09:33:47,908 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/simple/thirdtestSimpleCascade
2015-08-14 09:33:47,948 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:33:47,949 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 09:33:47,980 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:33:47,981 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 09:33:48,012 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:33:48,012 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 09:33:48,043 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:33:48,043 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 09:33:48,059 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/idtest/fourth
2015-08-14 09:33:48,061 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/idtest/first
2015-08-14 09:33:48,062 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/idtest/second
2015-08-14 09:33:48,064 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.6.x/build/test/output//hadoop2-mr1/cascadeplatform/idtest/third
2015-08-14 09:33:48,086 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:33:48,087 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 09:33:48,134 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 09:33:48,135 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