Created
December 9, 2013 16:14
-
-
Save gregakespret/7874908 to your computer and use it in GitHub Desktop.
Resubmision due to a fetch failure
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Connected to jdbc:vertica://vertica7.aws.celtra-test.com:5433/aws7 (DirectBatchInsert: false) | |
13/12/09 15:45:36,704 INFO slf4j.Slf4jEventHandler: Slf4jEventHandler started | |
13/12/09 15:45:36,888 INFO spark.SparkEnv: Registering BlockManagerMaster | |
13/12/09 15:45:36,925 INFO storage.DiskBlockManager: Created local directory at /tmp/spark-local-20131209154536-5135 | |
13/12/09 15:45:36,933 INFO storage.MemoryStore: MemoryStore started with capacity 2.2 GB. | |
13/12/09 15:45:36,969 INFO network.ConnectionManager: Bound socket to port 45383 with id = ConnectionManagerId(ip-10-170-8-11.ec2.internal,45383) | |
13/12/09 15:45:36,977 INFO storage.BlockManagerMaster: Trying to register BlockManager | |
13/12/09 15:45:36,988 INFO storage.BlockManagerMasterActor$BlockManagerInfo: Registering block manager ip-10-170-8-11.ec2.internal:45383 with 2.2 GB RAM | |
13/12/09 15:45:36,989 INFO storage.BlockManagerMaster: Registered BlockManager | |
13/12/09 15:45:37,078 INFO server.Server: jetty-7.x.y-SNAPSHOT | |
13/12/09 15:45:37,102 INFO server.AbstractConnector: Started SocketConnector@0.0.0.0:40816 | |
13/12/09 15:45:37,103 INFO broadcast.HttpBroadcast: Broadcast server started at http://10.170.8.11:40816 | |
13/12/09 15:45:37,108 INFO spark.SparkEnv: Registering MapOutputTracker | |
13/12/09 15:45:37,113 INFO spark.HttpFileServer: HTTP File server directory is /tmp/spark-9d21a3c6-31ee-4cad-bcea-a6d511220210 | |
13/12/09 15:45:37,114 INFO server.Server: jetty-7.x.y-SNAPSHOT | |
13/12/09 15:45:37,116 INFO server.AbstractConnector: Started SocketConnector@0.0.0.0:44411 | |
13/12/09 15:45:37,214 INFO server.Server: jetty-7.x.y-SNAPSHOT | |
13/12/09 15:45:37,214 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/storage/rdd,null} | |
13/12/09 15:45:37,215 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/storage,null} | |
13/12/09 15:45:37,215 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/stages/stage,null} | |
13/12/09 15:45:37,215 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/stages/pool,null} | |
13/12/09 15:45:37,215 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/stages,null} | |
13/12/09 15:45:37,216 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/environment,null} | |
13/12/09 15:45:37,216 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/executors,null} | |
13/12/09 15:45:37,216 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/metrics/json,null} | |
13/12/09 15:45:37,217 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/static,null} | |
13/12/09 15:45:37,217 INFO handler.ContextHandler: started o.e.j.s.h.ContextHandler{/,null} | |
13/12/09 15:45:37,229 INFO server.AbstractConnector: Started SelectChannelConnector@0.0.0.0:5555 | |
13/12/09 15:45:37,230 INFO ui.SparkUI: Started Spark Web UI at http://ip-10-170-8-11.ec2.internal:5555 | |
13/12/09 15:45:37,795 INFO spark.SparkContext: Added JAR /home/grega/mab-grega/analyzer/target/scala-2.9.3/analyzer-assembly-1.0-SNAPSHOT.jar at http://10.170.8.11:44411/jars/analyzer-assembly-1.0-SNAPSHOT.jar with timestamp 1386603937794 | |
13/12/09 15:45:37,856 INFO client.Client$ClientActor: Connecting to master spark://ec2-184-72-177-49.compute-1.amazonaws.com:7077... | |
13/12/09 15:45:38,043 INFO cluster.SparkDeploySchedulerBackend: Connected to Spark cluster with app ID app-20131209154538-0001 | |
13/12/09 15:45:38,063 INFO client.Client$ClientActor: Executor added: app-20131209154538-0001/0 on worker-20131209153424-ip-10-43-129-89.ec2.internal-36674 (ip-10-43-129-89.ec2.internal:7077) with 8 cores | |
13/12/09 15:45:38,064 INFO cluster.SparkDeploySchedulerBackend: Granted executor ID app-20131209154538-0001/0 on hostPort ip-10-43-129-89.ec2.internal:7077 with 8 cores, 5.0 GB RAM | |
13/12/09 15:45:38,064 INFO client.Client$ClientActor: Executor added: app-20131209154538-0001/1 on worker-20131209153424-ip-10-181-0-146.ec2.internal-48913 (ip-10-181-0-146.ec2.internal:7077) with 8 cores | |
13/12/09 15:45:38,064 INFO cluster.SparkDeploySchedulerBackend: Granted executor ID app-20131209154538-0001/1 on hostPort ip-10-181-0-146.ec2.internal:7077 with 8 cores, 5.0 GB RAM | |
13/12/09 15:45:38,100 INFO client.Client$ClientActor: Executor updated: app-20131209154538-0001/0 is now RUNNING | |
13/12/09 15:45:38,101 INFO client.Client$ClientActor: Executor updated: app-20131209154538-0001/1 is now RUNNING | |
13/12/09 15:45:38,130 INFO util.Utils: Copying /home/grega/mab-grega/vendor/maxmind/GeoIPCity.dat to /tmp/spark-dfe8539c-c3c7-4cce-ab9f-3a8f84fe64fa/GeoIPCity.dat | |
13/12/09 15:45:38,282 INFO spark.SparkContext: Added file /home/grega/mab-grega/vendor/maxmind/GeoIPCity.dat at http://10.170.8.11:44411/files/GeoIPCity.dat with timestamp 1386603938128 | |
13/12/09 15:45:38,283 INFO util.Utils: Copying /home/grega/mab-grega/shared/constants.json to /tmp/spark-dfe8539c-c3c7-4cce-ab9f-3a8f84fe64fa/constants.json | |
13/12/09 15:45:38,289 INFO spark.SparkContext: Added file /home/grega/mab-grega/shared/constants.json at http://10.170.8.11:44411/files/constants.json with timestamp 1386603938282 | |
13/12/09 15:45:38,503 INFO analyzer.Entities: Loading entities from operational database... | |
13/12/09 15:45:39,589 INFO cluster.SparkDeploySchedulerBackend: Registered executor: Actor[akka://sparkExecutor@ip-10-181-0-146.ec2.internal:47339/user/Executor] with ID 1 | |
13/12/09 15:45:39,621 INFO cluster.SparkDeploySchedulerBackend: Registered executor: Actor[akka://sparkExecutor@ip-10-43-129-89.ec2.internal:59327/user/Executor] with ID 0 | |
13/12/09 15:45:39,834 INFO storage.BlockManagerMasterActor$BlockManagerInfo: Registering block manager ip-10-181-0-146.ec2.internal:33986 with 3.2 GB RAM | |
13/12/09 15:45:39,862 INFO storage.BlockManagerMasterActor$BlockManagerInfo: Registering block manager ip-10-43-129-89.ec2.internal:46195 with 3.2 GB RAM | |
13/12/09 15:46:51,090 INFO analyzer.Entities: Loaded 561 accounts, 10988 campaigns, 60862 creatives, 22198 placements | |
13/12/09 15:46:51,092 INFO analyzer.LogAnalyzer: Analyzing sessions started in 2013-01-27T00:00:00.000Z/2013-01-27T01:00:00.000Z (max session duration: PT1800S) | |
13/12/09 15:46:51,094 INFO analyzer.S3: Requested logs for interval 2013-01-27T00:00:00.000Z/2013-01-27T01:30:00.000Z | |
13/12/09 15:46:51,095 INFO analyzer.S3: 18 partitions total | |
13/12/09 15:46:51,099 INFO analyzer.S3: Creating RDD with URL: s3n://celtra-mab/tracking-logs/{x,2013-01-27/{_,00-00,00-05,00-10,00-15,00-20,00-25,00-30,00-35,00-40,00-45,00-50,00-55,01-00,01-05,01-10,01-15,01-20,01-25}}/*{.events,.events.gz} | |
13/12/09 15:46:51,184 INFO storage.MemoryStore: ensureFreeSpace(36819) called with curMem=0, maxMem=2362260848 | |
13/12/09 15:46:51,185 INFO storage.MemoryStore: Block broadcast_0 stored as values to memory (estimated size 36.0 KB, free 2.2 GB) | |
13/12/09 15:46:52,060 INFO storage.MemoryStore: ensureFreeSpace(34415520) called with curMem=36819, maxMem=2362260848 | |
13/12/09 15:46:52,060 INFO storage.MemoryStore: Block broadcast_1 stored as values to memory (estimated size 32.8 MB, free 2.2 GB) | |
13/12/09 15:46:52,833 INFO analyzer.LogAnalyzer: Using 64 tasks for grouping sessions | |
13/12/09 15:46:52,880 INFO vertica.Vertica: Creating temporary tables... | |
13/12/09 15:46:54,583 INFO vertica.Vertica: Inserting sessions... | |
13/12/09 15:46:54,584 INFO vertica.Vertica: Using 64 inserters and a batch size of 10000 | |
13/12/09 15:46:54,586 INFO vertica.Vertica: Inserting to temporary tables started | |
13/12/09 15:46:54,644 INFO spark.SparkContext: Starting job: foreach at Vertica.scala:143 | |
13/12/09 15:46:56,591 INFO mapred.FileInputFormat: Total input paths to process : 216 | |
13/12/09 15:46:56,624 INFO scheduler.DAGScheduler: Registering RDD 2 (keyBy at LogAnalyzer.scala:35) | |
13/12/09 15:46:56,627 INFO scheduler.DAGScheduler: Got job 0 (foreach at Vertica.scala:143) with 64 output partitions (allowLocal=false) | |
13/12/09 15:46:56,628 INFO scheduler.DAGScheduler: Final stage: Stage 0 (foreach at Vertica.scala:143) | |
13/12/09 15:46:56,628 INFO scheduler.DAGScheduler: Parents of final stage: List(Stage 1) | |
13/12/09 15:46:56,648 INFO scheduler.DAGScheduler: Missing parents: List(Stage 1) | |
13/12/09 15:46:56,677 INFO scheduler.DAGScheduler: Submitting Stage 1 (MappedRDD[2] at keyBy at LogAnalyzer.scala:35), which has no missing parents | |
13/12/09 15:46:56,734 INFO scheduler.DAGScheduler: Submitting 216 missing tasks from Stage 1 (MappedRDD[2] at keyBy at LogAnalyzer.scala:35) | |
13/12/09 15:46:56,737 INFO cluster.ClusterScheduler: Adding task set 1.0 with 216 tasks | |
13/12/09 15:46:56,755 INFO cluster.ClusterTaskSetManager: Starting task 1.0:0 as TID 0 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,763 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:0 as 2083 bytes in 6 ms | |
13/12/09 15:46:56,769 INFO cluster.ClusterTaskSetManager: Starting task 1.0:1 as TID 1 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,770 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:1 as 2083 bytes in 1 ms | |
13/12/09 15:46:56,770 INFO cluster.ClusterTaskSetManager: Starting task 1.0:2 as TID 2 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,771 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:2 as 2083 bytes in 1 ms | |
13/12/09 15:46:56,771 INFO cluster.ClusterTaskSetManager: Starting task 1.0:3 as TID 3 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,772 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:3 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,773 INFO cluster.ClusterTaskSetManager: Starting task 1.0:4 as TID 4 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,773 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:4 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,774 INFO cluster.ClusterTaskSetManager: Starting task 1.0:5 as TID 5 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,774 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:5 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,775 INFO cluster.ClusterTaskSetManager: Starting task 1.0:6 as TID 6 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,776 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:6 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,776 INFO cluster.ClusterTaskSetManager: Starting task 1.0:7 as TID 7 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,777 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:7 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,778 INFO cluster.ClusterTaskSetManager: Starting task 1.0:8 as TID 8 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,778 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:8 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,779 INFO cluster.ClusterTaskSetManager: Starting task 1.0:9 as TID 9 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,780 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:9 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,780 INFO cluster.ClusterTaskSetManager: Starting task 1.0:10 as TID 10 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,781 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:10 as 2083 bytes in 1 ms | |
13/12/09 15:46:56,781 INFO cluster.ClusterTaskSetManager: Starting task 1.0:11 as TID 11 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,782 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:11 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,783 INFO cluster.ClusterTaskSetManager: Starting task 1.0:12 as TID 12 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,783 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:12 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,784 INFO cluster.ClusterTaskSetManager: Starting task 1.0:13 as TID 13 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,785 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:13 as 2083 bytes in 1 ms | |
13/12/09 15:46:56,786 INFO cluster.ClusterTaskSetManager: Starting task 1.0:14 as TID 14 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,786 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:14 as 2083 bytes in 0 ms | |
13/12/09 15:46:56,787 INFO cluster.ClusterTaskSetManager: Starting task 1.0:15 as TID 15 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:46:56,787 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:15 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,707 INFO cluster.ClusterTaskSetManager: Starting task 1.0:16 as TID 16 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,708 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:16 as 2083 bytes in 1 ms | |
13/12/09 15:47:01,717 INFO cluster.ClusterTaskSetManager: Finished TID 12 in 4934 ms on ip-10-43-129-89.ec2.internal (progress: 0/216) | |
13/12/09 15:47:01,720 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 12) | |
13/12/09 15:47:01,720 INFO cluster.ClusterTaskSetManager: Starting task 1.0:17 as TID 17 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,720 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:17 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,723 INFO cluster.ClusterTaskSetManager: Finished TID 14 in 4935 ms on ip-10-43-129-89.ec2.internal (progress: 1/216) | |
13/12/09 15:47:01,723 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 14) | |
13/12/09 15:47:01,766 INFO cluster.ClusterTaskSetManager: Starting task 1.0:18 as TID 18 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,767 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:18 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,768 INFO cluster.ClusterTaskSetManager: Finished TID 10 in 4988 ms on ip-10-43-129-89.ec2.internal (progress: 2/216) | |
13/12/09 15:47:01,769 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 10) | |
13/12/09 15:47:01,799 INFO cluster.ClusterTaskSetManager: Starting task 1.0:19 as TID 19 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,800 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:19 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,801 INFO cluster.ClusterTaskSetManager: Finished TID 2 in 5030 ms on ip-10-43-129-89.ec2.internal (progress: 3/216) | |
13/12/09 15:47:01,802 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 2) | |
13/12/09 15:47:01,804 INFO cluster.ClusterTaskSetManager: Starting task 1.0:20 as TID 20 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,805 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:20 as 2083 bytes in 1 ms | |
13/12/09 15:47:01,806 INFO cluster.ClusterTaskSetManager: Finished TID 0 in 5053 ms on ip-10-43-129-89.ec2.internal (progress: 4/216) | |
13/12/09 15:47:01,806 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 0) | |
13/12/09 15:47:01,824 INFO cluster.ClusterTaskSetManager: Finished TID 13 in 5040 ms on ip-10-181-0-146.ec2.internal (progress: 5/216) | |
13/12/09 15:47:01,824 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 13) | |
13/12/09 15:47:01,825 INFO cluster.ClusterTaskSetManager: Starting task 1.0:21 as TID 21 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,825 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:21 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,907 INFO cluster.ClusterTaskSetManager: Starting task 1.0:22 as TID 22 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,908 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:22 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,908 INFO cluster.ClusterTaskSetManager: Finished TID 1 in 5139 ms on ip-10-181-0-146.ec2.internal (progress: 6/216) | |
13/12/09 15:47:01,909 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 1) | |
13/12/09 15:47:01,909 INFO cluster.ClusterTaskSetManager: Starting task 1.0:23 as TID 23 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,910 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:23 as 2083 bytes in 1 ms | |
13/12/09 15:47:01,911 INFO cluster.ClusterTaskSetManager: Finished TID 11 in 5129 ms on ip-10-181-0-146.ec2.internal (progress: 7/216) | |
13/12/09 15:47:01,911 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 11) | |
13/12/09 15:47:01,983 INFO cluster.ClusterTaskSetManager: Starting task 1.0:24 as TID 24 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:01,983 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:24 as 2083 bytes in 0 ms | |
13/12/09 15:47:01,984 INFO cluster.ClusterTaskSetManager: Finished TID 9 in 5205 ms on ip-10-181-0-146.ec2.internal (progress: 8/216) | |
13/12/09 15:47:01,985 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 9) | |
13/12/09 15:47:02,248 INFO cluster.ClusterTaskSetManager: Starting task 1.0:25 as TID 25 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,249 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:25 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,250 INFO cluster.ClusterTaskSetManager: Finished TID 6 in 5475 ms on ip-10-43-129-89.ec2.internal (progress: 9/216) | |
13/12/09 15:47:02,250 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 6) | |
13/12/09 15:47:02,253 INFO cluster.ClusterTaskSetManager: Starting task 1.0:26 as TID 26 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,253 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:26 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,254 INFO cluster.ClusterTaskSetManager: Finished TID 4 in 5482 ms on ip-10-43-129-89.ec2.internal (progress: 10/216) | |
13/12/09 15:47:02,254 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 4) | |
13/12/09 15:47:02,262 INFO cluster.ClusterTaskSetManager: Starting task 1.0:27 as TID 27 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,263 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:27 as 2083 bytes in 1 ms | |
13/12/09 15:47:02,263 INFO cluster.ClusterTaskSetManager: Finished TID 8 in 5485 ms on ip-10-43-129-89.ec2.internal (progress: 11/216) | |
13/12/09 15:47:02,264 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 8) | |
13/12/09 15:47:02,360 INFO cluster.ClusterTaskSetManager: Starting task 1.0:28 as TID 28 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,361 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:28 as 2083 bytes in 1 ms | |
13/12/09 15:47:02,362 INFO cluster.ClusterTaskSetManager: Finished TID 3 in 5590 ms on ip-10-181-0-146.ec2.internal (progress: 12/216) | |
13/12/09 15:47:02,362 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 3) | |
13/12/09 15:47:02,375 INFO cluster.ClusterTaskSetManager: Starting task 1.0:29 as TID 29 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,376 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:29 as 2083 bytes in 1 ms | |
13/12/09 15:47:02,377 INFO cluster.ClusterTaskSetManager: Finished TID 5 in 5603 ms on ip-10-181-0-146.ec2.internal (progress: 13/216) | |
13/12/09 15:47:02,377 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 5) | |
13/12/09 15:47:02,445 INFO cluster.ClusterTaskSetManager: Starting task 1.0:30 as TID 30 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,445 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:30 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,446 INFO cluster.ClusterTaskSetManager: Finished TID 15 in 5659 ms on ip-10-181-0-146.ec2.internal (progress: 14/216) | |
13/12/09 15:47:02,446 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 15) | |
13/12/09 15:47:02,464 INFO cluster.ClusterTaskSetManager: Starting task 1.0:31 as TID 31 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,464 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:31 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,465 INFO cluster.ClusterTaskSetManager: Finished TID 7 in 5689 ms on ip-10-181-0-146.ec2.internal (progress: 15/216) | |
13/12/09 15:47:02,466 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 7) | |
13/12/09 15:47:02,593 INFO cluster.ClusterTaskSetManager: Starting task 1.0:32 as TID 32 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,594 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:32 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,595 INFO cluster.ClusterTaskSetManager: Finished TID 23 in 685 ms on ip-10-181-0-146.ec2.internal (progress: 16/216) | |
13/12/09 15:47:02,595 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 23) | |
13/12/09 15:47:02,626 INFO cluster.ClusterTaskSetManager: Finished TID 22 in 720 ms on ip-10-181-0-146.ec2.internal (progress: 17/216) | |
13/12/09 15:47:02,626 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 22) | |
13/12/09 15:47:02,626 INFO cluster.ClusterTaskSetManager: Starting task 1.0:33 as TID 33 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,627 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:33 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,651 INFO cluster.ClusterTaskSetManager: Starting task 1.0:34 as TID 34 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,652 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:34 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,652 INFO cluster.ClusterTaskSetManager: Finished TID 21 in 828 ms on ip-10-181-0-146.ec2.internal (progress: 18/216) | |
13/12/09 15:47:02,653 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 21) | |
13/12/09 15:47:02,721 INFO cluster.ClusterTaskSetManager: Starting task 1.0:35 as TID 35 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,722 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:35 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,722 INFO cluster.ClusterTaskSetManager: Finished TID 24 in 740 ms on ip-10-181-0-146.ec2.internal (progress: 19/216) | |
13/12/09 15:47:02,723 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 24) | |
13/12/09 15:47:02,850 INFO cluster.ClusterTaskSetManager: Starting task 1.0:36 as TID 36 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,851 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:36 as 2083 bytes in 1 ms | |
13/12/09 15:47:02,852 INFO cluster.ClusterTaskSetManager: Finished TID 26 in 599 ms on ip-10-43-129-89.ec2.internal (progress: 20/216) | |
13/12/09 15:47:02,853 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 26) | |
13/12/09 15:47:02,882 INFO cluster.ClusterTaskSetManager: Starting task 1.0:37 as TID 37 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:02,883 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:37 as 2083 bytes in 0 ms | |
13/12/09 15:47:02,884 INFO cluster.ClusterTaskSetManager: Finished TID 25 in 636 ms on ip-10-43-129-89.ec2.internal (progress: 21/216) | |
13/12/09 15:47:02,884 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 25) | |
13/12/09 15:47:03,009 INFO cluster.ClusterTaskSetManager: Starting task 1.0:38 as TID 38 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,009 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:38 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,010 INFO cluster.ClusterTaskSetManager: Finished TID 18 in 1244 ms on ip-10-43-129-89.ec2.internal (progress: 22/216) | |
13/12/09 15:47:03,010 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 18) | |
13/12/09 15:47:03,018 INFO cluster.ClusterTaskSetManager: Starting task 1.0:39 as TID 39 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,018 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:39 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,019 INFO cluster.ClusterTaskSetManager: Finished TID 16 in 1312 ms on ip-10-43-129-89.ec2.internal (progress: 23/216) | |
13/12/09 15:47:03,020 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 16) | |
13/12/09 15:47:03,043 INFO cluster.ClusterTaskSetManager: Finished TID 17 in 1323 ms on ip-10-43-129-89.ec2.internal (progress: 24/216) | |
13/12/09 15:47:03,044 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 17) | |
13/12/09 15:47:03,044 INFO cluster.ClusterTaskSetManager: Starting task 1.0:40 as TID 40 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,045 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:40 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,054 INFO cluster.ClusterTaskSetManager: Starting task 1.0:41 as TID 41 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,055 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:41 as 2083 bytes in 1 ms | |
13/12/09 15:47:03,056 INFO cluster.ClusterTaskSetManager: Finished TID 19 in 1256 ms on ip-10-43-129-89.ec2.internal (progress: 25/216) | |
13/12/09 15:47:03,056 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 19) | |
13/12/09 15:47:03,134 INFO cluster.ClusterTaskSetManager: Starting task 1.0:42 as TID 42 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,135 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:42 as 2083 bytes in 1 ms | |
13/12/09 15:47:03,136 INFO cluster.ClusterTaskSetManager: Finished TID 20 in 1331 ms on ip-10-43-129-89.ec2.internal (progress: 26/216) | |
13/12/09 15:47:03,136 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 20) | |
13/12/09 15:47:03,254 INFO cluster.ClusterTaskSetManager: Starting task 1.0:43 as TID 43 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,254 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:43 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,255 INFO cluster.ClusterTaskSetManager: Finished TID 33 in 629 ms on ip-10-181-0-146.ec2.internal (progress: 27/216) | |
13/12/09 15:47:03,255 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 33) | |
13/12/09 15:47:03,354 INFO cluster.ClusterTaskSetManager: Starting task 1.0:44 as TID 44 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,355 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:44 as 2083 bytes in 1 ms | |
13/12/09 15:47:03,355 INFO cluster.ClusterTaskSetManager: Finished TID 35 in 634 ms on ip-10-181-0-146.ec2.internal (progress: 28/216) | |
13/12/09 15:47:03,356 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 35) | |
13/12/09 15:47:03,377 INFO cluster.ClusterTaskSetManager: Finished TID 27 in 1114 ms on ip-10-43-129-89.ec2.internal (progress: 29/216) | |
13/12/09 15:47:03,377 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 27) | |
13/12/09 15:47:03,377 INFO cluster.ClusterTaskSetManager: Starting task 1.0:45 as TID 45 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,378 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:45 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,396 INFO cluster.ClusterTaskSetManager: Finished TID 34 in 745 ms on ip-10-181-0-146.ec2.internal (progress: 30/216) | |
13/12/09 15:47:03,396 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 34) | |
13/12/09 15:47:03,396 INFO cluster.ClusterTaskSetManager: Starting task 1.0:46 as TID 46 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,397 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:46 as 2083 bytes in 1 ms | |
13/12/09 15:47:03,429 INFO cluster.ClusterTaskSetManager: Starting task 1.0:47 as TID 47 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,429 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:47 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,430 INFO cluster.ClusterTaskSetManager: Finished TID 28 in 1070 ms on ip-10-181-0-146.ec2.internal (progress: 31/216) | |
13/12/09 15:47:03,430 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 28) | |
13/12/09 15:47:03,486 INFO cluster.ClusterTaskSetManager: Starting task 1.0:48 as TID 48 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,487 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:48 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,487 INFO cluster.ClusterTaskSetManager: Finished TID 31 in 1023 ms on ip-10-181-0-146.ec2.internal (progress: 32/216) | |
13/12/09 15:47:03,488 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 31) | |
13/12/09 15:47:03,544 INFO cluster.ClusterTaskSetManager: Finished TID 37 in 661 ms on ip-10-43-129-89.ec2.internal (progress: 33/216) | |
13/12/09 15:47:03,544 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 37) | |
13/12/09 15:47:03,544 INFO cluster.ClusterTaskSetManager: Starting task 1.0:49 as TID 49 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,545 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:49 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,556 INFO cluster.ClusterTaskSetManager: Finished TID 30 in 1112 ms on ip-10-181-0-146.ec2.internal (progress: 34/216) | |
13/12/09 15:47:03,556 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 30) | |
13/12/09 15:47:03,556 INFO cluster.ClusterTaskSetManager: Starting task 1.0:50 as TID 50 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,557 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:50 as 2083 bytes in 1 ms | |
13/12/09 15:47:03,559 INFO cluster.ClusterTaskSetManager: Starting task 1.0:51 as TID 51 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,560 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:51 as 2083 bytes in 1 ms | |
13/12/09 15:47:03,560 INFO cluster.ClusterTaskSetManager: Finished TID 36 in 710 ms on ip-10-43-129-89.ec2.internal (progress: 35/216) | |
13/12/09 15:47:03,561 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 36) | |
13/12/09 15:47:03,612 INFO cluster.ClusterTaskSetManager: Starting task 1.0:52 as TID 52 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,613 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:52 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,613 INFO cluster.ClusterTaskSetManager: Finished TID 29 in 1238 ms on ip-10-181-0-146.ec2.internal (progress: 36/216) | |
13/12/09 15:47:03,614 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 29) | |
13/12/09 15:47:03,672 INFO cluster.ClusterTaskSetManager: Starting task 1.0:53 as TID 53 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,673 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:53 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,673 INFO cluster.ClusterTaskSetManager: Finished TID 32 in 1080 ms on ip-10-181-0-146.ec2.internal (progress: 37/216) | |
13/12/09 15:47:03,674 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 32) | |
13/12/09 15:47:03,746 INFO cluster.ClusterTaskSetManager: Starting task 1.0:54 as TID 54 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:03,746 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:54 as 2083 bytes in 0 ms | |
13/12/09 15:47:03,747 INFO cluster.ClusterTaskSetManager: Finished TID 38 in 739 ms on ip-10-43-129-89.ec2.internal (progress: 38/216) | |
13/12/09 15:47:03,748 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 38) | |
13/12/09 15:47:04,099 INFO cluster.ClusterTaskSetManager: Starting task 1.0:55 as TID 55 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,099 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:55 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,100 INFO cluster.ClusterTaskSetManager: Finished TID 45 in 723 ms on ip-10-43-129-89.ec2.internal (progress: 39/216) | |
13/12/09 15:47:04,101 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 45) | |
13/12/09 15:47:04,104 INFO cluster.ClusterTaskSetManager: Starting task 1.0:56 as TID 56 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,104 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:56 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,105 INFO cluster.ClusterTaskSetManager: Finished TID 46 in 709 ms on ip-10-181-0-146.ec2.internal (progress: 40/216) | |
13/12/09 15:47:04,106 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 46) | |
13/12/09 15:47:04,119 INFO cluster.ClusterTaskSetManager: Starting task 1.0:57 as TID 57 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,119 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:57 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,121 INFO cluster.ClusterTaskSetManager: Finished TID 48 in 635 ms on ip-10-181-0-146.ec2.internal (progress: 41/216) | |
13/12/09 15:47:04,122 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 48) | |
13/12/09 15:47:04,167 INFO cluster.ClusterTaskSetManager: Starting task 1.0:58 as TID 58 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,168 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:58 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,172 INFO cluster.ClusterTaskSetManager: Finished TID 47 in 742 ms on ip-10-181-0-146.ec2.internal (progress: 42/216) | |
13/12/09 15:47:04,172 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 47) | |
13/12/09 15:47:04,176 INFO cluster.ClusterTaskSetManager: Starting task 1.0:59 as TID 59 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,176 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:59 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,177 INFO cluster.ClusterTaskSetManager: Finished TID 40 in 1133 ms on ip-10-43-129-89.ec2.internal (progress: 43/216) | |
13/12/09 15:47:04,177 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 40) | |
13/12/09 15:47:04,225 INFO cluster.ClusterTaskSetManager: Starting task 1.0:60 as TID 60 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,226 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:60 as 2083 bytes in 1 ms | |
13/12/09 15:47:04,227 INFO cluster.ClusterTaskSetManager: Starting task 1.0:61 as TID 61 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,227 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:61 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,228 INFO cluster.ClusterTaskSetManager: Finished TID 41 in 1174 ms on ip-10-43-129-89.ec2.internal (progress: 44/216) | |
13/12/09 15:47:04,228 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 41) | |
13/12/09 15:47:04,228 INFO cluster.ClusterTaskSetManager: Finished TID 39 in 1210 ms on ip-10-43-129-89.ec2.internal (progress: 45/216) | |
13/12/09 15:47:04,229 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 39) | |
13/12/09 15:47:04,231 INFO cluster.ClusterTaskSetManager: Starting task 1.0:62 as TID 62 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,232 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:62 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,233 INFO cluster.ClusterTaskSetManager: Finished TID 50 in 676 ms on ip-10-181-0-146.ec2.internal (progress: 46/216) | |
13/12/09 15:47:04,233 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 50) | |
13/12/09 15:47:04,271 INFO cluster.ClusterTaskSetManager: Starting task 1.0:63 as TID 63 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,272 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:63 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,273 INFO cluster.ClusterTaskSetManager: Finished TID 49 in 729 ms on ip-10-43-129-89.ec2.internal (progress: 47/216) | |
13/12/09 15:47:04,273 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 49) | |
13/12/09 15:47:04,331 INFO cluster.ClusterTaskSetManager: Starting task 1.0:64 as TID 64 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,332 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:64 as 2083 bytes in 1 ms | |
13/12/09 15:47:04,332 INFO cluster.ClusterTaskSetManager: Finished TID 42 in 1198 ms on ip-10-43-129-89.ec2.internal (progress: 48/216) | |
13/12/09 15:47:04,333 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 42) | |
13/12/09 15:47:04,376 INFO cluster.ClusterTaskSetManager: Starting task 1.0:65 as TID 65 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,377 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:65 as 2083 bytes in 1 ms | |
13/12/09 15:47:04,377 INFO cluster.ClusterTaskSetManager: Finished TID 43 in 1124 ms on ip-10-181-0-146.ec2.internal (progress: 49/216) | |
13/12/09 15:47:04,378 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 43) | |
13/12/09 15:47:04,513 INFO cluster.ClusterTaskSetManager: Starting task 1.0:66 as TID 66 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,513 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:66 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,514 INFO cluster.ClusterTaskSetManager: Finished TID 44 in 1160 ms on ip-10-181-0-146.ec2.internal (progress: 50/216) | |
13/12/09 15:47:04,514 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 44) | |
13/12/09 15:47:04,603 INFO cluster.ClusterTaskSetManager: Starting task 1.0:67 as TID 67 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,603 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:67 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,604 INFO cluster.ClusterTaskSetManager: Finished TID 51 in 1046 ms on ip-10-43-129-89.ec2.internal (progress: 51/216) | |
13/12/09 15:47:04,604 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 51) | |
13/12/09 15:47:04,776 INFO cluster.ClusterTaskSetManager: Starting task 1.0:68 as TID 68 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,776 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:68 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,777 INFO cluster.ClusterTaskSetManager: Finished TID 52 in 1165 ms on ip-10-181-0-146.ec2.internal (progress: 52/216) | |
13/12/09 15:47:04,777 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 52) | |
13/12/09 15:47:04,793 INFO cluster.ClusterTaskSetManager: Finished TID 58 in 626 ms on ip-10-181-0-146.ec2.internal (progress: 53/216) | |
13/12/09 15:47:04,793 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 58) | |
13/12/09 15:47:04,793 INFO cluster.ClusterTaskSetManager: Starting task 1.0:69 as TID 69 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,794 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:69 as 2083 bytes in 1 ms | |
13/12/09 15:47:04,813 INFO cluster.ClusterTaskSetManager: Starting task 1.0:70 as TID 70 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,814 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:70 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,816 INFO cluster.ClusterTaskSetManager: Finished TID 59 in 640 ms on ip-10-43-129-89.ec2.internal (progress: 54/216) | |
13/12/09 15:47:04,816 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 59) | |
13/12/09 15:47:04,816 INFO cluster.ClusterTaskSetManager: Starting task 1.0:71 as TID 71 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,817 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:71 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,817 INFO cluster.ClusterTaskSetManager: Finished TID 54 in 1072 ms on ip-10-43-129-89.ec2.internal (progress: 55/216) | |
13/12/09 15:47:04,818 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 54) | |
13/12/09 15:47:04,818 INFO cluster.ClusterTaskSetManager: Starting task 1.0:72 as TID 72 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,818 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:72 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,819 INFO cluster.ClusterTaskSetManager: Finished TID 53 in 1147 ms on ip-10-181-0-146.ec2.internal (progress: 56/216) | |
13/12/09 15:47:04,820 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 53) | |
13/12/09 15:47:04,842 INFO cluster.ClusterTaskSetManager: Finished TID 57 in 723 ms on ip-10-181-0-146.ec2.internal (progress: 57/216) | |
13/12/09 15:47:04,842 INFO cluster.ClusterTaskSetManager: Starting task 1.0:73 as TID 73 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,843 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:73 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,844 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 57) | |
13/12/09 15:47:04,921 INFO cluster.ClusterTaskSetManager: Starting task 1.0:74 as TID 74 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,921 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:74 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,922 INFO cluster.ClusterTaskSetManager: Finished TID 61 in 695 ms on ip-10-43-129-89.ec2.internal (progress: 58/216) | |
13/12/09 15:47:04,922 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 61) | |
13/12/09 15:47:04,948 INFO cluster.ClusterTaskSetManager: Starting task 1.0:75 as TID 75 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:04,949 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:75 as 2083 bytes in 0 ms | |
13/12/09 15:47:04,950 INFO cluster.ClusterTaskSetManager: Finished TID 62 in 718 ms on ip-10-181-0-146.ec2.internal (progress: 59/216) | |
13/12/09 15:47:04,950 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 62) | |
13/12/09 15:47:05,001 INFO cluster.ClusterTaskSetManager: Starting task 1.0:76 as TID 76 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,001 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:76 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,002 INFO cluster.ClusterTaskSetManager: Finished TID 60 in 777 ms on ip-10-43-129-89.ec2.internal (progress: 60/216) | |
13/12/09 15:47:05,002 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 60) | |
13/12/09 15:47:05,136 INFO cluster.ClusterTaskSetManager: Starting task 1.0:77 as TID 77 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,136 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:77 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,137 INFO cluster.ClusterTaskSetManager: Finished TID 55 in 1038 ms on ip-10-43-129-89.ec2.internal (progress: 61/216) | |
13/12/09 15:47:05,137 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 55) | |
13/12/09 15:47:05,218 INFO cluster.ClusterTaskSetManager: Starting task 1.0:78 as TID 78 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,218 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:78 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,219 INFO cluster.ClusterTaskSetManager: Finished TID 56 in 1116 ms on ip-10-181-0-146.ec2.internal (progress: 62/216) | |
13/12/09 15:47:05,219 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 56) | |
13/12/09 15:47:05,344 INFO cluster.ClusterTaskSetManager: Starting task 1.0:79 as TID 79 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,345 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:79 as 2083 bytes in 1 ms | |
13/12/09 15:47:05,345 INFO cluster.ClusterTaskSetManager: Finished TID 63 in 1074 ms on ip-10-43-129-89.ec2.internal (progress: 63/216) | |
13/12/09 15:47:05,346 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 63) | |
13/12/09 15:47:05,353 INFO cluster.ClusterTaskSetManager: Starting task 1.0:80 as TID 80 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,354 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:80 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,355 INFO cluster.ClusterTaskSetManager: Finished TID 64 in 1023 ms on ip-10-43-129-89.ec2.internal (progress: 64/216) | |
13/12/09 15:47:05,355 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 64) | |
13/12/09 15:47:05,356 INFO cluster.ClusterTaskSetManager: Finished TID 72 in 538 ms on ip-10-181-0-146.ec2.internal (progress: 65/216) | |
13/12/09 15:47:05,357 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 72) | |
13/12/09 15:47:05,357 INFO cluster.ClusterTaskSetManager: Starting task 1.0:81 as TID 81 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,357 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:81 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,430 INFO cluster.ClusterTaskSetManager: Starting task 1.0:82 as TID 82 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,431 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:82 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,432 INFO cluster.ClusterTaskSetManager: Finished TID 73 in 590 ms on ip-10-181-0-146.ec2.internal (progress: 66/216) | |
13/12/09 15:47:05,432 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 73) | |
13/12/09 15:47:05,436 INFO cluster.ClusterTaskSetManager: Starting task 1.0:83 as TID 83 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,436 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:83 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,437 INFO cluster.ClusterTaskSetManager: Finished TID 70 in 624 ms on ip-10-43-129-89.ec2.internal (progress: 67/216) | |
13/12/09 15:47:05,437 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 70) | |
13/12/09 15:47:05,445 INFO cluster.ClusterTaskSetManager: Finished TID 71 in 628 ms on ip-10-43-129-89.ec2.internal (progress: 68/216) | |
13/12/09 15:47:05,445 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 71) | |
13/12/09 15:47:05,445 INFO cluster.ClusterTaskSetManager: Starting task 1.0:84 as TID 84 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,446 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:84 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,455 INFO cluster.ClusterTaskSetManager: Finished TID 69 in 662 ms on ip-10-181-0-146.ec2.internal (progress: 69/216) | |
13/12/09 15:47:05,456 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 69) | |
13/12/09 15:47:05,456 INFO cluster.ClusterTaskSetManager: Starting task 1.0:85 as TID 85 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,456 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:85 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,463 INFO cluster.ClusterTaskSetManager: Starting task 1.0:86 as TID 86 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,463 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:86 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,464 INFO cluster.ClusterTaskSetManager: Finished TID 65 in 1088 ms on ip-10-181-0-146.ec2.internal (progress: 70/216) | |
13/12/09 15:47:05,465 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 65) | |
13/12/09 15:47:05,593 INFO cluster.ClusterTaskSetManager: Starting task 1.0:87 as TID 87 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,593 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:87 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,594 INFO cluster.ClusterTaskSetManager: Finished TID 74 in 674 ms on ip-10-43-129-89.ec2.internal (progress: 71/216) | |
13/12/09 15:47:05,594 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 74) | |
13/12/09 15:47:05,595 INFO cluster.ClusterTaskSetManager: Finished TID 66 in 1082 ms on ip-10-181-0-146.ec2.internal (progress: 72/216) | |
13/12/09 15:47:05,595 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 66) | |
13/12/09 15:47:05,596 INFO cluster.ClusterTaskSetManager: Starting task 1.0:88 as TID 88 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,596 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:88 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,665 INFO cluster.ClusterTaskSetManager: Starting task 1.0:89 as TID 89 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,665 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:89 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,666 INFO cluster.ClusterTaskSetManager: Finished TID 67 in 1063 ms on ip-10-43-129-89.ec2.internal (progress: 73/216) | |
13/12/09 15:47:05,667 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 67) | |
13/12/09 15:47:05,800 INFO cluster.ClusterTaskSetManager: Finished TID 68 in 1024 ms on ip-10-181-0-146.ec2.internal (progress: 74/216) | |
13/12/09 15:47:05,800 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 68) | |
13/12/09 15:47:05,801 INFO cluster.ClusterTaskSetManager: Starting task 1.0:90 as TID 90 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,801 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:90 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,953 INFO cluster.ClusterTaskSetManager: Starting task 1.0:91 as TID 91 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,954 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:91 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,955 INFO cluster.ClusterTaskSetManager: Finished TID 81 in 598 ms on ip-10-181-0-146.ec2.internal (progress: 75/216) | |
13/12/09 15:47:05,955 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 81) | |
13/12/09 15:47:05,977 INFO cluster.ClusterTaskSetManager: Starting task 1.0:92 as TID 92 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,977 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:92 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,978 INFO cluster.ClusterTaskSetManager: Finished TID 82 in 548 ms on ip-10-181-0-146.ec2.internal (progress: 76/216) | |
13/12/09 15:47:05,978 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 82) | |
13/12/09 15:47:05,991 INFO cluster.ClusterTaskSetManager: Starting task 1.0:93 as TID 93 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:05,991 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:93 as 2083 bytes in 0 ms | |
13/12/09 15:47:05,992 INFO cluster.ClusterTaskSetManager: Finished TID 85 in 536 ms on ip-10-181-0-146.ec2.internal (progress: 77/216) | |
13/12/09 15:47:05,993 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 85) | |
13/12/09 15:47:06,022 INFO cluster.ClusterTaskSetManager: Starting task 1.0:94 as TID 94 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,023 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:94 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,024 INFO cluster.ClusterTaskSetManager: Finished TID 76 in 1023 ms on ip-10-43-129-89.ec2.internal (progress: 78/216) | |
13/12/09 15:47:06,024 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 76) | |
13/12/09 15:47:06,024 INFO cluster.ClusterTaskSetManager: Starting task 1.0:95 as TID 95 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,025 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:95 as 2083 bytes in 1 ms | |
13/12/09 15:47:06,025 INFO cluster.ClusterTaskSetManager: Finished TID 75 in 1077 ms on ip-10-181-0-146.ec2.internal (progress: 79/216) | |
13/12/09 15:47:06,026 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 75) | |
13/12/09 15:47:06,041 INFO cluster.ClusterTaskSetManager: Starting task 1.0:96 as TID 96 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,041 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:96 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,042 INFO cluster.ClusterTaskSetManager: Finished TID 83 in 607 ms on ip-10-43-129-89.ec2.internal (progress: 80/216) | |
13/12/09 15:47:06,042 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 83) | |
13/12/09 15:47:06,043 INFO cluster.ClusterTaskSetManager: Starting task 1.0:97 as TID 97 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,043 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:97 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,044 INFO cluster.ClusterTaskSetManager: Finished TID 84 in 598 ms on ip-10-43-129-89.ec2.internal (progress: 81/216) | |
13/12/09 15:47:06,044 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 84) | |
13/12/09 15:47:06,075 INFO cluster.ClusterTaskSetManager: Starting task 1.0:98 as TID 98 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,075 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:98 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,076 INFO cluster.ClusterTaskSetManager: Finished TID 77 in 941 ms on ip-10-43-129-89.ec2.internal (progress: 82/216) | |
13/12/09 15:47:06,076 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 77) | |
13/12/09 15:47:06,094 INFO cluster.ClusterTaskSetManager: Starting task 1.0:99 as TID 99 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,094 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:99 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,095 INFO cluster.ClusterTaskSetManager: Finished TID 86 in 632 ms on ip-10-181-0-146.ec2.internal (progress: 83/216) | |
13/12/09 15:47:06,096 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 86) | |
13/12/09 15:47:06,373 INFO cluster.ClusterTaskSetManager: Starting task 1.0:100 as TID 100 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,374 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:100 as 2083 bytes in 1 ms | |
13/12/09 15:47:06,375 INFO cluster.ClusterTaskSetManager: Finished TID 79 in 1030 ms on ip-10-43-129-89.ec2.internal (progress: 84/216) | |
13/12/09 15:47:06,375 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 79) | |
13/12/09 15:47:06,379 INFO cluster.ClusterTaskSetManager: Starting task 1.0:101 as TID 101 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,379 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:101 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,380 INFO cluster.ClusterTaskSetManager: Finished TID 78 in 1163 ms on ip-10-181-0-146.ec2.internal (progress: 85/216) | |
13/12/09 15:47:06,380 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 78) | |
13/12/09 15:47:06,466 INFO cluster.ClusterTaskSetManager: Starting task 1.0:102 as TID 102 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,466 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:102 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,467 INFO cluster.ClusterTaskSetManager: Finished TID 80 in 1114 ms on ip-10-43-129-89.ec2.internal (progress: 86/216) | |
13/12/09 15:47:06,467 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 80) | |
13/12/09 15:47:06,594 INFO cluster.ClusterTaskSetManager: Starting task 1.0:103 as TID 103 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,594 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:103 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,595 INFO cluster.ClusterTaskSetManager: Finished TID 98 in 520 ms on ip-10-43-129-89.ec2.internal (progress: 87/216) | |
13/12/09 15:47:06,595 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 98) | |
13/12/09 15:47:06,596 INFO cluster.ClusterTaskSetManager: Starting task 1.0:104 as TID 104 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,596 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:104 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,597 INFO cluster.ClusterTaskSetManager: Finished TID 96 in 555 ms on ip-10-43-129-89.ec2.internal (progress: 88/216) | |
13/12/09 15:47:06,597 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 96) | |
13/12/09 15:47:06,603 INFO cluster.ClusterTaskSetManager: Starting task 1.0:105 as TID 105 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,604 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:105 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,605 INFO cluster.ClusterTaskSetManager: Finished TID 94 in 582 ms on ip-10-43-129-89.ec2.internal (progress: 89/216) | |
13/12/09 15:47:06,605 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 94) | |
13/12/09 15:47:06,611 INFO cluster.ClusterTaskSetManager: Starting task 1.0:106 as TID 106 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,611 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:106 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,612 INFO cluster.ClusterTaskSetManager: Finished TID 95 in 588 ms on ip-10-181-0-146.ec2.internal (progress: 90/216) | |
13/12/09 15:47:06,613 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 95) | |
13/12/09 15:47:06,635 INFO cluster.ClusterTaskSetManager: Starting task 1.0:107 as TID 107 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,636 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:107 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,637 INFO cluster.ClusterTaskSetManager: Finished TID 88 in 1041 ms on ip-10-181-0-146.ec2.internal (progress: 91/216) | |
13/12/09 15:47:06,637 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 88) | |
13/12/09 15:47:06,638 INFO cluster.ClusterTaskSetManager: Starting task 1.0:108 as TID 108 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,638 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:108 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,639 INFO cluster.ClusterTaskSetManager: Finished TID 93 in 648 ms on ip-10-181-0-146.ec2.internal (progress: 92/216) | |
13/12/09 15:47:06,639 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 93) | |
13/12/09 15:47:06,661 INFO cluster.ClusterTaskSetManager: Finished TID 89 in 996 ms on ip-10-43-129-89.ec2.internal (progress: 93/216) | |
13/12/09 15:47:06,661 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 89) | |
13/12/09 15:47:06,662 INFO cluster.ClusterTaskSetManager: Starting task 1.0:109 as TID 109 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,662 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:109 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,673 INFO cluster.ClusterTaskSetManager: Starting task 1.0:110 as TID 110 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,673 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:110 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,674 INFO cluster.ClusterTaskSetManager: Finished TID 97 in 632 ms on ip-10-43-129-89.ec2.internal (progress: 94/216) | |
13/12/09 15:47:06,674 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 97) | |
13/12/09 15:47:06,762 INFO cluster.ClusterTaskSetManager: Starting task 1.0:111 as TID 111 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,762 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:111 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,763 INFO cluster.ClusterTaskSetManager: Finished TID 87 in 1171 ms on ip-10-43-129-89.ec2.internal (progress: 95/216) | |
13/12/09 15:47:06,764 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 87) | |
13/12/09 15:47:06,895 INFO cluster.ClusterTaskSetManager: Starting task 1.0:112 as TID 112 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:06,896 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:112 as 2083 bytes in 0 ms | |
13/12/09 15:47:06,897 INFO cluster.ClusterTaskSetManager: Finished TID 90 in 1095 ms on ip-10-181-0-146.ec2.internal (progress: 96/216) | |
13/12/09 15:47:06,897 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 90) | |
13/12/09 15:47:07,099 INFO cluster.ClusterTaskSetManager: Starting task 1.0:113 as TID 113 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,100 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:113 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,101 INFO cluster.ClusterTaskSetManager: Finished TID 92 in 1125 ms on ip-10-181-0-146.ec2.internal (progress: 97/216) | |
13/12/09 15:47:07,101 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 92) | |
13/12/09 15:47:07,112 INFO cluster.ClusterTaskSetManager: Starting task 1.0:114 as TID 114 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,112 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:114 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,113 INFO cluster.ClusterTaskSetManager: Finished TID 91 in 1160 ms on ip-10-181-0-146.ec2.internal (progress: 98/216) | |
13/12/09 15:47:07,114 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 91) | |
13/12/09 15:47:07,119 INFO cluster.ClusterTaskSetManager: Starting task 1.0:115 as TID 115 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,120 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:115 as 2083 bytes in 1 ms | |
13/12/09 15:47:07,120 INFO cluster.ClusterTaskSetManager: Finished TID 99 in 1026 ms on ip-10-181-0-146.ec2.internal (progress: 99/216) | |
13/12/09 15:47:07,121 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 99) | |
13/12/09 15:47:07,166 INFO cluster.ClusterTaskSetManager: Starting task 1.0:116 as TID 116 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,167 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:116 as 2083 bytes in 1 ms | |
13/12/09 15:47:07,167 INFO cluster.ClusterTaskSetManager: Finished TID 110 in 494 ms on ip-10-43-129-89.ec2.internal (progress: 100/216) | |
13/12/09 15:47:07,168 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 110) | |
13/12/09 15:47:07,177 INFO cluster.ClusterTaskSetManager: Starting task 1.0:117 as TID 117 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,178 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:117 as 2083 bytes in 1 ms | |
13/12/09 15:47:07,179 INFO cluster.ClusterTaskSetManager: Finished TID 105 in 576 ms on ip-10-43-129-89.ec2.internal (progress: 101/216) | |
13/12/09 15:47:07,180 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 105) | |
13/12/09 15:47:07,199 INFO cluster.ClusterTaskSetManager: Starting task 1.0:118 as TID 118 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,199 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:118 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,200 INFO cluster.ClusterTaskSetManager: Finished TID 108 in 563 ms on ip-10-181-0-146.ec2.internal (progress: 102/216) | |
13/12/09 15:47:07,200 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 108) | |
13/12/09 15:47:07,206 INFO cluster.ClusterTaskSetManager: Starting task 1.0:119 as TID 119 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,206 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:119 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,207 INFO cluster.ClusterTaskSetManager: Finished TID 106 in 595 ms on ip-10-181-0-146.ec2.internal (progress: 103/216) | |
13/12/09 15:47:07,207 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 106) | |
13/12/09 15:47:07,231 INFO cluster.ClusterTaskSetManager: Starting task 1.0:120 as TID 120 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,232 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:120 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,232 INFO cluster.ClusterTaskSetManager: Finished TID 109 in 570 ms on ip-10-43-129-89.ec2.internal (progress: 104/216) | |
13/12/09 15:47:07,233 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 109) | |
13/12/09 15:47:07,249 INFO cluster.ClusterTaskSetManager: Starting task 1.0:121 as TID 121 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,250 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:121 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,251 INFO cluster.ClusterTaskSetManager: Finished TID 107 in 616 ms on ip-10-181-0-146.ec2.internal (progress: 105/216) | |
13/12/09 15:47:07,251 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 107) | |
13/12/09 15:47:07,252 INFO cluster.ClusterTaskSetManager: Starting task 1.0:122 as TID 122 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,252 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:122 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,253 INFO cluster.ClusterTaskSetManager: Finished TID 100 in 880 ms on ip-10-43-129-89.ec2.internal (progress: 106/216) | |
13/12/09 15:47:07,254 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 100) | |
13/12/09 15:47:07,340 INFO cluster.ClusterTaskSetManager: Starting task 1.0:123 as TID 123 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,341 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:123 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,342 INFO cluster.ClusterTaskSetManager: Finished TID 102 in 877 ms on ip-10-43-129-89.ec2.internal (progress: 107/216) | |
13/12/09 15:47:07,342 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 102) | |
13/12/09 15:47:07,393 INFO cluster.ClusterTaskSetManager: Starting task 1.0:124 as TID 124 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,393 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:124 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,394 INFO cluster.ClusterTaskSetManager: Finished TID 101 in 1015 ms on ip-10-181-0-146.ec2.internal (progress: 108/216) | |
13/12/09 15:47:07,395 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 101) | |
13/12/09 15:47:07,453 INFO cluster.ClusterTaskSetManager: Starting task 1.0:125 as TID 125 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,454 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:125 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,455 INFO cluster.ClusterTaskSetManager: Finished TID 103 in 860 ms on ip-10-43-129-89.ec2.internal (progress: 109/216) | |
13/12/09 15:47:07,455 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 103) | |
13/12/09 15:47:07,760 INFO cluster.ClusterTaskSetManager: Starting task 1.0:126 as TID 126 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,760 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:126 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,761 INFO cluster.ClusterTaskSetManager: Finished TID 119 in 556 ms on ip-10-181-0-146.ec2.internal (progress: 110/216) | |
13/12/09 15:47:07,761 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 119) | |
13/12/09 15:47:07,761 INFO cluster.ClusterTaskSetManager: Starting task 1.0:127 as TID 127 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,762 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:127 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,763 INFO cluster.ClusterTaskSetManager: Finished TID 118 in 563 ms on ip-10-181-0-146.ec2.internal (progress: 111/216) | |
13/12/09 15:47:07,763 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 118) | |
13/12/09 15:47:07,793 INFO cluster.ClusterTaskSetManager: Starting task 1.0:128 as TID 128 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,794 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:128 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,795 INFO cluster.ClusterTaskSetManager: Finished TID 117 in 617 ms on ip-10-43-129-89.ec2.internal (progress: 112/216) | |
13/12/09 15:47:07,795 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 117) | |
13/12/09 15:47:07,796 INFO cluster.ClusterTaskSetManager: Starting task 1.0:129 as TID 129 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,796 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:129 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,797 INFO cluster.ClusterTaskSetManager: Finished TID 112 in 902 ms on ip-10-181-0-146.ec2.internal (progress: 113/216) | |
13/12/09 15:47:07,797 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 112) | |
13/12/09 15:47:07,803 INFO cluster.ClusterTaskSetManager: Finished TID 121 in 554 ms on ip-10-181-0-146.ec2.internal (progress: 114/216) | |
13/12/09 15:47:07,803 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 121) | |
13/12/09 15:47:07,804 INFO cluster.ClusterTaskSetManager: Starting task 1.0:130 as TID 130 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,804 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:130 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,830 INFO cluster.ClusterTaskSetManager: Starting task 1.0:131 as TID 131 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,830 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:131 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,831 INFO cluster.ClusterTaskSetManager: Finished TID 120 in 600 ms on ip-10-43-129-89.ec2.internal (progress: 115/216) | |
13/12/09 15:47:07,832 INFO cluster.ClusterTaskSetManager: Finished TID 122 in 580 ms on ip-10-43-129-89.ec2.internal (progress: 116/216) | |
13/12/09 15:47:07,833 INFO cluster.ClusterTaskSetManager: Starting task 1.0:132 as TID 132 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,833 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:132 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,833 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 120) | |
13/12/09 15:47:07,835 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 122) | |
13/12/09 15:47:07,935 INFO cluster.ClusterTaskSetManager: Starting task 1.0:133 as TID 133 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,936 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:133 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,937 INFO cluster.ClusterTaskSetManager: Finished TID 104 in 1342 ms on ip-10-43-129-89.ec2.internal (progress: 117/216) | |
13/12/09 15:47:07,937 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 104) | |
13/12/09 15:47:07,974 INFO cluster.ClusterTaskSetManager: Starting task 1.0:134 as TID 134 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,975 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:134 as 2083 bytes in 1 ms | |
13/12/09 15:47:07,975 INFO cluster.ClusterTaskSetManager: Finished TID 113 in 876 ms on ip-10-181-0-146.ec2.internal (progress: 118/216) | |
13/12/09 15:47:07,976 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 113) | |
13/12/09 15:47:07,979 INFO cluster.ClusterTaskSetManager: Starting task 1.0:135 as TID 135 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:07,980 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:135 as 2083 bytes in 0 ms | |
13/12/09 15:47:07,981 INFO cluster.ClusterTaskSetManager: Finished TID 115 in 861 ms on ip-10-181-0-146.ec2.internal (progress: 119/216) | |
13/12/09 15:47:07,981 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 115) | |
13/12/09 15:47:08,005 INFO cluster.ClusterTaskSetManager: Finished TID 111 in 1244 ms on ip-10-43-129-89.ec2.internal (progress: 120/216) | |
13/12/09 15:47:08,005 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 111) | |
13/12/09 15:47:08,006 INFO cluster.ClusterTaskSetManager: Starting task 1.0:136 as TID 136 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,006 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:136 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,014 INFO cluster.ClusterTaskSetManager: Starting task 1.0:137 as TID 137 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,014 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:137 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,015 INFO cluster.ClusterTaskSetManager: Finished TID 114 in 903 ms on ip-10-181-0-146.ec2.internal (progress: 121/216) | |
13/12/09 15:47:08,015 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 114) | |
13/12/09 15:47:08,072 INFO cluster.ClusterTaskSetManager: Starting task 1.0:138 as TID 138 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,073 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:138 as 2083 bytes in 1 ms | |
13/12/09 15:47:08,073 INFO cluster.ClusterTaskSetManager: Finished TID 116 in 907 ms on ip-10-43-129-89.ec2.internal (progress: 122/216) | |
13/12/09 15:47:08,074 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 116) | |
13/12/09 15:47:08,181 INFO cluster.ClusterTaskSetManager: Starting task 1.0:139 as TID 139 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,182 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:139 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,182 INFO cluster.ClusterTaskSetManager: Finished TID 123 in 842 ms on ip-10-43-129-89.ec2.internal (progress: 123/216) | |
13/12/09 15:47:08,183 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 123) | |
13/12/09 15:47:08,293 INFO cluster.ClusterTaskSetManager: Starting task 1.0:140 as TID 140 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,294 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:140 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,295 INFO cluster.ClusterTaskSetManager: Finished TID 125 in 842 ms on ip-10-43-129-89.ec2.internal (progress: 124/216) | |
13/12/09 15:47:08,296 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 125) | |
13/12/09 15:47:08,312 INFO cluster.ClusterTaskSetManager: Starting task 1.0:141 as TID 141 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,313 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:141 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,314 INFO cluster.ClusterTaskSetManager: Finished TID 124 in 921 ms on ip-10-181-0-146.ec2.internal (progress: 125/216) | |
13/12/09 15:47:08,314 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 124) | |
13/12/09 15:47:08,353 INFO cluster.ClusterTaskSetManager: Finished TID 132 in 521 ms on ip-10-43-129-89.ec2.internal (progress: 126/216) | |
13/12/09 15:47:08,354 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 132) | |
13/12/09 15:47:08,354 INFO cluster.ClusterTaskSetManager: Starting task 1.0:142 as TID 142 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,355 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:142 as 2083 bytes in 1 ms | |
13/12/09 15:47:08,427 INFO cluster.ClusterTaskSetManager: Starting task 1.0:143 as TID 143 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,428 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:143 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,428 INFO cluster.ClusterTaskSetManager: Finished TID 129 in 633 ms on ip-10-181-0-146.ec2.internal (progress: 127/216) | |
13/12/09 15:47:08,429 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 129) | |
13/12/09 15:47:08,439 INFO cluster.ClusterTaskSetManager: Starting task 1.0:144 as TID 144 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,440 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:144 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,440 INFO cluster.ClusterTaskSetManager: Finished TID 130 in 637 ms on ip-10-181-0-146.ec2.internal (progress: 128/216) | |
13/12/09 15:47:08,441 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 130) | |
13/12/09 15:47:08,476 INFO cluster.ClusterTaskSetManager: Finished TID 131 in 647 ms on ip-10-43-129-89.ec2.internal (progress: 129/216) | |
13/12/09 15:47:08,477 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 131) | |
13/12/09 15:47:08,477 INFO cluster.ClusterTaskSetManager: Starting task 1.0:145 as TID 145 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,478 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:145 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,533 INFO cluster.ClusterTaskSetManager: Finished TID 134 in 558 ms on ip-10-181-0-146.ec2.internal (progress: 130/216) | |
13/12/09 15:47:08,534 INFO cluster.ClusterTaskSetManager: Starting task 1.0:146 as TID 146 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,534 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 134) | |
13/12/09 15:47:08,534 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:146 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,536 INFO cluster.ClusterTaskSetManager: Starting task 1.0:147 as TID 147 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,537 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:147 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,537 INFO cluster.ClusterTaskSetManager: Finished TID 133 in 602 ms on ip-10-43-129-89.ec2.internal (progress: 131/216) | |
13/12/09 15:47:08,538 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 133) | |
13/12/09 15:47:08,574 INFO cluster.ClusterTaskSetManager: Starting task 1.0:148 as TID 148 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,575 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:148 as 2083 bytes in 1 ms | |
13/12/09 15:47:08,575 INFO cluster.ClusterTaskSetManager: Finished TID 127 in 814 ms on ip-10-181-0-146.ec2.internal (progress: 132/216) | |
13/12/09 15:47:08,576 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 127) | |
13/12/09 15:47:08,619 INFO cluster.ClusterTaskSetManager: Starting task 1.0:149 as TID 149 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,620 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:149 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,621 INFO cluster.ClusterTaskSetManager: Finished TID 128 in 827 ms on ip-10-43-129-89.ec2.internal (progress: 133/216) | |
13/12/09 15:47:08,621 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 128) | |
13/12/09 15:47:08,675 INFO cluster.ClusterTaskSetManager: Finished TID 126 in 915 ms on ip-10-181-0-146.ec2.internal (progress: 134/216) | |
13/12/09 15:47:08,675 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 126) | |
13/12/09 15:47:08,675 INFO cluster.ClusterTaskSetManager: Starting task 1.0:150 as TID 150 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,676 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:150 as 2083 bytes in 1 ms | |
13/12/09 15:47:08,825 INFO cluster.ClusterTaskSetManager: Starting task 1.0:151 as TID 151 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,826 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:151 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,826 INFO cluster.ClusterTaskSetManager: Finished TID 141 in 514 ms on ip-10-181-0-146.ec2.internal (progress: 135/216) | |
13/12/09 15:47:08,827 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 141) | |
13/12/09 15:47:08,879 INFO cluster.ClusterTaskSetManager: Finished TID 136 in 874 ms on ip-10-43-129-89.ec2.internal (progress: 136/216) | |
13/12/09 15:47:08,879 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 136) | |
13/12/09 15:47:08,879 INFO cluster.ClusterTaskSetManager: Starting task 1.0:152 as TID 152 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,880 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:152 as 2083 bytes in 1 ms | |
13/12/09 15:47:08,902 INFO cluster.ClusterTaskSetManager: Starting task 1.0:153 as TID 153 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,902 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:153 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,903 INFO cluster.ClusterTaskSetManager: Finished TID 142 in 549 ms on ip-10-43-129-89.ec2.internal (progress: 137/216) | |
13/12/09 15:47:08,904 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 142) | |
13/12/09 15:47:08,924 INFO cluster.ClusterTaskSetManager: Starting task 1.0:154 as TID 154 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,924 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:154 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,925 INFO cluster.ClusterTaskSetManager: Finished TID 135 in 946 ms on ip-10-181-0-146.ec2.internal (progress: 138/216) | |
13/12/09 15:47:08,925 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 135) | |
13/12/09 15:47:08,926 INFO cluster.ClusterTaskSetManager: Finished TID 137 in 912 ms on ip-10-181-0-146.ec2.internal (progress: 139/216) | |
13/12/09 15:47:08,926 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 137) | |
13/12/09 15:47:08,926 INFO cluster.ClusterTaskSetManager: Starting task 1.0:155 as TID 155 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,927 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:155 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,943 INFO cluster.ClusterTaskSetManager: Starting task 1.0:156 as TID 156 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,943 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:156 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,944 INFO cluster.ClusterTaskSetManager: Finished TID 138 in 872 ms on ip-10-43-129-89.ec2.internal (progress: 140/216) | |
13/12/09 15:47:08,944 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 138) | |
13/12/09 15:47:08,996 INFO cluster.ClusterTaskSetManager: Starting task 1.0:157 as TID 157 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:08,997 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:157 as 2083 bytes in 0 ms | |
13/12/09 15:47:08,997 INFO cluster.ClusterTaskSetManager: Finished TID 139 in 816 ms on ip-10-43-129-89.ec2.internal (progress: 141/216) | |
13/12/09 15:47:08,998 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 139) | |
13/12/09 15:47:09,015 INFO cluster.ClusterTaskSetManager: Finished TID 145 in 538 ms on ip-10-43-129-89.ec2.internal (progress: 142/216) | |
13/12/09 15:47:09,016 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 145) | |
13/12/09 15:47:09,016 INFO cluster.ClusterTaskSetManager: Starting task 1.0:158 as TID 158 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,016 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:158 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,032 INFO cluster.ClusterTaskSetManager: Starting task 1.0:159 as TID 159 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,033 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:159 as 2083 bytes in 1 ms | |
13/12/09 15:47:09,033 INFO cluster.ClusterTaskSetManager: Finished TID 144 in 594 ms on ip-10-181-0-146.ec2.internal (progress: 143/216) | |
13/12/09 15:47:09,034 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 144) | |
13/12/09 15:47:09,061 INFO cluster.ClusterTaskSetManager: Finished TID 146 in 528 ms on ip-10-181-0-146.ec2.internal (progress: 144/216) | |
13/12/09 15:47:09,062 INFO cluster.ClusterTaskSetManager: Starting task 1.0:160 as TID 160 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,062 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:160 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,063 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 146) | |
13/12/09 15:47:09,115 INFO cluster.ClusterTaskSetManager: Starting task 1.0:161 as TID 161 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,116 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:161 as 2083 bytes in 1 ms | |
13/12/09 15:47:09,116 INFO cluster.ClusterTaskSetManager: Finished TID 143 in 690 ms on ip-10-181-0-146.ec2.internal (progress: 145/216) | |
13/12/09 15:47:09,117 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 143) | |
13/12/09 15:47:09,171 INFO cluster.ClusterTaskSetManager: Starting task 1.0:162 as TID 162 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,171 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:162 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,172 INFO cluster.ClusterTaskSetManager: Finished TID 140 in 879 ms on ip-10-43-129-89.ec2.internal (progress: 146/216) | |
13/12/09 15:47:09,172 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 140) | |
13/12/09 15:47:09,395 INFO cluster.ClusterTaskSetManager: Starting task 1.0:163 as TID 163 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,395 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:163 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,396 INFO cluster.ClusterTaskSetManager: Finished TID 147 in 860 ms on ip-10-43-129-89.ec2.internal (progress: 147/216) | |
13/12/09 15:47:09,396 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 147) | |
13/12/09 15:47:09,408 INFO cluster.ClusterTaskSetManager: Starting task 1.0:164 as TID 164 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,409 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:164 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,410 INFO cluster.ClusterTaskSetManager: Finished TID 148 in 836 ms on ip-10-181-0-146.ec2.internal (progress: 148/216) | |
13/12/09 15:47:09,410 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 148) | |
13/12/09 15:47:09,450 INFO cluster.ClusterTaskSetManager: Starting task 1.0:165 as TID 165 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,450 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:165 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,451 INFO cluster.ClusterTaskSetManager: Finished TID 154 in 528 ms on ip-10-181-0-146.ec2.internal (progress: 149/216) | |
13/12/09 15:47:09,451 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 154) | |
13/12/09 15:47:09,475 INFO cluster.ClusterTaskSetManager: Starting task 1.0:166 as TID 166 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,475 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:166 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,476 INFO cluster.ClusterTaskSetManager: Finished TID 153 in 574 ms on ip-10-43-129-89.ec2.internal (progress: 150/216) | |
13/12/09 15:47:09,476 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 153) | |
13/12/09 15:47:09,494 INFO cluster.ClusterTaskSetManager: Starting task 1.0:167 as TID 167 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,495 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:167 as 2083 bytes in 1 ms | |
13/12/09 15:47:09,495 INFO cluster.ClusterTaskSetManager: Finished TID 156 in 552 ms on ip-10-43-129-89.ec2.internal (progress: 151/216) | |
13/12/09 15:47:09,496 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 156) | |
13/12/09 15:47:09,507 INFO cluster.ClusterTaskSetManager: Starting task 1.0:168 as TID 168 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,507 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:168 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,508 INFO cluster.ClusterTaskSetManager: Finished TID 150 in 833 ms on ip-10-181-0-146.ec2.internal (progress: 152/216) | |
13/12/09 15:47:09,508 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 150) | |
13/12/09 15:47:09,512 INFO cluster.ClusterTaskSetManager: Starting task 1.0:169 as TID 169 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,513 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:169 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,514 INFO cluster.ClusterTaskSetManager: Finished TID 158 in 498 ms on ip-10-43-129-89.ec2.internal (progress: 153/216) | |
13/12/09 15:47:09,514 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 158) | |
13/12/09 15:47:09,522 INFO cluster.ClusterTaskSetManager: Starting task 1.0:170 as TID 170 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,523 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:170 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,524 INFO cluster.ClusterTaskSetManager: Finished TID 155 in 597 ms on ip-10-181-0-146.ec2.internal (progress: 154/216) | |
13/12/09 15:47:09,524 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 155) | |
13/12/09 15:47:09,556 INFO cluster.ClusterTaskSetManager: Starting task 1.0:171 as TID 171 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,557 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:171 as 2083 bytes in 1 ms | |
13/12/09 15:47:09,557 INFO cluster.ClusterTaskSetManager: Finished TID 149 in 938 ms on ip-10-43-129-89.ec2.internal (progress: 155/216) | |
13/12/09 15:47:09,558 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 149) | |
13/12/09 15:47:09,573 INFO cluster.ClusterTaskSetManager: Starting task 1.0:172 as TID 172 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,574 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:172 as 2083 bytes in 1 ms | |
13/12/09 15:47:09,574 INFO cluster.ClusterTaskSetManager: Finished TID 157 in 578 ms on ip-10-43-129-89.ec2.internal (progress: 156/216) | |
13/12/09 15:47:09,575 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 157) | |
13/12/09 15:47:09,670 INFO cluster.ClusterTaskSetManager: Starting task 1.0:173 as TID 173 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,671 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:173 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,671 INFO cluster.ClusterTaskSetManager: Finished TID 152 in 792 ms on ip-10-43-129-89.ec2.internal (progress: 157/216) | |
13/12/09 15:47:09,671 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 152) | |
13/12/09 15:47:09,685 INFO cluster.ClusterTaskSetManager: Starting task 1.0:174 as TID 174 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,685 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:174 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,686 INFO cluster.ClusterTaskSetManager: Finished TID 151 in 861 ms on ip-10-181-0-146.ec2.internal (progress: 158/216) | |
13/12/09 15:47:09,686 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 151) | |
13/12/09 15:47:09,897 INFO cluster.ClusterTaskSetManager: Starting task 1.0:175 as TID 175 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,897 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:175 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,898 INFO cluster.ClusterTaskSetManager: Finished TID 159 in 866 ms on ip-10-181-0-146.ec2.internal (progress: 159/216) | |
13/12/09 15:47:09,898 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 159) | |
13/12/09 15:47:09,906 INFO cluster.ClusterTaskSetManager: Starting task 1.0:176 as TID 176 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,907 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:176 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,907 INFO cluster.ClusterTaskSetManager: Finished TID 161 in 792 ms on ip-10-181-0-146.ec2.internal (progress: 160/216) | |
13/12/09 15:47:09,908 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 161) | |
13/12/09 15:47:09,986 INFO cluster.ClusterTaskSetManager: Starting task 1.0:177 as TID 177 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:09,986 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:177 as 2083 bytes in 0 ms | |
13/12/09 15:47:09,987 INFO cluster.ClusterTaskSetManager: Finished TID 165 in 538 ms on ip-10-181-0-146.ec2.internal (progress: 161/216) | |
13/12/09 15:47:09,987 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 165) | |
13/12/09 15:47:10,007 INFO cluster.ClusterTaskSetManager: Starting task 1.0:178 as TID 178 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,007 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:178 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,008 INFO cluster.ClusterTaskSetManager: Finished TID 166 in 533 ms on ip-10-43-129-89.ec2.internal (progress: 162/216) | |
13/12/09 15:47:10,008 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 166) | |
13/12/09 15:47:10,040 INFO cluster.ClusterTaskSetManager: Finished TID 160 in 978 ms on ip-10-181-0-146.ec2.internal (progress: 163/216) | |
13/12/09 15:47:10,040 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 160) | |
13/12/09 15:47:10,041 INFO cluster.ClusterTaskSetManager: Starting task 1.0:179 as TID 179 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,041 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:179 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,042 INFO cluster.ClusterTaskSetManager: Finished TID 169 in 530 ms on ip-10-43-129-89.ec2.internal (progress: 164/216) | |
13/12/09 15:47:10,043 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 169) | |
13/12/09 15:47:10,043 INFO cluster.ClusterTaskSetManager: Starting task 1.0:180 as TID 180 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,043 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:180 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,044 INFO cluster.ClusterTaskSetManager: Starting task 1.0:181 as TID 181 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,045 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:181 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,045 INFO cluster.ClusterTaskSetManager: Finished TID 162 in 874 ms on ip-10-43-129-89.ec2.internal (progress: 165/216) | |
13/12/09 15:47:10,046 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 162) | |
13/12/09 15:47:10,046 INFO cluster.ClusterTaskSetManager: Starting task 1.0:182 as TID 182 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,046 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:182 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,047 INFO cluster.ClusterTaskSetManager: Finished TID 168 in 540 ms on ip-10-181-0-146.ec2.internal (progress: 166/216) | |
13/12/09 15:47:10,047 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 168) | |
13/12/09 15:47:10,065 INFO cluster.ClusterTaskSetManager: Starting task 1.0:183 as TID 183 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,065 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:183 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,066 INFO cluster.ClusterTaskSetManager: Finished TID 167 in 572 ms on ip-10-43-129-89.ec2.internal (progress: 167/216) | |
13/12/09 15:47:10,066 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 167) | |
13/12/09 15:47:10,093 INFO cluster.ClusterTaskSetManager: Finished TID 170 in 571 ms on ip-10-181-0-146.ec2.internal (progress: 168/216) | |
13/12/09 15:47:10,093 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 170) | |
13/12/09 15:47:10,093 INFO cluster.ClusterTaskSetManager: Starting task 1.0:184 as TID 184 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,094 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:184 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,150 INFO cluster.ClusterTaskSetManager: Starting task 1.0:185 as TID 185 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,151 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:185 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,151 INFO cluster.ClusterTaskSetManager: Finished TID 164 in 743 ms on ip-10-181-0-146.ec2.internal (progress: 169/216) | |
13/12/09 15:47:10,151 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 164) | |
13/12/09 15:47:10,241 INFO cluster.ClusterTaskSetManager: Starting task 1.0:186 as TID 186 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,242 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:186 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,243 INFO cluster.ClusterTaskSetManager: Finished TID 163 in 848 ms on ip-10-43-129-89.ec2.internal (progress: 170/216) | |
13/12/09 15:47:10,243 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 163) | |
13/12/09 15:47:10,329 INFO cluster.ClusterTaskSetManager: Starting task 1.0:187 as TID 187 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,329 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:187 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,330 INFO cluster.ClusterTaskSetManager: Finished TID 172 in 757 ms on ip-10-43-129-89.ec2.internal (progress: 171/216) | |
13/12/09 15:47:10,330 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 172) | |
13/12/09 15:47:10,398 INFO cluster.ClusterTaskSetManager: Starting task 1.0:188 as TID 188 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,399 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:188 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,399 INFO cluster.ClusterTaskSetManager: Finished TID 171 in 843 ms on ip-10-43-129-89.ec2.internal (progress: 172/216) | |
13/12/09 15:47:10,399 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 171) | |
13/12/09 15:47:10,488 INFO cluster.ClusterTaskSetManager: Starting task 1.0:189 as TID 189 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,488 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:189 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,489 INFO cluster.ClusterTaskSetManager: Finished TID 174 in 804 ms on ip-10-181-0-146.ec2.internal (progress: 173/216) | |
13/12/09 15:47:10,489 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 174) | |
13/12/09 15:47:10,489 INFO cluster.ClusterTaskSetManager: Starting task 1.0:190 as TID 190 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,490 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:190 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,490 INFO cluster.ClusterTaskSetManager: Finished TID 177 in 504 ms on ip-10-181-0-146.ec2.internal (progress: 174/216) | |
13/12/09 15:47:10,490 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 177) | |
13/12/09 15:47:10,497 INFO cluster.ClusterTaskSetManager: Starting task 1.0:191 as TID 191 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,498 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:191 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,498 INFO cluster.ClusterTaskSetManager: Finished TID 173 in 828 ms on ip-10-43-129-89.ec2.internal (progress: 175/216) | |
13/12/09 15:47:10,499 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 173) | |
13/12/09 15:47:10,499 INFO cluster.ClusterTaskSetManager: Finished TID 178 in 492 ms on ip-10-43-129-89.ec2.internal (progress: 176/216) | |
13/12/09 15:47:10,500 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 178) | |
13/12/09 15:47:10,500 INFO cluster.ClusterTaskSetManager: Starting task 1.0:192 as TID 192 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,501 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:192 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,534 INFO cluster.ClusterTaskSetManager: Starting task 1.0:193 as TID 193 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,534 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:193 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,535 INFO cluster.ClusterTaskSetManager: Finished TID 182 in 489 ms on ip-10-181-0-146.ec2.internal (progress: 177/216) | |
13/12/09 15:47:10,535 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 182) | |
13/12/09 15:47:10,583 INFO cluster.ClusterTaskSetManager: Starting task 1.0:194 as TID 194 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,584 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:194 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,584 INFO cluster.ClusterTaskSetManager: Finished TID 180 in 541 ms on ip-10-43-129-89.ec2.internal (progress: 178/216) | |
13/12/09 15:47:10,585 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 180) | |
13/12/09 15:47:10,589 INFO cluster.ClusterTaskSetManager: Starting task 1.0:195 as TID 195 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,589 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:195 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,590 INFO cluster.ClusterTaskSetManager: Finished TID 179 in 550 ms on ip-10-181-0-146.ec2.internal (progress: 179/216) | |
13/12/09 15:47:10,590 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 179) | |
13/12/09 15:47:10,609 INFO cluster.ClusterTaskSetManager: Finished TID 181 in 565 ms on ip-10-43-129-89.ec2.internal (progress: 180/216) | |
13/12/09 15:47:10,609 INFO cluster.ClusterTaskSetManager: Starting task 1.0:196 as TID 196 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,610 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:196 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,611 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 181) | |
13/12/09 15:47:10,664 INFO cluster.ClusterTaskSetManager: Starting task 1.0:197 as TID 197 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,665 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:197 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,666 INFO cluster.ClusterTaskSetManager: Finished TID 175 in 769 ms on ip-10-181-0-146.ec2.internal (progress: 181/216) | |
13/12/09 15:47:10,666 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 175) | |
13/12/09 15:47:10,679 INFO cluster.ClusterTaskSetManager: Starting task 1.0:198 as TID 198 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,680 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:198 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,681 INFO cluster.ClusterTaskSetManager: Finished TID 176 in 775 ms on ip-10-181-0-146.ec2.internal (progress: 182/216) | |
13/12/09 15:47:10,681 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 176) | |
13/12/09 15:47:10,884 INFO cluster.ClusterTaskSetManager: Starting task 1.0:199 as TID 199 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,885 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:199 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,885 INFO cluster.ClusterTaskSetManager: Finished TID 183 in 820 ms on ip-10-43-129-89.ec2.internal (progress: 183/216) | |
13/12/09 15:47:10,886 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 183) | |
13/12/09 15:47:10,921 INFO cluster.ClusterTaskSetManager: Starting task 1.0:200 as TID 200 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,921 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:200 as 2083 bytes in 0 ms | |
13/12/09 15:47:10,922 INFO cluster.ClusterTaskSetManager: Finished TID 184 in 829 ms on ip-10-181-0-146.ec2.internal (progress: 184/216) | |
13/12/09 15:47:10,922 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 184) | |
13/12/09 15:47:10,979 INFO cluster.ClusterTaskSetManager: Starting task 1.0:201 as TID 201 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,980 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:201 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,980 INFO cluster.ClusterTaskSetManager: Finished TID 189 in 493 ms on ip-10-181-0-146.ec2.internal (progress: 185/216) | |
13/12/09 15:47:10,981 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 189) | |
13/12/09 15:47:10,988 INFO cluster.ClusterTaskSetManager: Starting task 1.0:202 as TID 202 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:10,989 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:202 as 2083 bytes in 1 ms | |
13/12/09 15:47:10,989 INFO cluster.ClusterTaskSetManager: Finished TID 191 in 492 ms on ip-10-43-129-89.ec2.internal (progress: 186/216) | |
13/12/09 15:47:10,990 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 191) | |
13/12/09 15:47:11,000 INFO cluster.ClusterTaskSetManager: Starting task 1.0:203 as TID 203 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,000 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:203 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,001 INFO cluster.ClusterTaskSetManager: Finished TID 186 in 760 ms on ip-10-43-129-89.ec2.internal (progress: 187/216) | |
13/12/09 15:47:11,001 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 186) | |
13/12/09 15:47:11,002 INFO cluster.ClusterTaskSetManager: Finished TID 190 in 513 ms on ip-10-181-0-146.ec2.internal (progress: 188/216) | |
13/12/09 15:47:11,002 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 190) | |
13/12/09 15:47:11,002 INFO cluster.ClusterTaskSetManager: Starting task 1.0:204 as TID 204 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,003 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:204 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,008 INFO cluster.ClusterTaskSetManager: Starting task 1.0:205 as TID 205 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,008 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:205 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,009 INFO cluster.ClusterTaskSetManager: Finished TID 192 in 509 ms on ip-10-43-129-89.ec2.internal (progress: 189/216) | |
13/12/09 15:47:11,010 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 192) | |
13/12/09 15:47:11,016 INFO cluster.ClusterTaskSetManager: Starting task 1.0:206 as TID 206 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,016 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:206 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,017 INFO cluster.ClusterTaskSetManager: Finished TID 185 in 867 ms on ip-10-181-0-146.ec2.internal (progress: 190/216) | |
13/12/09 15:47:11,017 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 185) | |
13/12/09 15:47:11,064 INFO cluster.ClusterTaskSetManager: Starting task 1.0:207 as TID 207 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,065 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:207 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,066 INFO cluster.ClusterTaskSetManager: Finished TID 194 in 482 ms on ip-10-43-129-89.ec2.internal (progress: 191/216) | |
13/12/09 15:47:11,066 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 194) | |
13/12/09 15:47:11,142 INFO cluster.ClusterTaskSetManager: Starting task 1.0:208 as TID 208 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,142 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:208 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,143 INFO cluster.ClusterTaskSetManager: Finished TID 187 in 814 ms on ip-10-43-129-89.ec2.internal (progress: 192/216) | |
13/12/09 15:47:11,143 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 187) | |
13/12/09 15:47:11,157 INFO cluster.ClusterTaskSetManager: Starting task 1.0:209 as TID 209 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,157 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:209 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,158 INFO cluster.ClusterTaskSetManager: Finished TID 193 in 625 ms on ip-10-181-0-146.ec2.internal (progress: 193/216) | |
13/12/09 15:47:11,158 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 193) | |
13/12/09 15:47:11,242 INFO cluster.ClusterTaskSetManager: Starting task 1.0:210 as TID 210 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,242 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:210 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,243 INFO cluster.ClusterTaskSetManager: Finished TID 188 in 845 ms on ip-10-43-129-89.ec2.internal (progress: 194/216) | |
13/12/09 15:47:11,243 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 188) | |
13/12/09 15:47:11,391 INFO cluster.ClusterTaskSetManager: Starting task 1.0:211 as TID 211 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,392 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:211 as 2083 bytes in 1 ms | |
13/12/09 15:47:11,392 INFO cluster.ClusterTaskSetManager: Finished TID 196 in 783 ms on ip-10-43-129-89.ec2.internal (progress: 195/216) | |
13/12/09 15:47:11,393 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 196) | |
13/12/09 15:47:11,475 INFO cluster.ClusterTaskSetManager: Starting task 1.0:212 as TID 212 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,476 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:212 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,477 INFO cluster.ClusterTaskSetManager: Finished TID 202 in 489 ms on ip-10-43-129-89.ec2.internal (progress: 196/216) | |
13/12/09 15:47:11,477 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 202) | |
13/12/09 15:47:11,479 INFO cluster.ClusterTaskSetManager: Finished TID 195 in 890 ms on ip-10-181-0-146.ec2.internal (progress: 197/216) | |
13/12/09 15:47:11,479 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 195) | |
13/12/09 15:47:11,479 INFO cluster.ClusterTaskSetManager: Starting task 1.0:213 as TID 213 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,480 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:213 as 2083 bytes in 0 ms | |
13/12/09 15:47:11,485 INFO cluster.ClusterTaskSetManager: Starting task 1.0:214 as TID 214 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,486 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:214 as 2083 bytes in 1 ms | |
13/12/09 15:47:11,486 INFO cluster.ClusterTaskSetManager: Finished TID 201 in 507 ms on ip-10-181-0-146.ec2.internal (progress: 198/216) | |
13/12/09 15:47:11,487 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 201) | |
13/12/09 15:47:11,500 INFO cluster.ClusterTaskSetManager: Starting task 1.0:215 as TID 215 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:11,501 INFO cluster.ClusterTaskSetManager: Serialized task 1.0:215 as 2083 bytes in 1 ms | |
13/12/09 15:47:11,501 INFO cluster.ClusterTaskSetManager: Finished TID 197 in 837 ms on ip-10-181-0-146.ec2.internal (progress: 199/216) | |
13/12/09 15:47:11,502 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 197) | |
13/12/09 15:47:11,512 INFO cluster.ClusterTaskSetManager: Finished TID 206 in 496 ms on ip-10-181-0-146.ec2.internal (progress: 200/216) | |
13/12/09 15:47:11,512 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 206) | |
13/12/09 15:47:11,528 INFO cluster.ClusterTaskSetManager: Finished TID 205 in 520 ms on ip-10-43-129-89.ec2.internal (progress: 201/216) | |
13/12/09 15:47:11,529 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 205) | |
13/12/09 15:47:11,539 INFO cluster.ClusterTaskSetManager: Finished TID 203 in 540 ms on ip-10-43-129-89.ec2.internal (progress: 202/216) | |
13/12/09 15:47:11,539 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 203) | |
13/12/09 15:47:11,547 INFO cluster.ClusterTaskSetManager: Finished TID 204 in 545 ms on ip-10-181-0-146.ec2.internal (progress: 203/216) | |
13/12/09 15:47:11,548 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 204) | |
13/12/09 15:47:11,551 INFO cluster.ClusterTaskSetManager: Finished TID 198 in 872 ms on ip-10-181-0-146.ec2.internal (progress: 204/216) | |
13/12/09 15:47:11,551 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 198) | |
13/12/09 15:47:11,596 INFO cluster.ClusterTaskSetManager: Finished TID 199 in 712 ms on ip-10-43-129-89.ec2.internal (progress: 205/216) | |
13/12/09 15:47:11,597 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 199) | |
13/12/09 15:47:11,724 INFO cluster.ClusterTaskSetManager: Finished TID 200 in 803 ms on ip-10-181-0-146.ec2.internal (progress: 206/216) | |
13/12/09 15:47:11,724 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 200) | |
13/12/09 15:47:11,844 INFO cluster.ClusterTaskSetManager: Finished TID 207 in 780 ms on ip-10-43-129-89.ec2.internal (progress: 207/216) | |
13/12/09 15:47:11,845 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 207) | |
13/12/09 15:47:11,847 INFO cluster.ClusterTaskSetManager: Finished TID 208 in 706 ms on ip-10-43-129-89.ec2.internal (progress: 208/216) | |
13/12/09 15:47:11,847 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 208) | |
13/12/09 15:47:11,955 INFO cluster.ClusterTaskSetManager: Finished TID 209 in 798 ms on ip-10-181-0-146.ec2.internal (progress: 209/216) | |
13/12/09 15:47:11,955 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 209) | |
13/12/09 15:47:11,960 INFO cluster.ClusterTaskSetManager: Finished TID 214 in 475 ms on ip-10-181-0-146.ec2.internal (progress: 210/216) | |
13/12/09 15:47:11,961 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 214) | |
13/12/09 15:47:11,966 INFO cluster.ClusterTaskSetManager: Finished TID 215 in 465 ms on ip-10-181-0-146.ec2.internal (progress: 211/216) | |
13/12/09 15:47:11,966 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 215) | |
13/12/09 15:47:12,042 INFO cluster.ClusterTaskSetManager: Finished TID 210 in 800 ms on ip-10-43-129-89.ec2.internal (progress: 212/216) | |
13/12/09 15:47:12,043 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 210) | |
13/12/09 15:47:12,068 INFO cluster.ClusterTaskSetManager: Finished TID 213 in 589 ms on ip-10-181-0-146.ec2.internal (progress: 213/216) | |
13/12/09 15:47:12,069 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 213) | |
13/12/09 15:47:12,115 INFO cluster.ClusterTaskSetManager: Finished TID 211 in 724 ms on ip-10-43-129-89.ec2.internal (progress: 214/216) | |
13/12/09 15:47:12,116 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 211) | |
13/12/09 15:47:12,358 INFO cluster.ClusterTaskSetManager: Finished TID 212 in 883 ms on ip-10-43-129-89.ec2.internal (progress: 215/216) | |
13/12/09 15:47:12,359 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 212) | |
13/12/09 15:47:12,360 INFO cluster.ClusterScheduler: Remove TaskSet 1.0 from pool | |
13/12/09 15:47:12,361 INFO scheduler.DAGScheduler: Stage 1 (keyBy at LogAnalyzer.scala:35) finished in 15.608 s | |
13/12/09 15:47:12,361 INFO scheduler.DAGScheduler: looking for newly runnable stages | |
13/12/09 15:47:12,362 INFO scheduler.DAGScheduler: running: Set() | |
13/12/09 15:47:12,363 INFO scheduler.DAGScheduler: waiting: Set(Stage 0) | |
13/12/09 15:47:12,364 INFO scheduler.DAGScheduler: failed: Set() | |
13/12/09 15:47:12,377 INFO scheduler.DAGScheduler: Missing parents for Stage 0: List() | |
13/12/09 15:47:12,381 INFO scheduler.DAGScheduler: Submitting Stage 0 (MapPartitionsRDD[7] at mapPartitionsWithIndex at Vertica.scala:143), which is now runnable | |
13/12/09 15:47:12,474 INFO scheduler.DAGScheduler: Submitting 64 missing tasks from Stage 0 (MapPartitionsRDD[7] at mapPartitionsWithIndex at Vertica.scala:143) | |
13/12/09 15:47:12,475 INFO cluster.ClusterScheduler: Adding task set 0.0 with 64 tasks | |
13/12/09 15:47:12,477 INFO cluster.ClusterTaskSetManager: Starting task 0.0:0 as TID 216 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,477 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:0 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,478 INFO cluster.ClusterTaskSetManager: Starting task 0.0:1 as TID 217 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,478 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:1 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,479 INFO cluster.ClusterTaskSetManager: Starting task 0.0:2 as TID 218 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,479 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:2 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,479 INFO cluster.ClusterTaskSetManager: Starting task 0.0:3 as TID 219 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,480 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:3 as 8080 bytes in 1 ms | |
13/12/09 15:47:12,480 INFO cluster.ClusterTaskSetManager: Starting task 0.0:4 as TID 220 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,480 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:4 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,481 INFO cluster.ClusterTaskSetManager: Starting task 0.0:5 as TID 221 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,481 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:5 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,482 INFO cluster.ClusterTaskSetManager: Starting task 0.0:6 as TID 222 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,482 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:6 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,482 INFO cluster.ClusterTaskSetManager: Starting task 0.0:7 as TID 223 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,483 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:7 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,483 INFO cluster.ClusterTaskSetManager: Starting task 0.0:8 as TID 224 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,484 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:8 as 8080 bytes in 1 ms | |
13/12/09 15:47:12,484 INFO cluster.ClusterTaskSetManager: Starting task 0.0:9 as TID 225 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,485 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:9 as 8080 bytes in 1 ms | |
13/12/09 15:47:12,485 INFO cluster.ClusterTaskSetManager: Starting task 0.0:10 as TID 226 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,485 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:10 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,486 INFO cluster.ClusterTaskSetManager: Starting task 0.0:11 as TID 227 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,486 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:11 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,487 INFO cluster.ClusterTaskSetManager: Starting task 0.0:12 as TID 228 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,487 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:12 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,487 INFO cluster.ClusterTaskSetManager: Starting task 0.0:13 as TID 229 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,488 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:13 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,489 INFO cluster.ClusterTaskSetManager: Starting task 0.0:14 as TID 230 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,489 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:14 as 8080 bytes in 0 ms | |
13/12/09 15:47:12,490 INFO cluster.ClusterTaskSetManager: Starting task 0.0:15 as TID 231 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:47:12,490 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:15 as 8080 bytes in 0 ms | |
13/12/09 15:47:13,960 INFO spark.MapOutputTrackerMasterActor: Asked to send map output locations for shuffle 0 to ip-10-43-129-89.ec2.internal:59327 | |
13/12/09 15:47:13,974 INFO spark.MapOutputTrackerMaster: Size of output statuses for shuffle 0 is 6266 bytes | |
13/12/09 15:47:14,181 INFO spark.MapOutputTrackerMasterActor: Asked to send map output locations for shuffle 0 to ip-10-181-0-146.ec2.internal:47339 | |
13/12/09 15:48:18,164 INFO cluster.ClusterTaskSetManager: Starting task 0.0:16 as TID 232 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:18,164 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:16 as 8080 bytes in 0 ms | |
13/12/09 15:48:18,167 INFO cluster.ClusterTaskSetManager: Finished TID 218 in 65689 ms on ip-10-43-129-89.ec2.internal (progress: 0/64) | |
13/12/09 15:48:18,167 INFO scheduler.DAGScheduler: Completed ResultTask(0, 2) | |
13/12/09 15:48:19,147 INFO cluster.ClusterTaskSetManager: Starting task 0.0:17 as TID 233 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:19,148 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:17 as 8080 bytes in 0 ms | |
13/12/09 15:48:19,149 INFO cluster.ClusterTaskSetManager: Finished TID 230 in 66660 ms on ip-10-43-129-89.ec2.internal (progress: 1/64) | |
13/12/09 15:48:19,149 INFO scheduler.DAGScheduler: Completed ResultTask(0, 14) | |
13/12/09 15:48:19,367 INFO cluster.ClusterTaskSetManager: Starting task 0.0:18 as TID 234 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:19,368 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:18 as 8080 bytes in 1 ms | |
13/12/09 15:48:19,368 INFO cluster.ClusterTaskSetManager: Finished TID 216 in 66891 ms on ip-10-43-129-89.ec2.internal (progress: 2/64) | |
13/12/09 15:48:19,368 INFO scheduler.DAGScheduler: Completed ResultTask(0, 0) | |
13/12/09 15:48:19,398 INFO cluster.ClusterTaskSetManager: Starting task 0.0:19 as TID 235 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:19,398 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:19 as 8080 bytes in 0 ms | |
13/12/09 15:48:19,399 INFO cluster.ClusterTaskSetManager: Finished TID 226 in 66914 ms on ip-10-43-129-89.ec2.internal (progress: 3/64) | |
13/12/09 15:48:19,399 INFO scheduler.DAGScheduler: Completed ResultTask(0, 10) | |
13/12/09 15:48:19,736 INFO cluster.ClusterTaskSetManager: Starting task 0.0:20 as TID 236 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:19,736 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:20 as 8080 bytes in 0 ms | |
13/12/09 15:48:19,737 INFO cluster.ClusterTaskSetManager: Finished TID 228 in 67251 ms on ip-10-43-129-89.ec2.internal (progress: 4/64) | |
13/12/09 15:48:19,737 INFO scheduler.DAGScheduler: Completed ResultTask(0, 12) | |
13/12/09 15:48:19,847 INFO cluster.ClusterTaskSetManager: Finished TID 220 in 67367 ms on ip-10-43-129-89.ec2.internal (progress: 5/64) | |
13/12/09 15:48:19,847 INFO scheduler.DAGScheduler: Completed ResultTask(0, 4) | |
13/12/09 15:48:19,847 INFO cluster.ClusterTaskSetManager: Starting task 0.0:21 as TID 237 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:19,848 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:21 as 8080 bytes in 1 ms | |
13/12/09 15:48:19,953 INFO cluster.ClusterTaskSetManager: Finished TID 224 in 67470 ms on ip-10-43-129-89.ec2.internal (progress: 6/64) | |
13/12/09 15:48:19,953 INFO scheduler.DAGScheduler: Completed ResultTask(0, 8) | |
13/12/09 15:48:19,954 INFO cluster.ClusterTaskSetManager: Starting task 0.0:22 as TID 238 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:19,954 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:22 as 8080 bytes in 0 ms | |
13/12/09 15:48:20,213 INFO cluster.ClusterTaskSetManager: Starting task 0.0:23 as TID 239 on executor 0: ip-10-43-129-89.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:20,213 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:23 as 8080 bytes in 0 ms | |
13/12/09 15:48:20,214 INFO cluster.ClusterTaskSetManager: Finished TID 222 in 67733 ms on ip-10-43-129-89.ec2.internal (progress: 7/64) | |
13/12/09 15:48:20,214 INFO scheduler.DAGScheduler: Completed ResultTask(0, 6) | |
13/12/09 15:48:21,141 INFO cluster.ClusterTaskSetManager: Starting task 0.0:24 as TID 240 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:21,142 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:24 as 8080 bytes in 0 ms | |
13/12/09 15:48:21,142 INFO cluster.ClusterTaskSetManager: Finished TID 227 in 68656 ms on ip-10-181-0-146.ec2.internal (progress: 8/64) | |
13/12/09 15:48:21,142 INFO scheduler.DAGScheduler: Completed ResultTask(0, 11) | |
13/12/09 15:48:21,380 INFO cluster.ClusterTaskSetManager: Starting task 0.0:25 as TID 241 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:21,380 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:25 as 8080 bytes in 0 ms | |
13/12/09 15:48:21,381 INFO cluster.ClusterTaskSetManager: Finished TID 217 in 68902 ms on ip-10-181-0-146.ec2.internal (progress: 9/64) | |
13/12/09 15:48:21,381 INFO scheduler.DAGScheduler: Completed ResultTask(0, 1) | |
13/12/09 15:48:22,127 INFO cluster.ClusterTaskSetManager: Starting task 0.0:26 as TID 242 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:22,128 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:26 as 8080 bytes in 1 ms | |
13/12/09 15:48:22,128 INFO cluster.ClusterTaskSetManager: Finished TID 225 in 69644 ms on ip-10-181-0-146.ec2.internal (progress: 10/64) | |
13/12/09 15:48:22,128 INFO scheduler.DAGScheduler: Completed ResultTask(0, 9) | |
13/12/09 15:48:22,705 INFO cluster.ClusterTaskSetManager: Starting task 0.0:27 as TID 243 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:22,706 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:27 as 8080 bytes in 0 ms | |
13/12/09 15:48:22,706 INFO cluster.ClusterTaskSetManager: Finished TID 231 in 70216 ms on ip-10-181-0-146.ec2.internal (progress: 11/64) | |
13/12/09 15:48:22,707 INFO scheduler.DAGScheduler: Completed ResultTask(0, 15) | |
13/12/09 15:48:22,798 INFO cluster.ClusterTaskSetManager: Starting task 0.0:28 as TID 244 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:22,798 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:28 as 8080 bytes in 0 ms | |
13/12/09 15:48:22,799 INFO cluster.ClusterTaskSetManager: Finished TID 229 in 70312 ms on ip-10-181-0-146.ec2.internal (progress: 12/64) | |
13/12/09 15:48:22,799 INFO scheduler.DAGScheduler: Completed ResultTask(0, 13) | |
13/12/09 15:48:22,920 INFO cluster.ClusterTaskSetManager: Starting task 0.0:29 as TID 245 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:22,920 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:29 as 8080 bytes in 0 ms | |
13/12/09 15:48:22,921 INFO cluster.ClusterTaskSetManager: Finished TID 219 in 70442 ms on ip-10-181-0-146.ec2.internal (progress: 13/64) | |
13/12/09 15:48:22,921 INFO scheduler.DAGScheduler: Completed ResultTask(0, 3) | |
13/12/09 15:48:23,040 INFO cluster.ClusterTaskSetManager: Starting task 0.0:30 as TID 246 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:23,040 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:30 as 8080 bytes in 0 ms | |
13/12/09 15:48:23,041 INFO cluster.ClusterTaskSetManager: Finished TID 221 in 70560 ms on ip-10-181-0-146.ec2.internal (progress: 14/64) | |
13/12/09 15:48:23,041 INFO scheduler.DAGScheduler: Completed ResultTask(0, 5) | |
13/12/09 15:48:23,438 INFO cluster.ClusterTaskSetManager: Starting task 0.0:31 as TID 247 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:48:23,439 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:31 as 8080 bytes in 1 ms | |
13/12/09 15:48:23,439 INFO cluster.ClusterTaskSetManager: Finished TID 223 in 70957 ms on ip-10-181-0-146.ec2.internal (progress: 15/64) | |
13/12/09 15:48:23,440 INFO scheduler.DAGScheduler: Completed ResultTask(0, 7) | |
13/12/09 15:48:44,903 INFO client.Client$ClientActor: Executor updated: app-20131209154538-0001/0 is now LOST (worker lost) | |
13/12/09 15:48:44,904 INFO cluster.SparkDeploySchedulerBackend: Executor app-20131209154538-0001/0 removed: worker lost | |
13/12/09 15:48:44,906 INFO cluster.SparkDeploySchedulerBackend: Executor 0 disconnected, so removing it | |
13/12/09 15:48:44,908 INFO cluster.ClusterTaskSetManager: Re-queueing tasks for 0 from TaskSet 0.0 | |
13/12/09 15:48:44,915 INFO scheduler.DAGScheduler: Executor lost: 0 (epoch 1) | |
13/12/09 15:48:44,916 INFO storage.BlockManagerMasterActor: Trying to remove executor 0 from BlockManagerMaster. | |
13/12/09 15:48:44,917 INFO storage.BlockManagerMaster: Removed 0 successfully in removeExecutor | |
13/12/09 15:48:44,928 INFO scheduler.Stage: Stage 1 is now unavailable on executor 0 (108/216, false) | |
13/12/09 15:49:25,092 INFO cluster.ClusterTaskSetManager: Starting task 0.0:20 as TID 248 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:25,092 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:20 as 8080 bytes in 0 ms | |
13/12/09 15:49:25,093 INFO cluster.ClusterTaskSetManager: Finished TID 241 in 63713 ms on ip-10-181-0-146.ec2.internal (progress: 16/64) | |
13/12/09 15:49:25,093 INFO scheduler.DAGScheduler: Completed ResultTask(0, 25) | |
13/12/09 15:49:25,190 INFO cluster.ClusterTaskSetManager: Starting task 0.0:17 as TID 249 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:25,191 INFO cluster.ClusterTaskSetManager: Serialized task 0.0:17 as 8080 bytes in 1 ms | |
13/12/09 15:49:25,193 INFO cluster.ClusterScheduler: Remove TaskSet 0.0 from pool | |
13/12/09 15:49:25,194 INFO scheduler.DAGScheduler: Marking Stage 0 (foreach at Vertica.scala:143) for resubmision due to a fetch failure | |
13/12/09 15:49:25,197 INFO scheduler.DAGScheduler: The failed fetch was from Stage 1 (keyBy at LogAnalyzer.scala:35); marking it for resubmission | |
13/12/09 15:49:25,197 INFO cluster.ClusterScheduler: Ignoring update from TID 249 because its task set is gone | |
13/12/09 15:49:25,277 INFO scheduler.DAGScheduler: Resubmitting failed stages | |
13/12/09 15:49:25,282 INFO cluster.ClusterScheduler: Ignoring update from TID 249 because its task set is gone | |
13/12/09 15:49:25,304 INFO scheduler.DAGScheduler: Submitting Stage 1 (MappedRDD[2] at keyBy at LogAnalyzer.scala:35), which has no missing parents | |
13/12/09 15:49:25,312 INFO scheduler.DAGScheduler: Submitting 108 missing tasks from Stage 1 (MappedRDD[2] at keyBy at LogAnalyzer.scala:35) | |
13/12/09 15:49:25,312 INFO cluster.ClusterScheduler: Adding task set 1.1 with 108 tasks | |
13/12/09 15:49:25,313 INFO cluster.ClusterTaskSetManager: Starting task 1.1:0 as TID 250 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:25,314 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:0 as 2083 bytes in 0 ms | |
13/12/09 15:49:25,384 INFO cluster.ClusterScheduler: Ignoring update from TID 240 because its task set is gone | |
13/12/09 15:49:25,384 INFO cluster.ClusterTaskSetManager: Starting task 1.1:1 as TID 251 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:25,384 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:1 as 2083 bytes in 0 ms | |
13/12/09 15:49:25,939 INFO cluster.ClusterTaskSetManager: Starting task 1.1:2 as TID 252 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:25,940 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:2 as 2083 bytes in 1 ms | |
13/12/09 15:49:25,940 INFO cluster.ClusterTaskSetManager: Finished TID 250 in 627 ms on ip-10-181-0-146.ec2.internal (progress: 0/108) | |
13/12/09 15:49:25,941 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 0) | |
13/12/09 15:49:26,029 INFO cluster.ClusterTaskSetManager: Starting task 1.1:3 as TID 253 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:26,030 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:3 as 2083 bytes in 0 ms | |
13/12/09 15:49:26,030 INFO cluster.ClusterTaskSetManager: Finished TID 251 in 646 ms on ip-10-181-0-146.ec2.internal (progress: 1/108) | |
13/12/09 15:49:26,031 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 2) | |
13/12/09 15:49:26,854 INFO cluster.ClusterTaskSetManager: Starting task 1.1:4 as TID 254 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:26,854 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:4 as 2083 bytes in 0 ms | |
13/12/09 15:49:26,855 INFO cluster.ClusterTaskSetManager: Finished TID 252 in 916 ms on ip-10-181-0-146.ec2.internal (progress: 2/108) | |
13/12/09 15:49:26,855 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 4) | |
13/12/09 15:49:26,927 INFO cluster.ClusterTaskSetManager: Starting task 1.1:5 as TID 255 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:26,928 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:5 as 2083 bytes in 0 ms | |
13/12/09 15:49:26,928 INFO cluster.ClusterTaskSetManager: Finished TID 253 in 899 ms on ip-10-181-0-146.ec2.internal (progress: 3/108) | |
13/12/09 15:49:26,929 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 6) | |
13/12/09 15:49:27,300 INFO cluster.ClusterScheduler: Ignoring update from TID 243 because its task set is gone | |
13/12/09 15:49:27,300 INFO cluster.ClusterTaskSetManager: Starting task 1.1:6 as TID 256 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,301 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:6 as 2083 bytes in 1 ms | |
13/12/09 15:49:27,474 INFO cluster.ClusterTaskSetManager: Starting task 1.1:7 as TID 257 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,475 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:7 as 2083 bytes in 0 ms | |
13/12/09 15:49:27,475 INFO cluster.ClusterTaskSetManager: Finished TID 255 in 548 ms on ip-10-181-0-146.ec2.internal (progress: 4/108) | |
13/12/09 15:49:27,476 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 10) | |
13/12/09 15:49:27,633 INFO cluster.ClusterTaskSetManager: Starting task 1.1:8 as TID 258 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,634 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:8 as 2083 bytes in 0 ms | |
13/12/09 15:49:27,634 INFO cluster.ClusterTaskSetManager: Finished TID 254 in 781 ms on ip-10-181-0-146.ec2.internal (progress: 5/108) | |
13/12/09 15:49:27,635 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 8) | |
13/12/09 15:49:27,778 INFO cluster.ClusterScheduler: Ignoring update from TID 242 because its task set is gone | |
13/12/09 15:49:27,778 INFO cluster.ClusterTaskSetManager: Starting task 1.1:9 as TID 259 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,779 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:9 as 2083 bytes in 1 ms | |
13/12/09 15:49:27,822 INFO cluster.ClusterScheduler: Ignoring update from TID 246 because its task set is gone | |
13/12/09 15:49:27,823 INFO cluster.ClusterTaskSetManager: Starting task 1.1:10 as TID 260 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,823 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:10 as 2083 bytes in 0 ms | |
13/12/09 15:49:27,837 INFO cluster.ClusterTaskSetManager: Finished TID 256 in 537 ms on ip-10-181-0-146.ec2.internal (progress: 6/108) | |
13/12/09 15:49:27,837 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 12) | |
13/12/09 15:49:27,838 INFO cluster.ClusterTaskSetManager: Starting task 1.1:11 as TID 261 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,838 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:11 as 2083 bytes in 0 ms | |
13/12/09 15:49:27,852 INFO cluster.ClusterScheduler: Ignoring update from TID 244 because its task set is gone | |
13/12/09 15:49:27,853 INFO cluster.ClusterTaskSetManager: Starting task 1.1:12 as TID 262 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,853 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:12 as 2083 bytes in 0 ms | |
13/12/09 15:49:27,933 INFO cluster.ClusterScheduler: Ignoring update from TID 245 because its task set is gone | |
13/12/09 15:49:27,933 INFO cluster.ClusterTaskSetManager: Starting task 1.1:13 as TID 263 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:27,934 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:13 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,078 INFO cluster.ClusterTaskSetManager: Starting task 1.1:14 as TID 264 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,079 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:14 as 2083 bytes in 1 ms | |
13/12/09 15:49:28,080 INFO cluster.ClusterTaskSetManager: Finished TID 257 in 605 ms on ip-10-181-0-146.ec2.internal (progress: 7/108) | |
13/12/09 15:49:28,080 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 14) | |
13/12/09 15:49:28,548 INFO cluster.ClusterTaskSetManager: Starting task 1.1:15 as TID 265 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,548 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:15 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,549 INFO cluster.ClusterTaskSetManager: Finished TID 258 in 916 ms on ip-10-181-0-146.ec2.internal (progress: 8/108) | |
13/12/09 15:49:28,549 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 16) | |
13/12/09 15:49:28,619 INFO cluster.ClusterTaskSetManager: Starting task 1.1:16 as TID 266 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,619 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:16 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,620 INFO cluster.ClusterTaskSetManager: Finished TID 264 in 542 ms on ip-10-181-0-146.ec2.internal (progress: 9/108) | |
13/12/09 15:49:28,620 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 26) | |
13/12/09 15:49:28,708 INFO cluster.ClusterTaskSetManager: Starting task 1.1:17 as TID 267 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,708 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:17 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,709 INFO cluster.ClusterTaskSetManager: Finished TID 262 in 857 ms on ip-10-181-0-146.ec2.internal (progress: 10/108) | |
13/12/09 15:49:28,709 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 20) | |
13/12/09 15:49:28,753 INFO cluster.ClusterTaskSetManager: Starting task 1.1:18 as TID 268 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,753 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:18 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,754 INFO cluster.ClusterTaskSetManager: Finished TID 263 in 821 ms on ip-10-181-0-146.ec2.internal (progress: 11/108) | |
13/12/09 15:49:28,754 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 25) | |
13/12/09 15:49:28,805 INFO cluster.ClusterTaskSetManager: Starting task 1.1:19 as TID 269 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,806 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:19 as 2083 bytes in 1 ms | |
13/12/09 15:49:28,806 INFO cluster.ClusterTaskSetManager: Finished TID 260 in 983 ms on ip-10-181-0-146.ec2.internal (progress: 12/108) | |
13/12/09 15:49:28,806 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 18) | |
13/12/09 15:49:28,832 INFO cluster.ClusterTaskSetManager: Starting task 1.1:20 as TID 270 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,832 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:20 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,833 INFO cluster.ClusterTaskSetManager: Finished TID 261 in 996 ms on ip-10-181-0-146.ec2.internal (progress: 13/108) | |
13/12/09 15:49:28,833 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 19) | |
13/12/09 15:49:28,907 INFO cluster.ClusterScheduler: Ignoring update from TID 247 because its task set is gone | |
13/12/09 15:49:28,908 INFO cluster.ClusterTaskSetManager: Starting task 1.1:21 as TID 271 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,908 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:21 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,956 INFO cluster.ClusterTaskSetManager: Starting task 1.1:22 as TID 272 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:28,956 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:22 as 2083 bytes in 0 ms | |
13/12/09 15:49:28,957 INFO cluster.ClusterTaskSetManager: Finished TID 259 in 1179 ms on ip-10-181-0-146.ec2.internal (progress: 14/108) | |
13/12/09 15:49:28,957 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 17) | |
13/12/09 15:49:29,288 INFO cluster.ClusterTaskSetManager: Starting task 1.1:23 as TID 273 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,288 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:23 as 2083 bytes in 0 ms | |
13/12/09 15:49:29,289 INFO cluster.ClusterTaskSetManager: Finished TID 266 in 670 ms on ip-10-181-0-146.ec2.internal (progress: 15/108) | |
13/12/09 15:49:29,289 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 36) | |
13/12/09 15:49:29,294 INFO cluster.ClusterTaskSetManager: Starting task 1.1:24 as TID 274 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,295 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:24 as 2083 bytes in 1 ms | |
13/12/09 15:49:29,295 INFO cluster.ClusterTaskSetManager: Finished TID 267 in 587 ms on ip-10-181-0-146.ec2.internal (progress: 16/108) | |
13/12/09 15:49:29,295 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 37) | |
13/12/09 15:49:29,445 INFO cluster.ClusterTaskSetManager: Finished TID 268 in 691 ms on ip-10-181-0-146.ec2.internal (progress: 17/108) | |
13/12/09 15:49:29,445 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 38) | |
13/12/09 15:49:29,445 INFO cluster.ClusterTaskSetManager: Starting task 1.1:25 as TID 275 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,445 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:25 as 2083 bytes in 0 ms | |
13/12/09 15:49:29,607 INFO cluster.ClusterTaskSetManager: Finished TID 265 in 1059 ms on ip-10-181-0-146.ec2.internal (progress: 18/108) | |
13/12/09 15:49:29,608 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 27) | |
13/12/09 15:49:29,608 INFO cluster.ClusterTaskSetManager: Starting task 1.1:26 as TID 276 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,608 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:26 as 2083 bytes in 0 ms | |
13/12/09 15:49:29,923 INFO cluster.ClusterTaskSetManager: Starting task 1.1:27 as TID 277 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,923 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:27 as 2083 bytes in 0 ms | |
13/12/09 15:49:29,924 INFO cluster.ClusterTaskSetManager: Finished TID 274 in 630 ms on ip-10-181-0-146.ec2.internal (progress: 19/108) | |
13/12/09 15:49:29,924 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 49) | |
13/12/09 15:49:29,961 INFO cluster.ClusterTaskSetManager: Starting task 1.1:28 as TID 278 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,961 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:28 as 2083 bytes in 0 ms | |
13/12/09 15:49:29,961 INFO cluster.ClusterTaskSetManager: Finished TID 269 in 1156 ms on ip-10-181-0-146.ec2.internal (progress: 20/108) | |
13/12/09 15:49:29,962 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 39) | |
13/12/09 15:49:29,967 INFO cluster.ClusterTaskSetManager: Finished TID 273 in 679 ms on ip-10-181-0-146.ec2.internal (progress: 21/108) | |
13/12/09 15:49:29,967 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 45) | |
13/12/09 15:49:29,967 INFO cluster.ClusterTaskSetManager: Starting task 1.1:29 as TID 279 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:29,968 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:29 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,002 INFO cluster.ClusterTaskSetManager: Finished TID 270 in 1170 ms on ip-10-181-0-146.ec2.internal (progress: 22/108) | |
13/12/09 15:49:30,003 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 40) | |
13/12/09 15:49:30,003 INFO cluster.ClusterTaskSetManager: Starting task 1.1:30 as TID 280 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,003 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:30 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,053 INFO cluster.ClusterTaskSetManager: Starting task 1.1:31 as TID 281 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,054 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:31 as 2083 bytes in 1 ms | |
13/12/09 15:49:30,054 INFO cluster.ClusterTaskSetManager: Finished TID 272 in 1098 ms on ip-10-181-0-146.ec2.internal (progress: 23/108) | |
13/12/09 15:49:30,055 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 42) | |
13/12/09 15:49:30,058 INFO cluster.ClusterTaskSetManager: Starting task 1.1:32 as TID 282 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,058 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:32 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,059 INFO cluster.ClusterTaskSetManager: Finished TID 271 in 1151 ms on ip-10-181-0-146.ec2.internal (progress: 24/108) | |
13/12/09 15:49:30,059 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 41) | |
13/12/09 15:49:30,476 INFO cluster.ClusterTaskSetManager: Starting task 1.1:33 as TID 283 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,477 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:33 as 2083 bytes in 1 ms | |
13/12/09 15:49:30,477 INFO cluster.ClusterTaskSetManager: Finished TID 275 in 1032 ms on ip-10-181-0-146.ec2.internal (progress: 25/108) | |
13/12/09 15:49:30,478 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 51) | |
13/12/09 15:49:30,559 INFO cluster.ClusterTaskSetManager: Starting task 1.1:34 as TID 284 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,560 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:34 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,560 INFO cluster.ClusterTaskSetManager: Finished TID 278 in 600 ms on ip-10-181-0-146.ec2.internal (progress: 26/108) | |
13/12/09 15:49:30,561 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 59) | |
13/12/09 15:49:30,586 INFO cluster.ClusterTaskSetManager: Starting task 1.1:35 as TID 285 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,587 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:35 as 2083 bytes in 1 ms | |
13/12/09 15:49:30,587 INFO cluster.ClusterTaskSetManager: Finished TID 279 in 620 ms on ip-10-181-0-146.ec2.internal (progress: 27/108) | |
13/12/09 15:49:30,587 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 60) | |
13/12/09 15:49:30,617 INFO cluster.ClusterTaskSetManager: Starting task 1.1:36 as TID 286 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,617 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:36 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,618 INFO cluster.ClusterTaskSetManager: Finished TID 280 in 615 ms on ip-10-181-0-146.ec2.internal (progress: 28/108) | |
13/12/09 15:49:30,618 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 61) | |
13/12/09 15:49:30,707 INFO cluster.ClusterTaskSetManager: Starting task 1.1:37 as TID 287 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,707 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:37 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,708 INFO cluster.ClusterTaskSetManager: Finished TID 276 in 1100 ms on ip-10-181-0-146.ec2.internal (progress: 29/108) | |
13/12/09 15:49:30,708 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 54) | |
13/12/09 15:49:30,948 INFO cluster.ClusterTaskSetManager: Starting task 1.1:38 as TID 288 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:30,948 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:38 as 2083 bytes in 0 ms | |
13/12/09 15:49:30,949 INFO cluster.ClusterTaskSetManager: Finished TID 277 in 1026 ms on ip-10-181-0-146.ec2.internal (progress: 30/108) | |
13/12/09 15:49:30,949 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 55) | |
13/12/09 15:49:31,025 INFO cluster.ClusterTaskSetManager: Starting task 1.1:39 as TID 289 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,026 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:39 as 2083 bytes in 0 ms | |
13/12/09 15:49:31,026 INFO cluster.ClusterTaskSetManager: Finished TID 281 in 973 ms on ip-10-181-0-146.ec2.internal (progress: 31/108) | |
13/12/09 15:49:31,027 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 63) | |
13/12/09 15:49:31,077 INFO cluster.ClusterTaskSetManager: Starting task 1.1:40 as TID 290 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,078 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:40 as 2083 bytes in 1 ms | |
13/12/09 15:49:31,078 INFO cluster.ClusterTaskSetManager: Finished TID 282 in 1020 ms on ip-10-181-0-146.ec2.internal (progress: 32/108) | |
13/12/09 15:49:31,078 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 64) | |
13/12/09 15:49:31,178 INFO cluster.ClusterTaskSetManager: Starting task 1.1:41 as TID 291 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,179 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:41 as 2083 bytes in 1 ms | |
13/12/09 15:49:31,179 INFO cluster.ClusterTaskSetManager: Finished TID 284 in 620 ms on ip-10-181-0-146.ec2.internal (progress: 33/108) | |
13/12/09 15:49:31,179 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 70) | |
13/12/09 15:49:31,182 INFO cluster.ClusterTaskSetManager: Starting task 1.1:42 as TID 292 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,182 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:42 as 2083 bytes in 0 ms | |
13/12/09 15:49:31,183 INFO cluster.ClusterTaskSetManager: Finished TID 286 in 565 ms on ip-10-181-0-146.ec2.internal (progress: 34/108) | |
13/12/09 15:49:31,183 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 74) | |
13/12/09 15:49:31,205 INFO cluster.ClusterTaskSetManager: Starting task 1.1:43 as TID 293 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,205 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:43 as 2083 bytes in 0 ms | |
13/12/09 15:49:31,206 INFO cluster.ClusterTaskSetManager: Finished TID 285 in 620 ms on ip-10-181-0-146.ec2.internal (progress: 35/108) | |
13/12/09 15:49:31,206 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 71) | |
13/12/09 15:49:31,619 INFO cluster.ClusterTaskSetManager: Starting task 1.1:44 as TID 294 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,619 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:44 as 2083 bytes in 0 ms | |
13/12/09 15:49:31,620 INFO cluster.ClusterTaskSetManager: Finished TID 283 in 1144 ms on ip-10-181-0-146.ec2.internal (progress: 36/108) | |
13/12/09 15:49:31,620 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 67) | |
13/12/09 15:49:31,765 INFO cluster.ClusterTaskSetManager: Starting task 1.1:45 as TID 295 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,765 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:45 as 2083 bytes in 0 ms | |
13/12/09 15:49:31,766 INFO cluster.ClusterTaskSetManager: Finished TID 292 in 584 ms on ip-10-181-0-146.ec2.internal (progress: 37/108) | |
13/12/09 15:49:31,766 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 84) | |
13/12/09 15:49:31,777 INFO cluster.ClusterTaskSetManager: Starting task 1.1:46 as TID 296 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,777 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:46 as 2083 bytes in 0 ms | |
13/12/09 15:49:31,778 INFO cluster.ClusterTaskSetManager: Finished TID 291 in 600 ms on ip-10-181-0-146.ec2.internal (progress: 38/108) | |
13/12/09 15:49:31,778 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 83) | |
13/12/09 15:49:31,785 INFO cluster.ClusterTaskSetManager: Finished TID 287 in 1078 ms on ip-10-181-0-146.ec2.internal (progress: 39/108) | |
13/12/09 15:49:31,785 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 76) | |
13/12/09 15:49:31,785 INFO cluster.ClusterTaskSetManager: Starting task 1.1:47 as TID 297 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:31,786 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:47 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,015 INFO cluster.ClusterTaskSetManager: Starting task 1.1:48 as TID 298 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,015 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:48 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,015 INFO cluster.ClusterTaskSetManager: Finished TID 288 in 1068 ms on ip-10-181-0-146.ec2.internal (progress: 40/108) | |
13/12/09 15:49:32,016 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 77) | |
13/12/09 15:49:32,029 INFO cluster.ClusterTaskSetManager: Finished TID 289 in 1004 ms on ip-10-181-0-146.ec2.internal (progress: 41/108) | |
13/12/09 15:49:32,030 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 79) | |
13/12/09 15:49:32,030 INFO cluster.ClusterTaskSetManager: Starting task 1.1:49 as TID 299 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,030 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:49 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,099 INFO cluster.ClusterTaskSetManager: Starting task 1.1:50 as TID 300 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,099 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:50 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,100 INFO cluster.ClusterTaskSetManager: Finished TID 290 in 1023 ms on ip-10-181-0-146.ec2.internal (progress: 42/108) | |
13/12/09 15:49:32,101 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 80) | |
13/12/09 15:49:32,232 INFO cluster.ClusterTaskSetManager: Starting task 1.1:51 as TID 301 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,232 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:51 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,232 INFO cluster.ClusterTaskSetManager: Finished TID 293 in 1027 ms on ip-10-181-0-146.ec2.internal (progress: 43/108) | |
13/12/09 15:49:32,233 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 87) | |
13/12/09 15:49:32,367 INFO cluster.ClusterTaskSetManager: Starting task 1.1:52 as TID 302 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,368 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:52 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,369 INFO cluster.ClusterTaskSetManager: Finished TID 296 in 591 ms on ip-10-181-0-146.ec2.internal (progress: 44/108) | |
13/12/09 15:49:32,369 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 96) | |
13/12/09 15:49:32,460 INFO cluster.ClusterTaskSetManager: Starting task 1.1:53 as TID 303 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,460 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:53 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,460 INFO cluster.ClusterTaskSetManager: Finished TID 295 in 695 ms on ip-10-181-0-146.ec2.internal (progress: 45/108) | |
13/12/09 15:49:32,461 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 94) | |
13/12/09 15:49:32,564 INFO cluster.ClusterTaskSetManager: Starting task 1.1:54 as TID 304 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,564 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:54 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,565 INFO cluster.ClusterTaskSetManager: Finished TID 297 in 780 ms on ip-10-181-0-146.ec2.internal (progress: 46/108) | |
13/12/09 15:49:32,565 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 97) | |
13/12/09 15:49:32,607 INFO cluster.ClusterTaskSetManager: Starting task 1.1:55 as TID 305 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,608 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:55 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,608 INFO cluster.ClusterTaskSetManager: Finished TID 298 in 594 ms on ip-10-181-0-146.ec2.internal (progress: 47/108) | |
13/12/09 15:49:32,609 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 98) | |
13/12/09 15:49:32,676 INFO cluster.ClusterTaskSetManager: Starting task 1.1:56 as TID 306 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,677 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:56 as 2083 bytes in 1 ms | |
13/12/09 15:49:32,677 INFO cluster.ClusterTaskSetManager: Finished TID 294 in 1058 ms on ip-10-181-0-146.ec2.internal (progress: 48/108) | |
13/12/09 15:49:32,678 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 89) | |
13/12/09 15:49:32,945 INFO cluster.ClusterTaskSetManager: Starting task 1.1:57 as TID 307 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:32,946 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:57 as 2083 bytes in 0 ms | |
13/12/09 15:49:32,946 INFO cluster.ClusterTaskSetManager: Finished TID 299 in 916 ms on ip-10-181-0-146.ec2.internal (progress: 49/108) | |
13/12/09 15:49:32,947 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 100) | |
13/12/09 15:49:33,032 INFO cluster.ClusterTaskSetManager: Starting task 1.1:58 as TID 308 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,033 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:58 as 2083 bytes in 1 ms | |
13/12/09 15:49:33,033 INFO cluster.ClusterTaskSetManager: Finished TID 303 in 573 ms on ip-10-181-0-146.ec2.internal (progress: 50/108) | |
13/12/09 15:49:33,033 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 105) | |
13/12/09 15:49:33,081 INFO cluster.ClusterTaskSetManager: Starting task 1.1:59 as TID 309 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,082 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:59 as 2083 bytes in 1 ms | |
13/12/09 15:49:33,082 INFO cluster.ClusterTaskSetManager: Finished TID 300 in 983 ms on ip-10-181-0-146.ec2.internal (progress: 51/108) | |
13/12/09 15:49:33,082 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 102) | |
13/12/09 15:49:33,124 INFO cluster.ClusterTaskSetManager: Starting task 1.1:60 as TID 310 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,124 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:60 as 2083 bytes in 0 ms | |
13/12/09 15:49:33,125 INFO cluster.ClusterTaskSetManager: Finished TID 304 in 561 ms on ip-10-181-0-146.ec2.internal (progress: 52/108) | |
13/12/09 15:49:33,125 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 109) | |
13/12/09 15:49:33,204 INFO cluster.ClusterTaskSetManager: Starting task 1.1:61 as TID 311 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,204 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:61 as 2083 bytes in 0 ms | |
13/12/09 15:49:33,205 INFO cluster.ClusterTaskSetManager: Finished TID 301 in 973 ms on ip-10-181-0-146.ec2.internal (progress: 53/108) | |
13/12/09 15:49:33,205 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 103) | |
13/12/09 15:49:33,281 INFO cluster.ClusterTaskSetManager: Starting task 1.1:62 as TID 312 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,281 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:62 as 2083 bytes in 0 ms | |
13/12/09 15:49:33,282 INFO cluster.ClusterTaskSetManager: Finished TID 305 in 675 ms on ip-10-181-0-146.ec2.internal (progress: 54/108) | |
13/12/09 15:49:33,282 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 110) | |
13/12/09 15:49:33,342 INFO cluster.ClusterTaskSetManager: Starting task 1.1:63 as TID 313 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,343 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:63 as 2083 bytes in 0 ms | |
13/12/09 15:49:33,343 INFO cluster.ClusterTaskSetManager: Finished TID 302 in 976 ms on ip-10-181-0-146.ec2.internal (progress: 55/108) | |
13/12/09 15:49:33,343 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 104) | |
13/12/09 15:49:33,514 INFO cluster.ClusterTaskSetManager: Starting task 1.1:64 as TID 314 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,515 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:64 as 2083 bytes in 1 ms | |
13/12/09 15:49:33,515 INFO cluster.ClusterTaskSetManager: Finished TID 306 in 839 ms on ip-10-181-0-146.ec2.internal (progress: 56/108) | |
13/12/09 15:49:33,516 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 111) | |
13/12/09 15:49:33,530 INFO cluster.ClusterTaskSetManager: Starting task 1.1:65 as TID 315 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,531 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:65 as 2083 bytes in 1 ms | |
13/12/09 15:49:33,531 INFO cluster.ClusterTaskSetManager: Finished TID 308 in 499 ms on ip-10-181-0-146.ec2.internal (progress: 57/108) | |
13/12/09 15:49:33,531 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 117) | |
13/12/09 15:49:33,693 INFO cluster.ClusterTaskSetManager: Starting task 1.1:66 as TID 316 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,693 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:66 as 2083 bytes in 0 ms | |
13/12/09 15:49:33,693 INFO cluster.ClusterTaskSetManager: Finished TID 309 in 612 ms on ip-10-181-0-146.ec2.internal (progress: 58/108) | |
13/12/09 15:49:33,694 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 120) | |
13/12/09 15:49:33,878 INFO cluster.ClusterTaskSetManager: Starting task 1.1:67 as TID 317 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:33,878 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:67 as 2083 bytes in 0 ms | |
13/12/09 15:49:33,878 INFO cluster.ClusterTaskSetManager: Finished TID 307 in 933 ms on ip-10-181-0-146.ec2.internal (progress: 59/108) | |
13/12/09 15:49:33,878 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 116) | |
13/12/09 15:49:34,032 INFO cluster.ClusterTaskSetManager: Starting task 1.1:68 as TID 318 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,032 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:68 as 2083 bytes in 0 ms | |
13/12/09 15:49:34,033 INFO cluster.ClusterTaskSetManager: Finished TID 315 in 503 ms on ip-10-181-0-146.ec2.internal (progress: 60/108) | |
13/12/09 15:49:34,033 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 132) | |
13/12/09 15:49:34,067 INFO cluster.ClusterTaskSetManager: Starting task 1.1:69 as TID 319 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,068 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:69 as 2083 bytes in 0 ms | |
13/12/09 15:49:34,068 INFO cluster.ClusterTaskSetManager: Finished TID 314 in 554 ms on ip-10-181-0-146.ec2.internal (progress: 61/108) | |
13/12/09 15:49:34,069 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 131) | |
13/12/09 15:49:34,175 INFO cluster.ClusterTaskSetManager: Starting task 1.1:70 as TID 320 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,175 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:70 as 2083 bytes in 0 ms | |
13/12/09 15:49:34,175 INFO cluster.ClusterTaskSetManager: Finished TID 312 in 894 ms on ip-10-181-0-146.ec2.internal (progress: 62/108) | |
13/12/09 15:49:34,176 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 125) | |
13/12/09 15:49:34,200 INFO cluster.ClusterTaskSetManager: Starting task 1.1:71 as TID 321 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,201 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:71 as 2083 bytes in 0 ms | |
13/12/09 15:49:34,201 INFO cluster.ClusterTaskSetManager: Finished TID 316 in 508 ms on ip-10-181-0-146.ec2.internal (progress: 63/108) | |
13/12/09 15:49:34,201 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 133) | |
13/12/09 15:49:34,214 INFO cluster.ClusterTaskSetManager: Starting task 1.1:72 as TID 322 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,215 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:72 as 2083 bytes in 0 ms | |
13/12/09 15:49:34,215 INFO cluster.ClusterTaskSetManager: Finished TID 313 in 873 ms on ip-10-181-0-146.ec2.internal (progress: 64/108) | |
13/12/09 15:49:34,216 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 128) | |
13/12/09 15:49:34,228 INFO cluster.ClusterTaskSetManager: Starting task 1.1:73 as TID 323 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,228 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:73 as 2083 bytes in 0 ms | |
13/12/09 15:49:34,229 INFO cluster.ClusterTaskSetManager: Finished TID 311 in 1025 ms on ip-10-181-0-146.ec2.internal (progress: 65/108) | |
13/12/09 15:49:34,229 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 123) | |
13/12/09 15:49:34,450 INFO cluster.ClusterTaskSetManager: Starting task 1.1:74 as TID 324 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,451 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:74 as 2083 bytes in 1 ms | |
13/12/09 15:49:34,451 INFO cluster.ClusterTaskSetManager: Finished TID 310 in 1327 ms on ip-10-181-0-146.ec2.internal (progress: 66/108) | |
13/12/09 15:49:34,451 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 122) | |
13/12/09 15:49:34,814 INFO cluster.ClusterTaskSetManager: Starting task 1.1:75 as TID 325 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,815 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:75 as 2083 bytes in 1 ms | |
13/12/09 15:49:34,815 INFO cluster.ClusterTaskSetManager: Finished TID 322 in 601 ms on ip-10-181-0-146.ec2.internal (progress: 67/108) | |
13/12/09 15:49:34,815 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 145) | |
13/12/09 15:49:34,823 INFO cluster.ClusterTaskSetManager: Starting task 1.1:76 as TID 326 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,824 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:76 as 2083 bytes in 1 ms | |
13/12/09 15:49:34,824 INFO cluster.ClusterTaskSetManager: Finished TID 317 in 947 ms on ip-10-181-0-146.ec2.internal (progress: 68/108) | |
13/12/09 15:49:34,824 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 136) | |
13/12/09 15:49:34,839 INFO cluster.ClusterTaskSetManager: Starting task 1.1:77 as TID 327 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:34,840 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:77 as 2083 bytes in 1 ms | |
13/12/09 15:49:34,840 INFO cluster.ClusterTaskSetManager: Finished TID 321 in 640 ms on ip-10-181-0-146.ec2.internal (progress: 69/108) | |
13/12/09 15:49:34,840 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 142) | |
13/12/09 15:49:35,101 INFO cluster.ClusterTaskSetManager: Starting task 1.1:78 as TID 328 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,101 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:78 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,102 INFO cluster.ClusterTaskSetManager: Finished TID 319 in 1035 ms on ip-10-181-0-146.ec2.internal (progress: 70/108) | |
13/12/09 15:49:35,102 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 139) | |
13/12/09 15:49:35,109 INFO cluster.ClusterTaskSetManager: Finished TID 320 in 935 ms on ip-10-181-0-146.ec2.internal (progress: 71/108) | |
13/12/09 15:49:35,109 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 140) | |
13/12/09 15:49:35,109 INFO cluster.ClusterTaskSetManager: Starting task 1.1:79 as TID 329 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,110 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:79 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,112 INFO cluster.ClusterTaskSetManager: Starting task 1.1:80 as TID 330 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,112 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:80 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,113 INFO cluster.ClusterTaskSetManager: Finished TID 318 in 1081 ms on ip-10-181-0-146.ec2.internal (progress: 72/108) | |
13/12/09 15:49:35,114 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 138) | |
13/12/09 15:49:35,256 INFO cluster.ClusterTaskSetManager: Starting task 1.1:81 as TID 331 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,256 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:81 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,257 INFO cluster.ClusterTaskSetManager: Finished TID 323 in 1028 ms on ip-10-181-0-146.ec2.internal (progress: 73/108) | |
13/12/09 15:49:35,257 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 147) | |
13/12/09 15:49:35,325 INFO cluster.ClusterTaskSetManager: Starting task 1.1:82 as TID 332 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,325 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:82 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,325 INFO cluster.ClusterTaskSetManager: Finished TID 327 in 486 ms on ip-10-181-0-146.ec2.internal (progress: 74/108) | |
13/12/09 15:49:35,326 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 156) | |
13/12/09 15:49:35,413 INFO cluster.ClusterTaskSetManager: Starting task 1.1:83 as TID 333 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,414 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:83 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,415 INFO cluster.ClusterTaskSetManager: Finished TID 326 in 591 ms on ip-10-181-0-146.ec2.internal (progress: 75/108) | |
13/12/09 15:49:35,415 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 153) | |
13/12/09 15:49:35,434 INFO cluster.ClusterTaskSetManager: Finished TID 324 in 984 ms on ip-10-181-0-146.ec2.internal (progress: 76/108) | |
13/12/09 15:49:35,434 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 149) | |
13/12/09 15:49:35,434 INFO cluster.ClusterTaskSetManager: Starting task 1.1:84 as TID 334 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,434 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:84 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,585 INFO cluster.ClusterTaskSetManager: Finished TID 328 in 484 ms on ip-10-181-0-146.ec2.internal (progress: 77/108) | |
13/12/09 15:49:35,585 INFO cluster.ClusterTaskSetManager: Starting task 1.1:85 as TID 335 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,585 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 157) | |
13/12/09 15:49:35,586 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:85 as 2083 bytes in 1 ms | |
13/12/09 15:49:35,591 INFO cluster.ClusterTaskSetManager: Finished TID 325 in 777 ms on ip-10-181-0-146.ec2.internal (progress: 78/108) | |
13/12/09 15:49:35,591 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 152) | |
13/12/09 15:49:35,591 INFO cluster.ClusterTaskSetManager: Starting task 1.1:86 as TID 336 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,592 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:86 as 2083 bytes in 1 ms | |
13/12/09 15:49:35,611 INFO cluster.ClusterTaskSetManager: Starting task 1.1:87 as TID 337 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,611 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:87 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,611 INFO cluster.ClusterTaskSetManager: Finished TID 329 in 502 ms on ip-10-181-0-146.ec2.internal (progress: 79/108) | |
13/12/09 15:49:35,612 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 158) | |
13/12/09 15:49:35,802 INFO cluster.ClusterTaskSetManager: Starting task 1.1:88 as TID 338 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,802 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:88 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,802 INFO cluster.ClusterTaskSetManager: Finished TID 332 in 478 ms on ip-10-181-0-146.ec2.internal (progress: 80/108) | |
13/12/09 15:49:35,803 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 166) | |
13/12/09 15:49:35,899 INFO cluster.ClusterTaskSetManager: Finished TID 334 in 465 ms on ip-10-181-0-146.ec2.internal (progress: 81/108) | |
13/12/09 15:49:35,899 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 169) | |
13/12/09 15:49:35,899 INFO cluster.ClusterTaskSetManager: Starting task 1.1:89 as TID 339 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,900 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:89 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,951 INFO cluster.ClusterTaskSetManager: Finished TID 330 in 839 ms on ip-10-181-0-146.ec2.internal (progress: 82/108) | |
13/12/09 15:49:35,951 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 162) | |
13/12/09 15:49:35,952 INFO cluster.ClusterTaskSetManager: Starting task 1.1:90 as TID 340 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,952 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:90 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,972 INFO cluster.ClusterTaskSetManager: Starting task 1.1:91 as TID 341 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:35,973 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:91 as 2083 bytes in 0 ms | |
13/12/09 15:49:35,973 INFO cluster.ClusterTaskSetManager: Finished TID 333 in 560 ms on ip-10-181-0-146.ec2.internal (progress: 83/108) | |
13/12/09 15:49:35,974 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 167) | |
13/12/09 15:49:36,308 INFO cluster.ClusterTaskSetManager: Starting task 1.1:92 as TID 342 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,308 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:92 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,309 INFO cluster.ClusterTaskSetManager: Finished TID 338 in 508 ms on ip-10-181-0-146.ec2.internal (progress: 84/108) | |
13/12/09 15:49:36,309 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 178) | |
13/12/09 15:49:36,362 INFO cluster.ClusterTaskSetManager: Starting task 1.1:93 as TID 343 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,363 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:93 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,363 INFO cluster.ClusterTaskSetManager: Finished TID 336 in 772 ms on ip-10-181-0-146.ec2.internal (progress: 85/108) | |
13/12/09 15:49:36,363 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 172) | |
13/12/09 15:49:36,448 INFO cluster.ClusterTaskSetManager: Starting task 1.1:94 as TID 344 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,449 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:94 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,449 INFO cluster.ClusterTaskSetManager: Finished TID 339 in 550 ms on ip-10-181-0-146.ec2.internal (progress: 86/108) | |
13/12/09 15:49:36,449 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 180) | |
13/12/09 15:49:36,457 INFO cluster.ClusterTaskSetManager: Finished TID 337 in 847 ms on ip-10-181-0-146.ec2.internal (progress: 87/108) | |
13/12/09 15:49:36,457 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 173) | |
13/12/09 15:49:36,458 INFO cluster.ClusterTaskSetManager: Starting task 1.1:95 as TID 345 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,458 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:95 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,480 INFO cluster.ClusterTaskSetManager: Starting task 1.1:96 as TID 346 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,481 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:96 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,481 INFO cluster.ClusterTaskSetManager: Finished TID 340 in 530 ms on ip-10-181-0-146.ec2.internal (progress: 88/108) | |
13/12/09 15:49:36,482 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 181) | |
13/12/09 15:49:36,511 INFO cluster.ClusterTaskSetManager: Starting task 1.1:97 as TID 347 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,511 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:97 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,512 INFO cluster.ClusterTaskSetManager: Finished TID 335 in 927 ms on ip-10-181-0-146.ec2.internal (progress: 89/108) | |
13/12/09 15:49:36,512 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 171) | |
13/12/09 15:49:36,959 INFO cluster.ClusterTaskSetManager: Starting task 1.1:98 as TID 348 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,960 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:98 as 2083 bytes in 0 ms | |
13/12/09 15:49:36,960 INFO cluster.ClusterTaskSetManager: Finished TID 345 in 502 ms on ip-10-181-0-146.ec2.internal (progress: 90/108) | |
13/12/09 15:49:36,961 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 191) | |
13/12/09 15:49:36,995 INFO cluster.ClusterTaskSetManager: Starting task 1.1:99 as TID 349 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:36,996 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:99 as 2083 bytes in 1 ms | |
13/12/09 15:49:36,996 INFO cluster.ClusterTaskSetManager: Finished TID 341 in 1024 ms on ip-10-181-0-146.ec2.internal (progress: 91/108) | |
13/12/09 15:49:36,996 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 183) | |
13/12/09 15:49:37,022 INFO cluster.ClusterTaskSetManager: Starting task 1.1:100 as TID 350 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,023 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:100 as 2083 bytes in 1 ms | |
13/12/09 15:49:37,023 INFO cluster.ClusterTaskSetManager: Finished TID 347 in 512 ms on ip-10-181-0-146.ec2.internal (progress: 92/108) | |
13/12/09 15:49:37,023 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 194) | |
13/12/09 15:49:37,052 INFO cluster.ClusterTaskSetManager: Starting task 1.1:101 as TID 351 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,053 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:101 as 2083 bytes in 1 ms | |
13/12/09 15:49:37,053 INFO cluster.ClusterTaskSetManager: Finished TID 346 in 573 ms on ip-10-181-0-146.ec2.internal (progress: 93/108) | |
13/12/09 15:49:37,054 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 192) | |
13/12/09 15:49:37,170 INFO cluster.ClusterTaskSetManager: Starting task 1.1:102 as TID 352 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,170 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:102 as 2083 bytes in 0 ms | |
13/12/09 15:49:37,171 INFO cluster.ClusterTaskSetManager: Finished TID 342 in 864 ms on ip-10-181-0-146.ec2.internal (progress: 94/108) | |
13/12/09 15:49:37,171 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 186) | |
13/12/09 15:49:37,201 INFO cluster.ClusterTaskSetManager: Starting task 1.1:103 as TID 353 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,201 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:103 as 2083 bytes in 0 ms | |
13/12/09 15:49:37,202 INFO cluster.ClusterTaskSetManager: Finished TID 343 in 840 ms on ip-10-181-0-146.ec2.internal (progress: 95/108) | |
13/12/09 15:49:37,202 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 187) | |
13/12/09 15:49:37,223 INFO cluster.ClusterTaskSetManager: Starting task 1.1:104 as TID 354 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,223 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:104 as 2083 bytes in 0 ms | |
13/12/09 15:49:37,223 INFO cluster.ClusterTaskSetManager: Finished TID 344 in 775 ms on ip-10-181-0-146.ec2.internal (progress: 96/108) | |
13/12/09 15:49:37,224 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 188) | |
13/12/09 15:49:37,563 INFO cluster.ClusterTaskSetManager: Starting task 1.1:105 as TID 355 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,564 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:105 as 2083 bytes in 0 ms | |
13/12/09 15:49:37,565 INFO cluster.ClusterTaskSetManager: Finished TID 350 in 543 ms on ip-10-181-0-146.ec2.internal (progress: 97/108) | |
13/12/09 15:49:37,565 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 202) | |
13/12/09 15:49:37,673 INFO cluster.ClusterTaskSetManager: Starting task 1.1:106 as TID 356 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,673 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:106 as 2083 bytes in 0 ms | |
13/12/09 15:49:37,676 INFO cluster.ClusterTaskSetManager: Finished TID 351 in 624 ms on ip-10-181-0-146.ec2.internal (progress: 98/108) | |
13/12/09 15:49:37,676 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 203) | |
13/12/09 15:49:37,677 INFO cluster.ClusterTaskSetManager: Starting task 1.1:107 as TID 357 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:37,677 INFO cluster.ClusterTaskSetManager: Serialized task 1.1:107 as 2083 bytes in 0 ms | |
13/12/09 15:49:37,678 INFO cluster.ClusterTaskSetManager: Finished TID 352 in 507 ms on ip-10-181-0-146.ec2.internal (progress: 99/108) | |
13/12/09 15:49:37,678 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 205) | |
13/12/09 15:49:37,747 INFO cluster.ClusterTaskSetManager: Finished TID 349 in 752 ms on ip-10-181-0-146.ec2.internal (progress: 100/108) | |
13/12/09 15:49:37,748 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 199) | |
13/12/09 15:49:37,834 INFO cluster.ClusterTaskSetManager: Finished TID 331 in 2578 ms on ip-10-181-0-146.ec2.internal (progress: 101/108) | |
13/12/09 15:49:37,834 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 163) | |
13/12/09 15:49:37,859 INFO cluster.ClusterTaskSetManager: Finished TID 348 in 900 ms on ip-10-181-0-146.ec2.internal (progress: 102/108) | |
13/12/09 15:49:37,859 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 196) | |
13/12/09 15:49:37,980 INFO cluster.ClusterTaskSetManager: Finished TID 353 in 779 ms on ip-10-181-0-146.ec2.internal (progress: 103/108) | |
13/12/09 15:49:37,981 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 207) | |
13/12/09 15:49:38,013 INFO cluster.ClusterTaskSetManager: Finished TID 354 in 791 ms on ip-10-181-0-146.ec2.internal (progress: 104/108) | |
13/12/09 15:49:38,013 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 208) | |
13/12/09 15:49:38,281 INFO cluster.ClusterTaskSetManager: Finished TID 355 in 718 ms on ip-10-181-0-146.ec2.internal (progress: 105/108) | |
13/12/09 15:49:38,282 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 210) | |
13/12/09 15:49:38,314 INFO cluster.ClusterTaskSetManager: Finished TID 356 in 641 ms on ip-10-181-0-146.ec2.internal (progress: 106/108) | |
13/12/09 15:49:38,314 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 211) | |
13/12/09 15:49:38,498 INFO cluster.ClusterTaskSetManager: Finished TID 357 in 821 ms on ip-10-181-0-146.ec2.internal (progress: 107/108) | |
13/12/09 15:49:38,498 INFO cluster.ClusterScheduler: Remove TaskSet 1.1 from pool | |
13/12/09 15:49:38,498 INFO scheduler.DAGScheduler: Completed ShuffleMapTask(1, 212) | |
13/12/09 15:49:38,499 INFO scheduler.DAGScheduler: Stage 1 (keyBy at LogAnalyzer.scala:35) finished in 13.184 s | |
13/12/09 15:49:38,499 INFO scheduler.DAGScheduler: looking for newly runnable stages | |
13/12/09 15:49:38,499 INFO scheduler.DAGScheduler: running: Set() | |
13/12/09 15:49:38,499 INFO scheduler.DAGScheduler: waiting: Set(Stage 0) | |
13/12/09 15:49:38,499 INFO scheduler.DAGScheduler: failed: Set() | |
13/12/09 15:49:38,506 INFO scheduler.DAGScheduler: Missing parents for Stage 0: List() | |
13/12/09 15:49:38,506 INFO scheduler.DAGScheduler: Submitting Stage 0 (MapPartitionsRDD[7] at mapPartitionsWithIndex at Vertica.scala:143), which is now runnable | |
13/12/09 15:49:38,508 INFO scheduler.DAGScheduler: Submitting 47 missing tasks from Stage 0 (MapPartitionsRDD[7] at mapPartitionsWithIndex at Vertica.scala:143) | |
13/12/09 15:49:38,509 INFO cluster.ClusterScheduler: Adding task set 0.1 with 47 tasks | |
13/12/09 15:49:38,509 INFO cluster.ClusterTaskSetManager: Starting task 0.1:0 as TID 358 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,510 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:0 as 8080 bytes in 1 ms | |
13/12/09 15:49:38,510 INFO cluster.ClusterTaskSetManager: Starting task 0.1:1 as TID 359 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,510 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:1 as 8080 bytes in 0 ms | |
13/12/09 15:49:38,511 INFO cluster.ClusterTaskSetManager: Starting task 0.1:2 as TID 360 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,511 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:2 as 8080 bytes in 0 ms | |
13/12/09 15:49:38,511 INFO cluster.ClusterTaskSetManager: Starting task 0.1:3 as TID 361 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,512 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:3 as 8080 bytes in 1 ms | |
13/12/09 15:49:38,512 INFO cluster.ClusterTaskSetManager: Starting task 0.1:4 as TID 362 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,512 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:4 as 8080 bytes in 0 ms | |
13/12/09 15:49:38,513 INFO cluster.ClusterTaskSetManager: Starting task 0.1:5 as TID 363 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,513 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:5 as 8080 bytes in 0 ms | |
13/12/09 15:49:38,513 INFO cluster.ClusterTaskSetManager: Starting task 0.1:6 as TID 364 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,514 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:6 as 8080 bytes in 1 ms | |
13/12/09 15:49:38,514 INFO cluster.ClusterTaskSetManager: Starting task 0.1:7 as TID 365 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:49:38,514 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:7 as 8080 bytes in 0 ms | |
13/12/09 15:49:38,536 INFO spark.MapOutputTrackerMasterActor: Asked to send map output locations for shuffle 0 to ip-10-181-0-146.ec2.internal:47339 | |
13/12/09 15:49:38,543 INFO spark.MapOutputTrackerMaster: Size of output statuses for shuffle 0 is 6156 bytes | |
13/12/09 15:50:43,076 INFO cluster.ClusterTaskSetManager: Starting task 0.1:8 as TID 366 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:43,077 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:8 as 8080 bytes in 0 ms | |
13/12/09 15:50:43,077 INFO cluster.ClusterTaskSetManager: Finished TID 362 in 64565 ms on ip-10-181-0-146.ec2.internal (progress: 0/47) | |
13/12/09 15:50:43,078 INFO scheduler.DAGScheduler: Completed ResultTask(0, 20) | |
13/12/09 15:50:44,654 INFO cluster.ClusterTaskSetManager: Starting task 0.1:9 as TID 367 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:44,654 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:9 as 8080 bytes in 0 ms | |
13/12/09 15:50:44,655 INFO cluster.ClusterTaskSetManager: Finished TID 359 in 66145 ms on ip-10-181-0-146.ec2.internal (progress: 1/47) | |
13/12/09 15:50:44,655 INFO scheduler.DAGScheduler: Completed ResultTask(0, 17) | |
13/12/09 15:50:45,059 INFO cluster.ClusterTaskSetManager: Starting task 0.1:10 as TID 368 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:45,059 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:10 as 8080 bytes in 0 ms | |
13/12/09 15:50:45,060 INFO cluster.ClusterTaskSetManager: Finished TID 364 in 66547 ms on ip-10-181-0-146.ec2.internal (progress: 2/47) | |
13/12/09 15:50:45,060 INFO scheduler.DAGScheduler: Completed ResultTask(0, 22) | |
13/12/09 15:50:45,384 INFO cluster.ClusterTaskSetManager: Starting task 0.1:11 as TID 369 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:45,384 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:11 as 8080 bytes in 0 ms | |
13/12/09 15:50:45,385 INFO cluster.ClusterTaskSetManager: Finished TID 358 in 66876 ms on ip-10-181-0-146.ec2.internal (progress: 3/47) | |
13/12/09 15:50:45,385 INFO scheduler.DAGScheduler: Completed ResultTask(0, 16) | |
13/12/09 15:50:45,401 INFO cluster.ClusterTaskSetManager: Starting task 0.1:12 as TID 370 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:45,401 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:12 as 8080 bytes in 0 ms | |
13/12/09 15:50:45,401 INFO cluster.ClusterTaskSetManager: Finished TID 361 in 66890 ms on ip-10-181-0-146.ec2.internal (progress: 4/47) | |
13/12/09 15:50:45,401 INFO scheduler.DAGScheduler: Completed ResultTask(0, 19) | |
13/12/09 15:50:45,480 INFO cluster.ClusterTaskSetManager: Starting task 0.1:13 as TID 371 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:45,480 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:13 as 8080 bytes in 0 ms | |
13/12/09 15:50:45,480 INFO cluster.ClusterTaskSetManager: Finished TID 360 in 66969 ms on ip-10-181-0-146.ec2.internal (progress: 5/47) | |
13/12/09 15:50:45,481 INFO scheduler.DAGScheduler: Completed ResultTask(0, 18) | |
13/12/09 15:50:45,642 INFO cluster.ClusterTaskSetManager: Starting task 0.1:14 as TID 372 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:45,642 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:14 as 8080 bytes in 0 ms | |
13/12/09 15:50:45,643 INFO cluster.ClusterTaskSetManager: Finished TID 363 in 67130 ms on ip-10-181-0-146.ec2.internal (progress: 6/47) | |
13/12/09 15:50:45,643 INFO scheduler.DAGScheduler: Completed ResultTask(0, 21) | |
13/12/09 15:50:45,821 INFO cluster.ClusterTaskSetManager: Starting task 0.1:15 as TID 373 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:50:45,822 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:15 as 8080 bytes in 0 ms | |
13/12/09 15:50:45,822 INFO cluster.ClusterTaskSetManager: Finished TID 365 in 67308 ms on ip-10-181-0-146.ec2.internal (progress: 7/47) | |
13/12/09 15:50:45,822 INFO scheduler.DAGScheduler: Completed ResultTask(0, 23) | |
13/12/09 15:51:47,178 INFO cluster.ClusterTaskSetManager: Starting task 0.1:16 as TID 374 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:47,179 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:16 as 8080 bytes in 1 ms | |
13/12/09 15:51:47,179 INFO cluster.ClusterTaskSetManager: Finished TID 366 in 64103 ms on ip-10-181-0-146.ec2.internal (progress: 8/47) | |
13/12/09 15:51:47,179 INFO scheduler.DAGScheduler: Completed ResultTask(0, 24) | |
13/12/09 15:51:49,204 INFO cluster.ClusterTaskSetManager: Starting task 0.1:17 as TID 375 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:49,204 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:17 as 8080 bytes in 0 ms | |
13/12/09 15:51:49,204 INFO cluster.ClusterTaskSetManager: Finished TID 367 in 64550 ms on ip-10-181-0-146.ec2.internal (progress: 9/47) | |
13/12/09 15:51:49,205 INFO scheduler.DAGScheduler: Completed ResultTask(0, 26) | |
13/12/09 15:51:50,649 INFO cluster.ClusterTaskSetManager: Starting task 0.1:18 as TID 376 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:50,650 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:18 as 8080 bytes in 0 ms | |
13/12/09 15:51:50,650 INFO cluster.ClusterTaskSetManager: Finished TID 371 in 65170 ms on ip-10-181-0-146.ec2.internal (progress: 10/47) | |
13/12/09 15:51:50,651 INFO scheduler.DAGScheduler: Completed ResultTask(0, 30) | |
13/12/09 15:51:50,993 INFO cluster.ClusterTaskSetManager: Starting task 0.1:19 as TID 377 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:50,993 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:19 as 8080 bytes in 0 ms | |
13/12/09 15:51:50,994 INFO cluster.ClusterTaskSetManager: Finished TID 369 in 65610 ms on ip-10-181-0-146.ec2.internal (progress: 11/47) | |
13/12/09 15:51:50,994 INFO scheduler.DAGScheduler: Completed ResultTask(0, 28) | |
13/12/09 15:51:51,382 INFO cluster.ClusterTaskSetManager: Starting task 0.1:20 as TID 378 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:51,382 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:20 as 8080 bytes in 0 ms | |
13/12/09 15:51:51,383 INFO cluster.ClusterTaskSetManager: Finished TID 368 in 66324 ms on ip-10-181-0-146.ec2.internal (progress: 12/47) | |
13/12/09 15:51:51,383 INFO scheduler.DAGScheduler: Completed ResultTask(0, 27) | |
13/12/09 15:51:51,476 INFO cluster.ClusterTaskSetManager: Starting task 0.1:21 as TID 379 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:51,476 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:21 as 8080 bytes in 0 ms | |
13/12/09 15:51:51,476 INFO cluster.ClusterTaskSetManager: Finished TID 373 in 65655 ms on ip-10-181-0-146.ec2.internal (progress: 13/47) | |
13/12/09 15:51:51,477 INFO scheduler.DAGScheduler: Completed ResultTask(0, 32) | |
13/12/09 15:51:51,569 INFO cluster.ClusterTaskSetManager: Starting task 0.1:22 as TID 380 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:51,570 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:22 as 8080 bytes in 1 ms | |
13/12/09 15:51:51,570 INFO cluster.ClusterTaskSetManager: Finished TID 370 in 66170 ms on ip-10-181-0-146.ec2.internal (progress: 14/47) | |
13/12/09 15:51:51,570 INFO scheduler.DAGScheduler: Completed ResultTask(0, 29) | |
13/12/09 15:51:52,116 INFO cluster.ClusterTaskSetManager: Starting task 0.1:23 as TID 381 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:51:52,116 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:23 as 8080 bytes in 0 ms | |
13/12/09 15:51:52,117 INFO cluster.ClusterTaskSetManager: Finished TID 372 in 66475 ms on ip-10-181-0-146.ec2.internal (progress: 15/47) | |
13/12/09 15:51:52,117 INFO scheduler.DAGScheduler: Completed ResultTask(0, 31) | |
13/12/09 15:52:55,809 INFO cluster.ClusterTaskSetManager: Starting task 0.1:24 as TID 382 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:52:55,810 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:24 as 8080 bytes in 0 ms | |
13/12/09 15:52:55,810 INFO cluster.ClusterTaskSetManager: Finished TID 374 in 68632 ms on ip-10-181-0-146.ec2.internal (progress: 16/47) | |
13/12/09 15:52:55,810 INFO scheduler.DAGScheduler: Completed ResultTask(0, 33) | |
13/12/09 15:52:57,018 INFO cluster.ClusterTaskSetManager: Starting task 0.1:25 as TID 383 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:52:57,018 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:25 as 8080 bytes in 0 ms | |
13/12/09 15:52:57,019 INFO cluster.ClusterTaskSetManager: Finished TID 375 in 67816 ms on ip-10-181-0-146.ec2.internal (progress: 17/47) | |
13/12/09 15:52:57,019 INFO scheduler.DAGScheduler: Completed ResultTask(0, 34) | |
13/12/09 15:52:58,851 INFO cluster.ClusterTaskSetManager: Starting task 0.1:26 as TID 384 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:52:58,851 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:26 as 8080 bytes in 0 ms | |
13/12/09 15:52:58,852 INFO cluster.ClusterTaskSetManager: Finished TID 376 in 68202 ms on ip-10-181-0-146.ec2.internal (progress: 18/47) | |
13/12/09 15:52:58,852 INFO scheduler.DAGScheduler: Completed ResultTask(0, 35) | |
13/12/09 15:52:58,898 INFO cluster.ClusterTaskSetManager: Starting task 0.1:27 as TID 385 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:52:58,898 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:27 as 8080 bytes in 0 ms | |
13/12/09 15:52:58,898 INFO cluster.ClusterTaskSetManager: Finished TID 379 in 67422 ms on ip-10-181-0-146.ec2.internal (progress: 19/47) | |
13/12/09 15:52:58,898 INFO scheduler.DAGScheduler: Completed ResultTask(0, 38) | |
13/12/09 15:53:00,243 INFO cluster.ClusterTaskSetManager: Starting task 0.1:28 as TID 386 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:53:00,244 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:28 as 8080 bytes in 0 ms | |
13/12/09 15:53:00,244 INFO cluster.ClusterTaskSetManager: Finished TID 380 in 68675 ms on ip-10-181-0-146.ec2.internal (progress: 20/47) | |
13/12/09 15:53:00,245 INFO scheduler.DAGScheduler: Completed ResultTask(0, 39) | |
13/12/09 15:53:00,273 INFO cluster.ClusterTaskSetManager: Starting task 0.1:29 as TID 387 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:53:00,274 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:29 as 8080 bytes in 1 ms | |
13/12/09 15:53:00,274 INFO cluster.ClusterTaskSetManager: Finished TID 377 in 69281 ms on ip-10-181-0-146.ec2.internal (progress: 21/47) | |
13/12/09 15:53:00,274 INFO scheduler.DAGScheduler: Completed ResultTask(0, 36) | |
13/12/09 15:53:00,442 INFO cluster.ClusterTaskSetManager: Starting task 0.1:30 as TID 388 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:53:00,443 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:30 as 8080 bytes in 1 ms | |
13/12/09 15:53:00,443 INFO cluster.ClusterTaskSetManager: Finished TID 378 in 69061 ms on ip-10-181-0-146.ec2.internal (progress: 22/47) | |
13/12/09 15:53:00,443 INFO scheduler.DAGScheduler: Completed ResultTask(0, 37) | |
13/12/09 15:53:00,693 INFO cluster.ClusterTaskSetManager: Starting task 0.1:31 as TID 389 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:53:00,693 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:31 as 8080 bytes in 0 ms | |
13/12/09 15:53:00,694 INFO cluster.ClusterTaskSetManager: Finished TID 381 in 68578 ms on ip-10-181-0-146.ec2.internal (progress: 23/47) | |
13/12/09 15:53:00,694 INFO scheduler.DAGScheduler: Completed ResultTask(0, 40) | |
13/12/09 15:53:57,469 INFO cluster.ClusterTaskSetManager: Starting task 0.1:32 as TID 390 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:53:57,469 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:32 as 8080 bytes in 0 ms | |
13/12/09 15:53:57,470 INFO cluster.ClusterTaskSetManager: Finished TID 382 in 61661 ms on ip-10-181-0-146.ec2.internal (progress: 24/47) | |
13/12/09 15:53:57,470 INFO scheduler.DAGScheduler: Completed ResultTask(0, 41) | |
13/12/09 15:53:58,087 INFO cluster.ClusterTaskSetManager: Starting task 0.1:33 as TID 391 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:53:58,087 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:33 as 8080 bytes in 0 ms | |
13/12/09 15:53:58,088 INFO cluster.ClusterTaskSetManager: Finished TID 383 in 61069 ms on ip-10-181-0-146.ec2.internal (progress: 25/47) | |
13/12/09 15:53:58,088 INFO scheduler.DAGScheduler: Completed ResultTask(0, 42) | |
13/12/09 15:54:01,820 INFO cluster.ClusterTaskSetManager: Starting task 0.1:34 as TID 392 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:01,821 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:34 as 8080 bytes in 1 ms | |
13/12/09 15:54:01,821 INFO cluster.ClusterTaskSetManager: Finished TID 385 in 62924 ms on ip-10-181-0-146.ec2.internal (progress: 26/47) | |
13/12/09 15:54:01,821 INFO scheduler.DAGScheduler: Completed ResultTask(0, 44) | |
13/12/09 15:54:02,787 INFO cluster.ClusterTaskSetManager: Starting task 0.1:35 as TID 393 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:02,788 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:35 as 8080 bytes in 0 ms | |
13/12/09 15:54:02,789 INFO cluster.ClusterTaskSetManager: Finished TID 384 in 63939 ms on ip-10-181-0-146.ec2.internal (progress: 27/47) | |
13/12/09 15:54:02,789 INFO scheduler.DAGScheduler: Completed ResultTask(0, 43) | |
13/12/09 15:54:02,885 INFO cluster.ClusterTaskSetManager: Starting task 0.1:36 as TID 394 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:02,886 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:36 as 8080 bytes in 0 ms | |
13/12/09 15:54:02,887 INFO cluster.ClusterTaskSetManager: Finished TID 388 in 62445 ms on ip-10-181-0-146.ec2.internal (progress: 28/47) | |
13/12/09 15:54:02,887 INFO scheduler.DAGScheduler: Completed ResultTask(0, 47) | |
13/12/09 15:54:03,489 INFO cluster.ClusterTaskSetManager: Starting task 0.1:37 as TID 395 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:03,490 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:37 as 8080 bytes in 0 ms | |
13/12/09 15:54:03,490 INFO cluster.ClusterTaskSetManager: Finished TID 389 in 62797 ms on ip-10-181-0-146.ec2.internal (progress: 29/47) | |
13/12/09 15:54:03,491 INFO scheduler.DAGScheduler: Completed ResultTask(0, 48) | |
13/12/09 15:54:03,672 INFO cluster.ClusterTaskSetManager: Starting task 0.1:38 as TID 396 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:03,672 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:38 as 8080 bytes in 0 ms | |
13/12/09 15:54:03,673 INFO cluster.ClusterTaskSetManager: Finished TID 386 in 63429 ms on ip-10-181-0-146.ec2.internal (progress: 30/47) | |
13/12/09 15:54:03,673 INFO scheduler.DAGScheduler: Completed ResultTask(0, 45) | |
13/12/09 15:54:04,074 INFO cluster.ClusterTaskSetManager: Starting task 0.1:39 as TID 397 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:04,075 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:39 as 8080 bytes in 1 ms | |
13/12/09 15:54:04,075 INFO cluster.ClusterTaskSetManager: Finished TID 387 in 63802 ms on ip-10-181-0-146.ec2.internal (progress: 31/47) | |
13/12/09 15:54:04,075 INFO scheduler.DAGScheduler: Completed ResultTask(0, 46) | |
13/12/09 15:54:56,843 INFO cluster.ClusterTaskSetManager: Starting task 0.1:40 as TID 398 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:56,843 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:40 as 8080 bytes in 0 ms | |
13/12/09 15:54:56,844 INFO cluster.ClusterTaskSetManager: Finished TID 390 in 59375 ms on ip-10-181-0-146.ec2.internal (progress: 32/47) | |
13/12/09 15:54:56,844 INFO scheduler.DAGScheduler: Completed ResultTask(0, 49) | |
13/12/09 15:54:58,077 INFO cluster.ClusterTaskSetManager: Starting task 0.1:41 as TID 399 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:54:58,078 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:41 as 8080 bytes in 0 ms | |
13/12/09 15:54:58,079 INFO cluster.ClusterTaskSetManager: Finished TID 391 in 59992 ms on ip-10-181-0-146.ec2.internal (progress: 33/47) | |
13/12/09 15:54:58,079 INFO scheduler.DAGScheduler: Completed ResultTask(0, 50) | |
13/12/09 15:55:01,648 INFO cluster.ClusterTaskSetManager: Starting task 0.1:42 as TID 400 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:55:01,648 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:42 as 8080 bytes in 0 ms | |
13/12/09 15:55:01,649 INFO cluster.ClusterTaskSetManager: Finished TID 392 in 59828 ms on ip-10-181-0-146.ec2.internal (progress: 34/47) | |
13/12/09 15:55:01,649 INFO scheduler.DAGScheduler: Completed ResultTask(0, 51) | |
13/12/09 15:55:02,858 INFO cluster.ClusterTaskSetManager: Starting task 0.1:43 as TID 401 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:55:02,858 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:43 as 8080 bytes in 0 ms | |
13/12/09 15:55:02,859 INFO cluster.ClusterTaskSetManager: Finished TID 394 in 59974 ms on ip-10-181-0-146.ec2.internal (progress: 35/47) | |
13/12/09 15:55:02,860 INFO scheduler.DAGScheduler: Completed ResultTask(0, 53) | |
13/12/09 15:55:04,308 INFO cluster.ClusterTaskSetManager: Starting task 0.1:44 as TID 402 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:55:04,309 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:44 as 8080 bytes in 1 ms | |
13/12/09 15:55:04,310 INFO cluster.ClusterTaskSetManager: Finished TID 393 in 61523 ms on ip-10-181-0-146.ec2.internal (progress: 36/47) | |
13/12/09 15:55:04,310 INFO scheduler.DAGScheduler: Completed ResultTask(0, 52) | |
13/12/09 15:55:04,377 INFO cluster.ClusterTaskSetManager: Starting task 0.1:45 as TID 403 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:55:04,377 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:45 as 8080 bytes in 0 ms | |
13/12/09 15:55:04,378 INFO cluster.ClusterTaskSetManager: Finished TID 396 in 60707 ms on ip-10-181-0-146.ec2.internal (progress: 37/47) | |
13/12/09 15:55:04,378 INFO scheduler.DAGScheduler: Completed ResultTask(0, 55) | |
13/12/09 15:55:07,222 INFO cluster.ClusterTaskSetManager: Starting task 0.1:46 as TID 404 on executor 1: ip-10-181-0-146.ec2.internal (PROCESS_LOCAL) | |
13/12/09 15:55:07,223 INFO cluster.ClusterTaskSetManager: Serialized task 0.1:46 as 8080 bytes in 1 ms | |
13/12/09 15:55:07,223 INFO cluster.ClusterTaskSetManager: Finished TID 395 in 63734 ms on ip-10-181-0-146.ec2.internal (progress: 38/47) | |
13/12/09 15:55:07,223 INFO scheduler.DAGScheduler: Completed ResultTask(0, 54) | |
13/12/09 15:55:07,603 INFO cluster.ClusterTaskSetManager: Finished TID 397 in 63528 ms on ip-10-181-0-146.ec2.internal (progress: 39/47) | |
13/12/09 15:55:07,603 INFO scheduler.DAGScheduler: Completed ResultTask(0, 56) | |
13/12/09 15:55:56,517 INFO cluster.ClusterTaskSetManager: Finished TID 398 in 59675 ms on ip-10-181-0-146.ec2.internal (progress: 40/47) | |
13/12/09 15:55:56,517 INFO scheduler.DAGScheduler: Completed ResultTask(0, 57) | |
13/12/09 15:55:56,827 INFO cluster.ClusterTaskSetManager: Finished TID 399 in 58750 ms on ip-10-181-0-146.ec2.internal (progress: 41/47) | |
13/12/09 15:55:56,827 INFO scheduler.DAGScheduler: Completed ResultTask(0, 58) | |
13/12/09 15:56:00,688 INFO cluster.ClusterTaskSetManager: Finished TID 400 in 59041 ms on ip-10-181-0-146.ec2.internal (progress: 42/47) | |
13/12/09 15:56:00,688 INFO scheduler.DAGScheduler: Completed ResultTask(0, 59) | |
13/12/09 15:56:02,001 INFO cluster.ClusterTaskSetManager: Finished TID 401 in 59143 ms on ip-10-181-0-146.ec2.internal (progress: 43/47) | |
13/12/09 15:56:02,001 INFO scheduler.DAGScheduler: Completed ResultTask(0, 60) | |
13/12/09 15:56:02,383 INFO cluster.ClusterTaskSetManager: Finished TID 403 in 58006 ms on ip-10-181-0-146.ec2.internal (progress: 44/47) | |
13/12/09 15:56:02,383 INFO scheduler.DAGScheduler: Completed ResultTask(0, 62) | |
13/12/09 15:56:03,367 INFO cluster.ClusterTaskSetManager: Finished TID 402 in 59059 ms on ip-10-181-0-146.ec2.internal (progress: 45/47) | |
13/12/09 15:56:03,367 INFO scheduler.DAGScheduler: Completed ResultTask(0, 61) | |
13/12/09 15:56:04,288 INFO cluster.ClusterTaskSetManager: Finished TID 404 in 57066 ms on ip-10-181-0-146.ec2.internal (progress: 46/47) | |
13/12/09 15:56:04,288 INFO cluster.ClusterScheduler: Remove TaskSet 0.1 from pool | |
13/12/09 15:56:04,288 INFO scheduler.DAGScheduler: Completed ResultTask(0, 63) | |
13/12/09 15:56:04,288 INFO scheduler.DAGScheduler: Stage 0 (foreach at Vertica.scala:143) finished in 385.779 s | |
13/12/09 15:56:04,301 INFO spark.SparkContext: Job finished: foreach at Vertica.scala:143, took 549.656763309 s | |
13/12/09 15:56:04,302 INFO vertica.Vertica: Inserting to temporary tables finished in 549.716 seconds | |
13/12/09 15:56:04,303 INFO vertica.Vertica: Copying to final tables started | |
13/12/09 15:56:04,305 INFO vertica.Vertica: - sessions... | |
13/12/09 15:56:11,839 INFO vertica.Vertica: - 860795 rows affected. | |
13/12/09 15:56:11,839 INFO vertica.Vertica: - experimentTags... | |
13/12/09 15:56:12,126 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:12,127 INFO vertica.Vertica: - customSegments... | |
13/12/09 15:56:12,375 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:12,375 INFO vertica.Vertica: - unitViews... | |
13/12/09 15:56:26,452 INFO vertica.Vertica: - 790931 rows affected. | |
13/12/09 15:56:26,452 INFO vertica.Vertica: - screenViews... | |
13/12/09 15:56:47,324 INFO vertica.Vertica: - 895482 rows affected. | |
13/12/09 15:56:47,324 INFO vertica.Vertica: - tweetPageOpens... | |
13/12/09 15:56:47,689 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:47,689 INFO vertica.Vertica: - customEventOccurrences... | |
13/12/09 15:56:50,475 INFO vertica.Vertica: - 24950 rows affected. | |
13/12/09 15:56:50,476 INFO vertica.Vertica: - storeOpens... | |
13/12/09 15:56:51,419 INFO vertica.Vertica: - 5 rows affected. | |
13/12/09 15:56:51,419 INFO vertica.Vertica: - pinterestPinAttempts... | |
13/12/09 15:56:51,778 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:51,778 INFO vertica.Vertica: - phoneCalls... | |
13/12/09 15:56:53,949 INFO vertica.Vertica: - 248 rows affected. | |
13/12/09 15:56:53,949 INFO vertica.Vertica: - videoSessions... | |
13/12/09 15:56:56,399 INFO vertica.Vertica: - 5167 rows affected. | |
13/12/09 15:56:56,399 INFO vertica.Vertica: - formSubmissionSuccesses... | |
13/12/09 15:56:56,753 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:56,753 INFO vertica.Vertica: - facebookLikes... | |
13/12/09 15:56:57,118 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:57,118 INFO vertica.Vertica: - formSubmissionAttempts... | |
13/12/09 15:56:57,473 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:56:57,473 INFO vertica.Vertica: - urlOpens... | |
13/12/09 15:56:59,971 INFO vertica.Vertica: - 2631 rows affected. | |
13/12/09 15:56:59,971 INFO vertica.Vertica: - facebookShares... | |
13/12/09 15:57:00,455 INFO vertica.Vertica: - 1 rows affected. | |
13/12/09 15:57:00,455 INFO vertica.Vertica: - twitterProfileOpens... | |
13/12/09 15:57:00,820 INFO vertica.Vertica: - 0 rows affected. | |
13/12/09 15:57:00,820 INFO vertica.Vertica: - videoSegmentViews... | |
13/12/09 15:57:03,375 INFO vertica.Vertica: - 1456 rows affected. | |
13/12/09 15:57:03,376 INFO vertica.Vertica: All tables processed. | |
13/12/09 15:57:03,376 INFO vertica.Vertica: Copying to final tables finished in 59.073 seconds | |
13/12/09 15:57:03,377 INFO vertica.Vertica: Commiting transaction... | |
13/12/09 15:57:03,446 INFO vertica.Vertica: Dropping temporary tables... | |
13/12/09 15:57:04,149 INFO analyzer.App: Done! |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment