2015-08-14 02:00:16,947 INFO platform.PlatformRunner (PlatformRunner.java:getPlatformClassesFromClasspath(187)) - found 1 test platforms from classpath
2015-08-14 02:00:17,014 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(237)) - installing platform: hadoop2-mr1
2015-08-14 02:00:17,014 INFO platform.PlatformRunner (PlatformRunner.java:addPlatform(238)) - running test: cascading.cascade.ParallelCascadePlatformTest
2015-08-14 02:00:17,050 INFO hadoop2.Hadoop2MR1Platform (Hadoop2MR1Platform.java:setUp(121)) - using cluster
2015-08-14 02:00:17,959 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 02:00:18,711 WARN impl.MetricsConfig (MetricsConfig.java:loadFirst(124)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2015-08-14 02:00:24,241 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 02:00:25,522 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 02:00:26,727 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 02:00:27,934 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 02:00:30,509 INFO platform.TestPlatform (TestPlatform.java:getGlobalProperties(72)) - platform property overrides:
2015-08-14 02:00:30,639 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:30,641 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 02:00:30,652 INFO property.AppProps (AppProps.java:getAppID(169)) - using app.id: 43152DBFBBCD4EDCA39517C16AD82F8C
2015-08-14 02:00:30,816 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopping all flows
2015-08-14 02:00:30,816 INFO util.Version (Version.java:printBanner(85)) - Concurrent, Inc - Cascading 2.7.1
2015-08-14 02:00:30,817 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] stopped all flows
2015-08-14 02:00:30,818 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-0/first-nondeterm...] starting
2015-08-14 02:00:30,852 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:30,853 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 02:00:30,882 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting
2015-08-14 02:00:30,885 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] parallel execution is enabled: true
2015-08-14 02:00:30,885 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flows: 1
2015-08-14 02:00:30,885 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] allocating threads: 1
2015-08-14 02:00:30,887 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] starting flow: race-50/first-nondeterministic
2015-08-14 02:00:30,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] at least one sink is marked for delete
2015-08-14 02:00:30,888 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:30,910 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting
2015-08-14 02:00:30,911 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:30,912 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-50/first-nondeterministic"]
2015-08-14 02:00:30,912 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] parallel execution is enabled: true
2015-08-14 02:00:30,912 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] starting jobs: 1
2015-08-14 02:00:30,913 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] allocating threads: 1
2015-08-14 02:00:30,914 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] starting step: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:30,932 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping all flows
2015-08-14 02:00:30,933 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopping flow: race-50/first-nondeterministic
2015-08-14 02:00:30,934 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopping all jobs
2015-08-14 02:00:30,935 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] stopping: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:30,937 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] stopped all jobs
2015-08-14 02:00:30,937 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutting down job executor
2015-08-14 02:00:31,715 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] submitted hadoop job: job_1439517622260_0001
2015-08-14 02:00:31,716 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-50/first-nondeter...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0001/
2015-08-14 02:00:31,768 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-50/first-nondeter...] shutdown complete
2015-08-14 02:00:31,769 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] stopped all flows
2015-08-14 02:00:31,769 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutting down flow executor
2015-08-14 02:00:31,769 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] completed flow: race-50/first-nondeterministic
2015-08-14 02:00:31,771 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-50/first-nondeter...] shutdown complete
2015-08-14 02:00:31,796 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:31,796 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 02:00:31,822 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting
2015-08-14 02:00:31,825 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:31,825 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flows: 1
2015-08-14 02:00:31,825 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] allocating threads: 1
2015-08-14 02:00:31,826 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] starting flow: race-100/first-nondeterministic
2015-08-14 02:00:31,827 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:31,828 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:31,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting
2015-08-14 02:00:31,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:31,834 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-100/first-nondeterministic"]
2015-08-14 02:00:31,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:31,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] starting jobs: 1
2015-08-14 02:00:31,835 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] allocating threads: 1
2015-08-14 02:00:31,837 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:31,923 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping all flows
2015-08-14 02:00:31,924 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopping flow: race-100/first-nondeterministic
2015-08-14 02:00:31,924 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopping all jobs
2015-08-14 02:00:31,925 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:31,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] stopped all jobs
2015-08-14 02:00:31,926 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutting down job executor
2015-08-14 02:00:32,124 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] submitted hadoop job: job_1439517622260_0002
2015-08-14 02:00:32,124 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-100/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0002/
2015-08-14 02:00:32,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-100/first-nondete...] shutdown complete
2015-08-14 02:00:32,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] stopped all flows
2015-08-14 02:00:32,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] completed flow: race-100/first-nondeterministic
2015-08-14 02:00:32,131 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutting down flow executor
2015-08-14 02:00:32,132 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-100/first-nondete...] shutdown complete
2015-08-14 02:00:32,170 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:32,171 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 02:00:32,199 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting
2015-08-14 02:00:32,201 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:32,201 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flows: 1
2015-08-14 02:00:32,201 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] allocating threads: 1
2015-08-14 02:00:32,203 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] starting flow: race-150/first-nondeterministic
2015-08-14 02:00:32,204 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:32,205 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:32,211 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting
2015-08-14 02:00:32,212 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:32,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-150/first-nondeterministic"]
2015-08-14 02:00:32,213 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:32,214 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] starting jobs: 1
2015-08-14 02:00:32,215 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] allocating threads: 1
2015-08-14 02:00:32,217 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:32,349 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping all flows
2015-08-14 02:00:32,350 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopping flow: race-150/first-nondeterministic
2015-08-14 02:00:32,351 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopping all jobs
2015-08-14 02:00:32,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:32,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] stopped all jobs
2015-08-14 02:00:32,352 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutting down job executor
2015-08-14 02:00:32,679 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] submitted hadoop job: job_1439517622260_0003
2015-08-14 02:00:32,680 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-150/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0003/
2015-08-14 02:00:32,686 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-150/first-nondete...] shutdown complete
2015-08-14 02:00:32,687 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] stopped all flows
2015-08-14 02:00:32,687 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutting down flow executor
2015-08-14 02:00:32,688 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] completed flow: race-150/first-nondeterministic
2015-08-14 02:00:32,688 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-150/first-nondete...] shutdown complete
2015-08-14 02:00:32,713 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:32,714 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 02:00:32,736 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting
2015-08-14 02:00:32,739 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:32,739 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flows: 1
2015-08-14 02:00:32,739 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] allocating threads: 1
2015-08-14 02:00:32,740 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] starting flow: race-200/first-nondeterministic
2015-08-14 02:00:32,740 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:32,741 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:32,746 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting
2015-08-14 02:00:32,747 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:32,747 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-200/first-nondeterministic"]
2015-08-14 02:00:32,748 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:32,749 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] starting jobs: 1
2015-08-14 02:00:32,749 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] allocating threads: 1
2015-08-14 02:00:32,750 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:32,881 WARN blockmanagement.BlockPlacementPolicy (BlockPlacementPolicyDefault.java:chooseTarget(295)) - Not able to place enough replicas, still in need of 1 to reach 4
For more information, please enable DEBUG log level on org.apache.commons.logging.impl.Log4JLogger
2015-08-14 02:00:32,936 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping all flows
2015-08-14 02:00:32,937 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopping flow: race-200/first-nondeterministic
2015-08-14 02:00:32,938 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopping all jobs
2015-08-14 02:00:32,939 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:32,939 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] stopped all jobs
2015-08-14 02:00:32,939 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutting down job executor
2015-08-14 02:00:33,036 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] submitted hadoop job: job_1439517622260_0004
2015-08-14 02:00:33,037 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-200/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0004/
2015-08-14 02:00:33,043 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-200/first-nondete...] shutdown complete
2015-08-14 02:00:33,044 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] stopped all flows
2015-08-14 02:00:33,044 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] shutting down flow executor
2015-08-14 02:00:33,045 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] completed flow: race-200/first-nondeterministic
2015-08-14 02:00:33,047 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-200/first-nondete...] shutdown complete
2015-08-14 02:00:33,070 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:33,070 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 02:00:33,097 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting
2015-08-14 02:00:33,098 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:33,098 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flows: 1
2015-08-14 02:00:33,099 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] allocating threads: 1
2015-08-14 02:00:33,099 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] starting flow: race-250/first-nondeterministic
2015-08-14 02:00:33,100 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:33,100 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:33,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting
2015-08-14 02:00:33,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:33,105 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-250/first-nondeterministic"]
2015-08-14 02:00:33,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:33,106 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] starting jobs: 1
2015-08-14 02:00:33,107 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] allocating threads: 1
2015-08-14 02:00:33,109 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:33,347 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping all flows
2015-08-14 02:00:33,351 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopping flow: race-250/first-nondeterministic
2015-08-14 02:00:33,351 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopping all jobs
2015-08-14 02:00:33,352 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:33,353 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] stopped all jobs
2015-08-14 02:00:33,354 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutting down job executor
2015-08-14 02:00:33,398 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] submitted hadoop job: job_1439517622260_0005
2015-08-14 02:00:33,399 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-250/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0005/
2015-08-14 02:00:33,406 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-250/first-nondete...] shutdown complete
2015-08-14 02:00:33,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] stopped all flows
2015-08-14 02:00:33,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] completed flow: race-250/first-nondeterministic
2015-08-14 02:00:33,407 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutting down flow executor
2015-08-14 02:00:33,408 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-250/first-nondete...] shutdown complete
2015-08-14 02:00:33,430 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:33,431 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 02:00:33,455 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting
2015-08-14 02:00:33,456 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:33,456 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flows: 1
2015-08-14 02:00:33,457 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] allocating threads: 1
2015-08-14 02:00:33,458 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] starting flow: race-300/first-nondeterministic
2015-08-14 02:00:33,458 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:33,458 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:33,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting
2015-08-14 02:00:33,464 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:33,465 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-300/first-nondeterministic"]
2015-08-14 02:00:33,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:33,466 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] starting jobs: 1
2015-08-14 02:00:33,467 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] allocating threads: 1
2015-08-14 02:00:33,469 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:33,688 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] submitted hadoop job: job_1439517622260_0006
2015-08-14 02:00:33,688 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0006/
2015-08-14 02:00:33,755 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping all flows
2015-08-14 02:00:33,757 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopping flow: race-300/first-nondeterministic
2015-08-14 02:00:33,757 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopping all jobs
2015-08-14 02:00:33,758 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-300/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:33,772 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] stopped all jobs
2015-08-14 02:00:33,772 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutting down job executor
2015-08-14 02:00:33,776 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-300/first-nondete...] shutdown complete
2015-08-14 02:00:33,777 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] stopped all flows
2015-08-14 02:00:33,777 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] completed flow: race-300/first-nondeterministic
2015-08-14 02:00:33,777 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] shutting down flow executor
2015-08-14 02:00:33,778 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-300/first-nondete...] shutdown complete
2015-08-14 02:00:33,800 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:33,801 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 02:00:33,819 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting
2015-08-14 02:00:33,822 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:33,823 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flows: 1
2015-08-14 02:00:33,823 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] allocating threads: 1
2015-08-14 02:00:33,824 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] starting flow: race-350/first-nondeterministic
2015-08-14 02:00:33,824 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:33,825 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:33,830 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting
2015-08-14 02:00:33,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:33,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-350/first-nondeterministic"]
2015-08-14 02:00:33,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:33,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] starting jobs: 1
2015-08-14 02:00:33,831 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] allocating threads: 1
2015-08-14 02:00:33,833 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:34,057 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] submitted hadoop job: job_1439517622260_0007
2015-08-14 02:00:34,058 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0007/
2015-08-14 02:00:34,169 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping all flows
2015-08-14 02:00:34,171 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopping flow: race-350/first-nondeterministic
2015-08-14 02:00:34,171 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopping all jobs
2015-08-14 02:00:34,172 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-350/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:34,179 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] stopped all jobs
2015-08-14 02:00:34,179 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] shutting down job executor
2015-08-14 02:00:34,183 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-350/first-nondete...] shutdown complete
2015-08-14 02:00:34,183 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] stopped all flows
2015-08-14 02:00:34,184 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutting down flow executor
2015-08-14 02:00:34,184 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] completed flow: race-350/first-nondeterministic
2015-08-14 02:00:34,185 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-350/first-nondete...] shutdown complete
2015-08-14 02:00:34,207 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:34,207 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 02:00:34,225 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting
2015-08-14 02:00:34,226 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:34,226 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flows: 1
2015-08-14 02:00:34,227 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] allocating threads: 1
2015-08-14 02:00:34,227 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] starting flow: race-400/first-nondeterministic
2015-08-14 02:00:34,228 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:34,228 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:34,233 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting
2015-08-14 02:00:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-400/first-nondeterministic"]
2015-08-14 02:00:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] starting jobs: 1
2015-08-14 02:00:34,234 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] allocating threads: 1
2015-08-14 02:00:34,236 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:34,470 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] submitted hadoop job: job_1439517622260_0008
2015-08-14 02:00:34,471 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0008/
2015-08-14 02:00:34,625 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping all flows
2015-08-14 02:00:34,626 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopping flow: race-400/first-nondeterministic
2015-08-14 02:00:34,627 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopping all jobs
2015-08-14 02:00:34,627 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-400/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:34,635 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] stopped all jobs
2015-08-14 02:00:34,636 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutting down job executor
2015-08-14 02:00:34,643 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-400/first-nondete...] shutdown complete
2015-08-14 02:00:34,644 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] stopped all flows
2015-08-14 02:00:34,644 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] completed flow: race-400/first-nondeterministic
2015-08-14 02:00:34,644 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutting down flow executor
2015-08-14 02:00:34,645 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-400/first-nondete...] shutdown complete
2015-08-14 02:00:34,668 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:34,669 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 02:00:34,715 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting
2015-08-14 02:00:34,718 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:34,718 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flows: 1
2015-08-14 02:00:34,718 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] allocating threads: 1
2015-08-14 02:00:34,719 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] starting flow: race-450/first-nondeterministic
2015-08-14 02:00:34,720 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:34,720 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:34,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting
2015-08-14 02:00:34,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:34,725 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-450/first-nondeterministic"]
2015-08-14 02:00:34,726 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:34,726 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] starting jobs: 1
2015-08-14 02:00:34,726 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] allocating threads: 1
2015-08-14 02:00:34,727 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] starting step: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:34,977 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] submitted hadoop job: job_1439517622260_0009
2015-08-14 02:00:34,978 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0009/
2015-08-14 02:00:35,165 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping all flows
2015-08-14 02:00:35,167 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopping flow: race-450/first-nondeterministic
2015-08-14 02:00:35,168 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopping all jobs
2015-08-14 02:00:35,169 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-450/first-nondete...] stopping: (1/1) ...50/first-nondeterministic
2015-08-14 02:00:35,175 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] stopped all jobs
2015-08-14 02:00:35,175 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutting down job executor
2015-08-14 02:00:35,186 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-450/first-nondete...] shutdown complete
2015-08-14 02:00:35,187 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] stopped all flows
2015-08-14 02:00:35,187 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] completed flow: race-450/first-nondeterministic
2015-08-14 02:00:35,187 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutting down flow executor
2015-08-14 02:00:35,188 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-450/first-nondete...] shutdown complete
2015-08-14 02:00:35,208 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:35,209 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 02:00:35,251 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting
2015-08-14 02:00:35,253 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:35,253 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flows: 1
2015-08-14 02:00:35,254 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] allocating threads: 1
2015-08-14 02:00:35,255 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] starting flow: race-500/first-nondeterministic
2015-08-14 02:00:35,255 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] at least one sink is marked for delete
2015-08-14 02:00:35,256 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:35,276 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting
2015-08-14 02:00:35,277 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:35,277 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/race-500/first-nondeterministic"]
2015-08-14 02:00:35,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] parallel execution is enabled: true
2015-08-14 02:00:35,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] starting jobs: 1
2015-08-14 02:00:35,279 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] allocating threads: 1
2015-08-14 02:00:35,292 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] starting step: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:35,622 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] submitted hadoop job: job_1439517622260_0010
2015-08-14 02:00:35,622 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0010/
2015-08-14 02:00:35,751 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping all flows
2015-08-14 02:00:35,753 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopping flow: race-500/first-nondeterministic
2015-08-14 02:00:35,754 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopping all jobs
2015-08-14 02:00:35,755 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [race-500/first-nondete...] stopping: (1/1) ...00/first-nondeterministic
2015-08-14 02:00:35,762 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] stopped all jobs
2015-08-14 02:00:35,763 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutting down job executor
2015-08-14 02:00:35,766 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [race-500/first-nondete...] shutdown complete
2015-08-14 02:00:35,767 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] stopped all flows
2015-08-14 02:00:35,767 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutting down flow executor
2015-08-14 02:00:35,767 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] completed flow: race-500/first-nondeterministic
2015-08-14 02:00:35,769 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [race-500/first-nondete...] shutdown complete
2015-08-14 02:00:35,772 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-500/first-nondeterministic
2015-08-14 02:00:35,774 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-450/first-nondeterministic
2015-08-14 02:00:35,776 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-200/first-nondeterministic
2015-08-14 02:00:35,777 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-50/first-nondeterministic
2015-08-14 02:00:35,778 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-300/first-nondeterministic
2015-08-14 02:00:35,780 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-250/first-nondeterministic
2015-08-14 02:00:35,781 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-100/first-nondeterministic
2015-08-14 02:00:35,783 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-400/first-nondeterministic
2015-08-14 02:00:35,784 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-150/first-nondeterministic
2015-08-14 02:00:35,785 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-350/first-nondeterministic
2015-08-14 02:00:35,787 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/race-0/first-nondeterministic
2015-08-14 02:00:35,823 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:35,824 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 02:00:35,865 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:35,866 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 02:00:35,915 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:35,916 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 02:00:35,952 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:35,953 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 02:00:35,994 INFO util.HadoopUtil (HadoopUtil.java:findMainClass(336)) - using default application jar, may cause class not found exceptions on the cluster
2015-08-14 02:00:35,995 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 02:00:36,037 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting
2015-08-14 02:00:36,039 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] parallel execution is enabled: true
2015-08-14 02:00:36,040 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flows: 5
2015-08-14 02:00:36,040 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] allocating threads: 5
2015-08-14 02:00:36,041 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first2
2015-08-14 02:00:36,042 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] at least one sink is marked for delete
2015-08-14 02:00:36,042 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:36,044 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: first1
2015-08-14 02:00:36,046 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] at least one sink is marked for delete
2015-08-14 02:00:36,046 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:00:36,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting
2015-08-14 02:00:36,049 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:36,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/first2"]
2015-08-14 02:00:36,050 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] parallel execution is enabled: true
2015-08-14 02:00:36,051 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] starting jobs: 1
2015-08-14 02:00:36,051 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first2] allocating threads: 1
2015-08-14 02:00:36,053 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] starting step: (1/1) ...lelcascadeplatform/first2
2015-08-14 02:00:36,063 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting
2015-08-14 02:00:36,064 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] source: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/classes/test/data/ips.20.txt"]
2015-08-14 02:00:36,065 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] sink: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/first1"]
2015-08-14 02:00:36,065 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] parallel execution is enabled: true
2015-08-14 02:00:36,065 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] starting jobs: 1
2015-08-14 02:00:36,065 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [first1] allocating threads: 1
2015-08-14 02:00:36,069 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] starting step: (1/1) ...lelcascadeplatform/first1
2015-08-14 02:00:36,322 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] submitted hadoop job: job_1439517622260_0011
2015-08-14 02:00:36,323 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first2] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0011/
2015-08-14 02:00:36,376 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] submitted hadoop job: job_1439517622260_0012
2015-08-14 02:00:36,377 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [first1] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0012/
2015-08-14 02:00:50,263 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0001_01_000004 is : 143
2015-08-14 02:00:50,789 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0001_01_000005 is : 143
2015-08-14 02:00:50,995 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0002_01_000004 is : 143
2015-08-14 02:00:51,030 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0002_01_000003 is : 143
2015-08-14 02:00:51,072 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0002_01_000002 is : 143
2015-08-14 02:00:51,108 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0002_01_000005 is : 143
2015-08-14 02:00:51,432 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0001_01_000003 is : 143
2015-08-14 02:00:52,109 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0001_01_000002 is : 143
2015-08-14 02:01:14,330 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0003_01_000003 is : 143
2015-08-14 02:01:14,602 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0003_01_000002 is : 143
2015-08-14 02:01:15,383 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0004_01_000005 is : 143
2015-08-14 02:01:15,416 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0003_01_000005 is : 143
2015-08-14 02:01:15,540 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0003_01_000004 is : 143
2015-08-14 02:01:15,609 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0004_01_000004 is : 143
2015-08-14 02:01:17,393 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0004_01_000003 is : 143
2015-08-14 02:01:17,547 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0004_01_000002 is : 143
2015-08-14 02:01:37,476 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0005_01_000002 is : 143
2015-08-14 02:01:38,023 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0005_01_000005 is : 143
2015-08-14 02:01:38,369 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0005_01_000004 is : 143
2015-08-14 02:01:41,615 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0011_01_000005 is : 143
2015-08-14 02:01:41,693 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0011_01_000003 is : 143
2015-08-14 02:01:41,771 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0011_01_000002 is : 143
2015-08-14 02:01:41,858 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0011_01_000004 is : 143
2015-08-14 02:01:43,176 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/first2/_temporary
2015-08-14 02:01:43,177 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first2
2015-08-14 02:01:43,177 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second2
2015-08-14 02:01:43,178 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] at least one sink is marked for delete
2015-08-14 02:01:43,179 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:01:43,181 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting
2015-08-14 02:01:43,181 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/first2"]
2015-08-14 02:01:43,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/second2"]
2015-08-14 02:01:43,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] parallel execution is enabled: true
2015-08-14 02:01:43,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] starting jobs: 1
2015-08-14 02:01:43,182 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second2] allocating threads: 1
2015-08-14 02:01:43,183 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] starting step: (1/1) ...elcascadeplatform/second2
2015-08-14 02:01:43,348 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] submitted hadoop job: job_1439517622260_0013
2015-08-14 02:01:43,348 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second2] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0013/
2015-08-14 02:02:00,680 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0012_01_000004 is : 143
2015-08-14 02:02:00,998 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0012_01_000002 is : 143
2015-08-14 02:02:01,360 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0012_01_000005 is : 143
2015-08-14 02:02:01,901 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0012_01_000003 is : 143
2015-08-14 02:02:03,545 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/first1/_temporary
2015-08-14 02:02:03,547 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: first1
2015-08-14 02:02:03,548 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: second1
2015-08-14 02:02:03,548 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] at least one sink is marked for delete
2015-08-14 02:02:03,548 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:02:03,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting
2015-08-14 02:02:03,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] source: Hfs["TextDelimited[['ip']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/first1"]
2015-08-14 02:02:03,562 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] sink: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/second1"]
2015-08-14 02:02:03,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] parallel execution is enabled: true
2015-08-14 02:02:03,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] starting jobs: 1
2015-08-14 02:02:03,563 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [second1] allocating threads: 1
2015-08-14 02:02:03,571 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] starting step: (1/1) ...elcascadeplatform/second1
2015-08-14 02:02:04,131 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] submitted hadoop job: job_1439517622260_0014
2015-08-14 02:02:04,132 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [second1] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0014/
2015-08-14 02:02:05,522 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0013_01_000002 is : 143
2015-08-14 02:02:05,577 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0013_01_000003 is : 143
2015-08-14 02:02:06,302 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0013_01_000006 is : 143
2015-08-14 02:02:06,376 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0013_01_000005 is : 143
2015-08-14 02:02:06,416 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0013_01_000004 is : 143
2015-08-14 02:02:07,733 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/second2/_temporary
2015-08-14 02:02:07,734 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second2
2015-08-14 02:02:23,808 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0014_01_000006 is : 143
2015-08-14 02:02:24,042 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0014_01_000005 is : 143
2015-08-14 02:02:24,186 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0014_01_000003 is : 143
2015-08-14 02:02:24,237 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0014_01_000002 is : 143
2015-08-14 02:02:24,856 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0014_01_000004 is : 143
2015-08-14 02:02:26,129 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/second1/_temporary
2015-08-14 02:02:26,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: second1
2015-08-14 02:02:26,130 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] starting flow: lhs*rhs
2015-08-14 02:02:26,130 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] at least one sink is marked for delete
2015-08-14 02:02:26,131 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink oldest modified date: Wed Dec 31 23:59:59 UTC 1969
2015-08-14 02:02:26,134 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting
2015-08-14 02:02:26,134 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/second2"]
2015-08-14 02:02:26,135 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] source: Hfs["TextDelimited[['mangled']]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/second1"]
2015-08-14 02:02:26,136 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] sink: Hfs["TextLine[['offset', 'line']->[ALL]]"]["/opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/third"]
2015-08-14 02:02:26,136 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] parallel execution is enabled: true
2015-08-14 02:02:26,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] starting jobs: 1
2015-08-14 02:02:26,137 INFO flow.Flow (BaseFlow.java:logInfo(1370)) - [lhs*rhs] allocating threads: 1
2015-08-14 02:02:26,138 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] starting step: (1/1) ...llelcascadeplatform/third
2015-08-14 02:02:26,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] submitted hadoop job: job_1439517622260_0015
2015-08-14 02:02:26,304 INFO flow.FlowStep (BaseFlowStep.java:logInfo(895)) - [lhs*rhs] tracking url: http://ip-10-235-34-50:40102/proxy/application_1439517622260_0015/
2015-08-14 02:02:45,626 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000003 is : 143
2015-08-14 02:02:46,010 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000002 is : 143
2015-08-14 02:02:46,384 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000008 is : 143
2015-08-14 02:02:46,787 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000007 is : 143
2015-08-14 02:02:46,858 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000005 is : 143
2015-08-14 02:02:46,896 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000006 is : 143
2015-08-14 02:02:46,927 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000010 is : 143
2015-08-14 02:02:46,962 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000009 is : 143
2015-08-14 02:02:47,038 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000011 is : 143
2015-08-14 02:02:47,043 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000004 is : 143
2015-08-14 02:02:52,775 WARN nodemanager.DefaultContainerExecutor (DefaultContainerExecutor.java:launchContainer(207)) - Exit code from container container_1439517622260_0015_01_000012 is : 143
2015-08-14 02:02:54,039 INFO util.Hadoop18TapUtil (Hadoop18TapUtil.java:cleanTempPath(219)) - deleting temp path /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output/hadoop2-mr1/parallelcascadeplatform/third/_temporary
2015-08-14 02:02:54,039 INFO cascade.Cascade (Cascade.java:logInfo(996)) - [first1+second1+first2+...] completed flow: lhs*rhs
2015-08-14 02:02:54,075 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/second1
2015-08-14 02:02:54,095 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/second2
2015-08-14 02:02:54,114 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/third
2015-08-14 02:02:54,119 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/first1
2015-08-14 02:02:54,134 INFO cascading.PlatformTestCase (PlatformTestCase.java:tearDown(209)) - copying to local /opt/buildAgent-8.0.3/work/8c57748d0461e126/apache-2.2.x/build/test/output//hadoop2-mr1/parallelcascadeplatform/first2