Fixed problem with method Read.getMatePosition returning null value

Changed the value to be an option. Several values on the API can return null. I think all those fields should be converted to Option on the RDD.
@calbach, good catch but even with changing the code to `!=`, I still get an error, but now of a different type.  Spark with Scala will be super-easy for you to pick up - it has some great features, which I think you'll like :)  

Elmer, with @calbach's recommended change to `!=` in `ReadsRDD.scala`, I now get the following `500 Internal Server Error` - any recommendations?  Also the order of the examples seems to have changed as well.

```
$ sbt "run --client-secrets /home/pgrosu/me/gg_client_secrets/client_secrets_java.json --spark-master local[4]"
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=256M; support was removed in 8.0
[info] Loading project definition from /home/pgrosu/me/gg_spark/test_null/spark-examples/project
[info] Set current project to googlegenomics-spark-examples (in build file:/home/pgrosu/me/gg_spark/test_null/spark-examples/)

Multiple main classes detected, select one to run:

 [1] com.google.cloud.genomics.spark.examples.SearchReadsExample1
 [2] com.google.cloud.genomics.spark.examples.SearchReadsExample2
 [3] com.google.cloud.genomics.spark.examples.SearchReadsExample3
 [4] com.google.cloud.genomics.spark.examples.SearchReadsExample4
 [5] com.google.cloud.genomics.spark.examples.SearchVariantsExampleKlotho
 [6] com.google.cloud.genomics.spark.examples.SearchVariantsExampleBRCA1
 [7] com.google.cloud.genomics.spark.examples.VariantsSource
 [8] com.google.cloud.genomics.spark.examples.VariantsPcaDriver

Enter number: 2

[info] Running com.google.cloud.genomics.spark.examples.SearchReadsExample2 --client-secrets /home/pgrosu/me/gg_client_secrets/client_secrets_java.json --spark-master local[4]
14/09/21 18:20:45 INFO spark.SecurityManager: Changing view acls to: pgrosu
14/09/21 18:20:45 INFO spark.SecurityManager: SecurityManager: authentication disabled; ui acls disabled; users with view permissions: Set(pgrosu)
14/09/21 18:20:46 INFO slf4j.Slf4jLogger: Slf4jLogger started
14/09/21 18:20:46 INFO Remoting: Starting remoting
14/09/21 18:20:46 INFO Remoting: Remoting started; listening on addresses :[akka.tcp://spark@eofe4.cm.cluster:59607]
14/09/21 18:20:46 INFO Remoting: Remoting now listens on addresses: [akka.tcp://spark@eofe4.cm.cluster:59607]
14/09/21 18:20:46 INFO spark.SparkEnv: Registering MapOutputTracker
14/09/21 18:20:46 INFO spark.SparkEnv: Registering BlockManagerMaster
14/09/21 18:20:46 INFO storage.DiskBlockManager: Created local directory at /tmp/spark-local-20140921182046-38a2
14/09/21 18:20:46 INFO storage.MemoryStore: MemoryStore started with capacity 819.3 MB.
14/09/21 18:20:46 INFO network.ConnectionManager: Bound socket to port 50577 with id = ConnectionManagerId(eofe4.cm.cluster,50577)
14/09/21 18:20:46 INFO storage.BlockManagerMaster: Trying to register BlockManager
14/09/21 18:20:46 INFO storage.BlockManagerInfo: Registering block manager eofe4.cm.cluster:50577 with 819.3 MB RAM
14/09/21 18:20:46 INFO storage.BlockManagerMaster: Registered BlockManager
14/09/21 18:20:46 INFO spark.HttpServer: Starting HTTP Server
14/09/21 18:20:46 INFO server.Server: jetty-8.1.14.v20131031
14/09/21 18:20:46 INFO server.AbstractConnector: Started SocketConnector@0.0.0.0:59478
14/09/21 18:20:46 INFO broadcast.HttpBroadcast: Broadcast server started at http://172.16.0.247:59478
14/09/21 18:20:46 INFO spark.HttpFileServer: HTTP File server directory is /tmp/spark-7cd19ddb-0e02-489e-a943-bf931e8ada3e
14/09/21 18:20:46 INFO spark.HttpServer: Starting HTTP Server
14/09/21 18:20:46 INFO server.Server: jetty-8.1.14.v20131031
14/09/21 18:20:46 INFO server.AbstractConnector: Started SocketConnector@0.0.0.0:56850
14/09/21 18:20:47 INFO server.Server: jetty-8.1.14.v20131031
14/09/21 18:20:47 INFO server.AbstractConnector: Started SelectChannelConnector@0.0.0.0:4040
14/09/21 18:20:47 INFO ui.SparkUI: Started SparkUI at http://eofe4.cm.cluster:4040
14/09/21 18:20:47 INFO spark.SparkContext: Starting job: reduce at SearchReadsExample.scala:121
14/09/21 18:20:47 INFO scheduler.DAGScheduler: Got job 0 (reduce at SearchReadsExample.scala:121) with 147 output partitions (allowLocal=false)
14/09/21 18:20:47 INFO scheduler.DAGScheduler: Final stage: Stage 0(reduce at SearchReadsExample.scala:121)
14/09/21 18:20:47 INFO scheduler.DAGScheduler: Parents of final stage: List()
14/09/21 18:20:47 INFO scheduler.DAGScheduler: Missing parents: List()
14/09/21 18:20:47 INFO scheduler.DAGScheduler: Submitting Stage 0 (MappedRDD[1] at map at SearchReadsExample.scala:120), which has no missing parents
14/09/21 18:20:48 INFO scheduler.DAGScheduler: Submitting 147 missing tasks from Stage 0 (MappedRDD[1] at map at SearchReadsExample.scala:120)
14/09/21 18:20:48 INFO scheduler.TaskSchedulerImpl: Adding task set 0.0 with 147 tasks
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Starting task 0.0:0 as TID 0 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Serialized task 0.0:0 as 2171 bytes in 5 ms
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Starting task 0.0:1 as TID 1 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Serialized task 0.0:1 as 2171 bytes in 1 ms
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Starting task 0.0:2 as TID 2 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Serialized task 0.0:2 as 2171 bytes in 0 ms
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Starting task 0.0:3 as TID 3 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:48 INFO scheduler.TaskSetManager: Serialized task 0.0:3 as 2171 bytes in 0 ms
14/09/21 18:20:48 INFO executor.Executor: Running task ID 0
14/09/21 18:20:48 INFO executor.Executor: Running task ID 1
14/09/21 18:20:48 INFO executor.Executor: Running task ID 2
14/09/21 18:20:48 INFO executor.Executor: Running task ID 3
14/09/21 18:20:49 INFO executor.Executor: Serialized size of result for 3 is 574
14/09/21 18:20:49 INFO executor.Executor: Serialized size of result for 1 is 574
14/09/21 18:20:49 INFO executor.Executor: Serialized size of result for 2 is 574
14/09/21 18:20:49 INFO executor.Executor: Serialized size of result for 0 is 574
14/09/21 18:20:49 INFO executor.Executor: Sending result for 0 directly to driver
14/09/21 18:20:49 INFO executor.Executor: Sending result for 3 directly to driver
14/09/21 18:20:49 INFO executor.Executor: Sending result for 2 directly to driver
14/09/21 18:20:49 INFO executor.Executor: Sending result for 1 directly to driver
14/09/21 18:20:49 INFO executor.Executor: Finished task ID 3
14/09/21 18:20:49 INFO executor.Executor: Finished task ID 1
14/09/21 18:20:49 INFO executor.Executor: Finished task ID 0
14/09/21 18:20:49 INFO executor.Executor: Finished task ID 2
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Starting task 0.0:4 as TID 4 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Serialized task 0.0:4 as 2171 bytes in 1 ms
14/09/21 18:20:49 INFO executor.Executor: Running task ID 4
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Finished TID 0 in 1726 ms on localhost (progress: 1/147)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Finished TID 3 in 1712 ms on localhost (progress: 2/147)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Starting task 0.0:5 as TID 5 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:49 INFO scheduler.DAGScheduler: Completed ResultTask(0, 0)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Serialized task 0.0:5 as 2171 bytes in 1 ms
14/09/21 18:20:49 INFO scheduler.DAGScheduler: Completed ResultTask(0, 3)
14/09/21 18:20:49 INFO executor.Executor: Running task ID 5
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Starting task 0.0:6 as TID 6 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Serialized task 0.0:6 as 2171 bytes in 0 ms
14/09/21 18:20:49 INFO executor.Executor: Running task ID 6
14/09/21 18:20:49 INFO scheduler.DAGScheduler: Completed ResultTask(0, 2)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Finished TID 2 in 1719 ms on localhost (progress: 3/147)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Starting task 0.0:7 as TID 7 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Serialized task 0.0:7 as 2171 bytes in 1 ms
14/09/21 18:20:49 INFO executor.Executor: Running task ID 7
14/09/21 18:20:49 INFO scheduler.DAGScheduler: Completed ResultTask(0, 1)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Finished TID 1 in 1727 ms on localhost (progress: 4/147)
14/09/21 18:20:49 INFO executor.Executor: Serialized size of result for 6 is 574
14/09/21 18:20:49 INFO executor.Executor: Sending result for 6 directly to driver
14/09/21 18:20:49 INFO executor.Executor: Finished task ID 6
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Starting task 0.0:8 as TID 8 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Serialized task 0.0:8 as 2171 bytes in 1 ms
14/09/21 18:20:49 INFO executor.Executor: Running task ID 8
14/09/21 18:20:49 INFO scheduler.DAGScheduler: Completed ResultTask(0, 6)
14/09/21 18:20:49 INFO scheduler.TaskSetManager: Finished TID 6 in 221 ms on localhost (progress: 5/147)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 7 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 7 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 7
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:9 as TID 9 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:9 as 2171 bytes in 0 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 9
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 7)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 7 in 281 ms on localhost (progress: 6/147)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 5 is 574
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 4 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 5 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Sending result for 4 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 5
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 4
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:10 as TID 10 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:10 as 2171 bytes in 1 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 10
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 5 in 499 ms on localhost (progress: 7/147)
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 5)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:11 as TID 11 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:11 as 2171 bytes in 0 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 11
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 4)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 4 in 513 ms on localhost (progress: 8/147)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 8 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 8 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 8
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:12 as TID 12 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:12 as 2171 bytes in 2 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 12
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 8)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 8 in 290 ms on localhost (progress: 9/147)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 9 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 9 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 9
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:13 as TID 13 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:13 as 2171 bytes in 0 ms
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 9)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 9 in 282 ms on localhost (progress: 10/147)
14/09/21 18:20:50 INFO executor.Executor: Running task ID 13
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 11 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 11 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 11
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:14 as TID 14 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:14 as 2171 bytes in 0 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 14
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 11 in 289 ms on localhost (progress: 11/147)
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 11)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 13 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 13 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 13
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:15 as TID 15 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:15 as 2171 bytes in 0 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 15
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 13)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 13 in 275 ms on localhost (progress: 12/147)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 10 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 10 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 10
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:16 as TID 16 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:16 as 2171 bytes in 1 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 16
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 10)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 10 in 499 ms on localhost (progress: 13/147)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 15 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 15 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 15
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:17 as TID 17 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:17 as 2171 bytes in 1 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 17
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 15 in 282 ms on localhost (progress: 14/147)
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 15)
14/09/21 18:20:50 INFO executor.Executor: Serialized size of result for 16 is 574
14/09/21 18:20:50 INFO executor.Executor: Sending result for 16 directly to driver
14/09/21 18:20:50 INFO executor.Executor: Finished task ID 16
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Starting task 0.0:18 as TID 18 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Serialized task 0.0:18 as 2171 bytes in 0 ms
14/09/21 18:20:50 INFO executor.Executor: Running task ID 18
14/09/21 18:20:50 INFO scheduler.DAGScheduler: Completed ResultTask(0, 16)
14/09/21 18:20:50 INFO scheduler.TaskSetManager: Finished TID 16 in 219 ms on localhost (progress: 15/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 12 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 12 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 12
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:19 as TID 19 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:19 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 19
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 12)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 12 in 793 ms on localhost (progress: 16/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 18 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 18 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 18
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:20 as TID 20 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:20 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 20
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 18)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 18 in 193 ms on localhost (progress: 17/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 17 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 17 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 17
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:21 as TID 21 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:21 as 2171 bytes in 1 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 21
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 17 in 283 ms on localhost (progress: 18/147)
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 17)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 19 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 19 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 19
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:22 as TID 22 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:22 as 2171 bytes in 1 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 22
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 19)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 19 in 279 ms on localhost (progress: 19/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 20 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 20 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 20
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:23 as TID 23 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:23 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 23
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 20)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 20 in 280 ms on localhost (progress: 20/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 21 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 21 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 21
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:24 as TID 24 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:24 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 24
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 21)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 21 in 281 ms on localhost (progress: 21/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 22 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 22 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 22
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:25 as TID 25 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:25 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 25
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 22 in 277 ms on localhost (progress: 22/147)
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 22)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 23 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 23 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 23
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:26 as TID 26 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:26 as 2171 bytes in 1 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 26
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 23)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 23 in 275 ms on localhost (progress: 23/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 24 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 24 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 24
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:27 as TID 27 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:27 as 2171 bytes in 1 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 27
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 24)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 24 in 288 ms on localhost (progress: 24/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 25 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 25 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 25
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:28 as TID 28 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:28 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 28
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 25)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 25 in 282 ms on localhost (progress: 25/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 27 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 27 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 27
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:29 as TID 29 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:29 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 29
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 27)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 27 in 256 ms on localhost (progress: 26/147)
14/09/21 18:20:51 INFO executor.Executor: Serialized size of result for 26 is 574
14/09/21 18:20:51 INFO executor.Executor: Sending result for 26 directly to driver
14/09/21 18:20:51 INFO executor.Executor: Finished task ID 26
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Starting task 0.0:30 as TID 30 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Serialized task 0.0:30 as 2171 bytes in 0 ms
14/09/21 18:20:51 INFO executor.Executor: Running task ID 30
14/09/21 18:20:51 INFO scheduler.TaskSetManager: Finished TID 26 in 277 ms on localhost (progress: 27/147)
14/09/21 18:20:51 INFO scheduler.DAGScheduler: Completed ResultTask(0, 26)
14/09/21 18:20:53 INFO executor.Executor: Serialized size of result for 14 is 574
14/09/21 18:20:53 INFO executor.Executor: Sending result for 14 directly to driver
14/09/21 18:20:53 INFO executor.Executor: Finished task ID 14
14/09/21 18:20:53 INFO scheduler.TaskSetManager: Starting task 0.0:31 as TID 31 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:20:53 INFO scheduler.TaskSetManager: Serialized task 0.0:31 as 2171 bytes in 0 ms
14/09/21 18:20:53 INFO executor.Executor: Running task ID 31
14/09/21 18:20:53 INFO scheduler.DAGScheduler: Completed ResultTask(0, 14)
14/09/21 18:20:53 INFO scheduler.TaskSetManager: Finished TID 14 in 3225 ms on localhost (progress: 28/147)
14/09/21 18:21:03 INFO executor.Executor: Serialized size of result for 28 is 676
14/09/21 18:21:03 INFO executor.Executor: Sending result for 28 directly to driver
14/09/21 18:21:03 INFO executor.Executor: Finished task ID 28
14/09/21 18:21:03 INFO scheduler.TaskSetManager: Starting task 0.0:32 as TID 32 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:21:03 INFO scheduler.TaskSetManager: Serialized task 0.0:32 as 2171 bytes in 0 ms
14/09/21 18:21:03 INFO executor.Executor: Running task ID 32
14/09/21 18:21:03 INFO scheduler.TaskSetManager: Finished TID 28 in 11974 ms on localhost (progress: 29/147)
14/09/21 18:21:03 INFO scheduler.DAGScheduler: Completed ResultTask(0, 28)
14/09/21 18:22:13 INFO executor.Executor: Serialized size of result for 31 is 676
14/09/21 18:22:13 INFO executor.Executor: Sending result for 31 directly to driver
14/09/21 18:22:13 INFO executor.Executor: Finished task ID 31
14/09/21 18:22:13 INFO scheduler.TaskSetManager: Starting task 0.0:33 as TID 33 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:13 INFO scheduler.TaskSetManager: Serialized task 0.0:33 as 2171 bytes in 0 ms
14/09/21 18:22:13 INFO executor.Executor: Running task ID 33
14/09/21 18:22:13 INFO scheduler.DAGScheduler: Completed ResultTask(0, 31)
14/09/21 18:22:13 INFO scheduler.TaskSetManager: Finished TID 31 in 79486 ms on localhost (progress: 30/147)
14/09/21 18:22:21 INFO executor.Executor: Serialized size of result for 29 is 676
14/09/21 18:22:21 INFO executor.Executor: Sending result for 29 directly to driver
14/09/21 18:22:21 INFO executor.Executor: Finished task ID 29
14/09/21 18:22:21 INFO scheduler.TaskSetManager: Starting task 0.0:34 as TID 34 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:21 INFO scheduler.TaskSetManager: Serialized task 0.0:34 as 2171 bytes in 0 ms
14/09/21 18:22:21 INFO executor.Executor: Running task ID 34
14/09/21 18:22:21 INFO scheduler.TaskSetManager: Finished TID 29 in 89976 ms on localhost (progress: 31/147)
14/09/21 18:22:21 INFO scheduler.DAGScheduler: Completed ResultTask(0, 29)
14/09/21 18:22:45 INFO executor.Executor: Serialized size of result for 30 is 676
14/09/21 18:22:45 INFO executor.Executor: Sending result for 30 directly to driver
14/09/21 18:22:45 INFO executor.Executor: Finished task ID 30
14/09/21 18:22:45 INFO scheduler.TaskSetManager: Starting task 0.0:35 as TID 35 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:45 INFO scheduler.TaskSetManager: Serialized task 0.0:35 as 2171 bytes in 1 ms
14/09/21 18:22:45 INFO executor.Executor: Running task ID 35
14/09/21 18:22:45 INFO scheduler.DAGScheduler: Completed ResultTask(0, 30)
14/09/21 18:22:45 INFO scheduler.TaskSetManager: Finished TID 30 in 113567 ms on localhost (progress: 32/147)
14/09/21 18:22:45 INFO executor.Executor: Serialized size of result for 35 is 574
14/09/21 18:22:45 INFO executor.Executor: Sending result for 35 directly to driver
14/09/21 18:22:45 INFO executor.Executor: Finished task ID 35
14/09/21 18:22:45 INFO scheduler.TaskSetManager: Starting task 0.0:36 as TID 36 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:45 INFO scheduler.TaskSetManager: Serialized task 0.0:36 as 2171 bytes in 1 ms
14/09/21 18:22:45 INFO executor.Executor: Running task ID 36
14/09/21 18:22:45 INFO scheduler.DAGScheduler: Completed ResultTask(0, 35)
14/09/21 18:22:45 INFO scheduler.TaskSetManager: Finished TID 35 in 332 ms on localhost (progress: 33/147)
14/09/21 18:22:46 INFO executor.Executor: Serialized size of result for 36 is 574
14/09/21 18:22:46 INFO executor.Executor: Sending result for 36 directly to driver
14/09/21 18:22:46 INFO executor.Executor: Finished task ID 36
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Starting task 0.0:37 as TID 37 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Serialized task 0.0:37 as 2171 bytes in 1 ms
14/09/21 18:22:46 INFO executor.Executor: Running task ID 37
14/09/21 18:22:46 INFO scheduler.DAGScheduler: Completed ResultTask(0, 36)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Finished TID 36 in 287 ms on localhost (progress: 34/147)
14/09/21 18:22:46 INFO executor.Executor: Serialized size of result for 37 is 574
14/09/21 18:22:46 INFO executor.Executor: Sending result for 37 directly to driver
14/09/21 18:22:46 INFO executor.Executor: Finished task ID 37
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Starting task 0.0:38 as TID 38 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Serialized task 0.0:38 as 2171 bytes in 1 ms
14/09/21 18:22:46 INFO executor.Executor: Running task ID 38
14/09/21 18:22:46 INFO scheduler.DAGScheduler: Completed ResultTask(0, 37)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Finished TID 37 in 254 ms on localhost (progress: 35/147)
14/09/21 18:22:46 INFO executor.Executor: Serialized size of result for 38 is 574
14/09/21 18:22:46 INFO executor.Executor: Sending result for 38 directly to driver
14/09/21 18:22:46 INFO executor.Executor: Finished task ID 38
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Starting task 0.0:39 as TID 39 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Serialized task 0.0:39 as 2171 bytes in 0 ms
14/09/21 18:22:46 INFO executor.Executor: Running task ID 39
14/09/21 18:22:46 INFO scheduler.DAGScheduler: Completed ResultTask(0, 38)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Finished TID 38 in 247 ms on localhost (progress: 36/147)
14/09/21 18:22:46 INFO executor.Executor: Serialized size of result for 39 is 574
14/09/21 18:22:46 INFO executor.Executor: Sending result for 39 directly to driver
14/09/21 18:22:46 INFO executor.Executor: Finished task ID 39
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Starting task 0.0:40 as TID 40 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Serialized task 0.0:40 as 2171 bytes in 0 ms
14/09/21 18:22:46 INFO executor.Executor: Running task ID 40
14/09/21 18:22:46 INFO scheduler.DAGScheduler: Completed ResultTask(0, 39)
14/09/21 18:22:46 INFO scheduler.TaskSetManager: Finished TID 39 in 280 ms on localhost (progress: 37/147)
14/09/21 18:22:47 INFO executor.Executor: Serialized size of result for 40 is 574
14/09/21 18:22:47 INFO executor.Executor: Sending result for 40 directly to driver
14/09/21 18:22:47 INFO executor.Executor: Finished task ID 40
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Starting task 0.0:41 as TID 41 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Serialized task 0.0:41 as 2171 bytes in 0 ms
14/09/21 18:22:47 INFO executor.Executor: Running task ID 41
14/09/21 18:22:47 INFO scheduler.DAGScheduler: Completed ResultTask(0, 40)
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Finished TID 40 in 276 ms on localhost (progress: 38/147)
14/09/21 18:22:47 INFO executor.Executor: Serialized size of result for 41 is 574
14/09/21 18:22:47 INFO executor.Executor: Sending result for 41 directly to driver
14/09/21 18:22:47 INFO executor.Executor: Finished task ID 41
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Starting task 0.0:42 as TID 42 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Serialized task 0.0:42 as 2171 bytes in 0 ms
14/09/21 18:22:47 INFO executor.Executor: Running task ID 42
14/09/21 18:22:47 INFO scheduler.DAGScheduler: Completed ResultTask(0, 41)
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Finished TID 41 in 280 ms on localhost (progress: 39/147)
14/09/21 18:22:47 INFO executor.Executor: Serialized size of result for 42 is 574
14/09/21 18:22:47 INFO executor.Executor: Sending result for 42 directly to driver
14/09/21 18:22:47 INFO executor.Executor: Finished task ID 42
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Starting task 0.0:43 as TID 43 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Serialized task 0.0:43 as 2171 bytes in 1 ms
14/09/21 18:22:47 INFO executor.Executor: Running task ID 43
14/09/21 18:22:47 INFO scheduler.DAGScheduler: Completed ResultTask(0, 42)
14/09/21 18:22:47 INFO scheduler.TaskSetManager: Finished TID 42 in 282 ms on localhost (progress: 40/147)
14/09/21 18:23:14 INFO executor.Executor: Serialized size of result for 43 is 676
14/09/21 18:23:14 INFO executor.Executor: Sending result for 43 directly to driver
14/09/21 18:23:14 INFO executor.Executor: Finished task ID 43
14/09/21 18:23:14 INFO scheduler.TaskSetManager: Starting task 0.0:44 as TID 44 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:23:14 INFO scheduler.TaskSetManager: Serialized task 0.0:44 as 2171 bytes in 1 ms
14/09/21 18:23:14 INFO executor.Executor: Running task ID 44
14/09/21 18:23:14 INFO scheduler.TaskSetManager: Finished TID 43 in 27014 ms on localhost (progress: 41/147)
14/09/21 18:23:14 INFO scheduler.DAGScheduler: Completed ResultTask(0, 43)
14/09/21 18:23:24 INFO executor.Executor: Serialized size of result for 34 is 676
14/09/21 18:23:24 INFO executor.Executor: Sending result for 34 directly to driver
14/09/21 18:23:24 INFO executor.Executor: Finished task ID 34
14/09/21 18:23:24 INFO scheduler.TaskSetManager: Starting task 0.0:45 as TID 45 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:23:24 INFO scheduler.TaskSetManager: Serialized task 0.0:45 as 2171 bytes in 0 ms
14/09/21 18:23:24 INFO executor.Executor: Running task ID 45
14/09/21 18:23:24 INFO scheduler.TaskSetManager: Finished TID 34 in 62063 ms on localhost (progress: 42/147)
14/09/21 18:23:24 INFO scheduler.DAGScheduler: Completed ResultTask(0, 34)
14/09/21 18:23:37 INFO executor.Executor: Serialized size of result for 32 is 676
14/09/21 18:23:37 INFO executor.Executor: Sending result for 32 directly to driver
14/09/21 18:23:37 INFO executor.Executor: Finished task ID 32
14/09/21 18:23:37 INFO scheduler.TaskSetManager: Starting task 0.0:46 as TID 46 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:23:37 INFO scheduler.TaskSetManager: Serialized task 0.0:46 as 2171 bytes in 0 ms
14/09/21 18:23:37 INFO executor.Executor: Running task ID 46
14/09/21 18:23:37 INFO scheduler.DAGScheduler: Completed ResultTask(0, 32)
14/09/21 18:23:37 INFO scheduler.TaskSetManager: Finished TID 32 in 154121 ms on localhost (progress: 43/147)

14/09/21 18:24:23 INFO executor.Executor: Serialized size of result for 45 is 676
14/09/21 18:24:23 INFO executor.Executor: Sending result for 45 directly to driver
14/09/21 18:24:23 INFO executor.Executor: Finished task ID 45
14/09/21 18:24:23 INFO scheduler.TaskSetManager: Starting task 0.0:47 as TID 47 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:24:23 INFO scheduler.TaskSetManager: Serialized task 0.0:47 as 2171 bytes in 1 ms
14/09/21 18:24:23 INFO executor.Executor: Running task ID 47
14/09/21 18:24:23 INFO scheduler.TaskSetManager: Finished TID 45 in 59237 ms on localhost (progress: 44/147)
14/09/21 18:24:23 INFO scheduler.DAGScheduler: Completed ResultTask(0, 45)
14/09/21 18:24:29 INFO executor.Executor: Serialized size of result for 46 is 676
14/09/21 18:24:29 INFO executor.Executor: Sending result for 46 directly to driver
14/09/21 18:24:29 INFO executor.Executor: Finished task ID 46
14/09/21 18:24:29 INFO scheduler.TaskSetManager: Starting task 0.0:48 as TID 48 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:24:29 INFO scheduler.TaskSetManager: Serialized task 0.0:48 as 2171 bytes in 0 ms
14/09/21 18:24:29 INFO executor.Executor: Running task ID 48
14/09/21 18:24:29 INFO scheduler.TaskSetManager: Finished TID 46 in 51135 ms on localhost (progress: 45/147)
14/09/21 18:24:29 INFO scheduler.DAGScheduler: Completed ResultTask(0, 46)
14/09/21 18:24:31 INFO executor.Executor: Serialized size of result for 44 is 676
14/09/21 18:24:31 INFO executor.Executor: Sending result for 44 directly to driver
14/09/21 18:24:31 INFO executor.Executor: Finished task ID 44
14/09/21 18:24:31 INFO scheduler.TaskSetManager: Starting task 0.0:49 as TID 49 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:24:31 INFO scheduler.TaskSetManager: Serialized task 0.0:49 as 2171 bytes in 1 ms
14/09/21 18:24:31 INFO executor.Executor: Running task ID 49
14/09/21 18:24:31 INFO scheduler.DAGScheduler: Completed ResultTask(0, 44)
14/09/21 18:24:31 INFO scheduler.TaskSetManager: Finished TID 44 in 76902 ms on localhost (progress: 46/147)
14/09/21 18:25:31 INFO executor.Executor: Serialized size of result for 47 is 676
14/09/21 18:25:31 INFO executor.Executor: Sending result for 47 directly to driver
14/09/21 18:25:31 INFO executor.Executor: Finished task ID 47
14/09/21 18:25:31 INFO scheduler.TaskSetManager: Starting task 0.0:50 as TID 50 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:25:31 INFO scheduler.TaskSetManager: Serialized task 0.0:50 as 2171 bytes in 0 ms
14/09/21 18:25:31 INFO executor.Executor: Running task ID 50
14/09/21 18:25:31 INFO scheduler.TaskSetManager: Finished TID 47 in 68273 ms on localhost (progress: 47/147)
14/09/21 18:25:31 INFO scheduler.DAGScheduler: Completed ResultTask(0, 47)
14/09/21 18:25:42 INFO executor.Executor: Serialized size of result for 48 is 676
14/09/21 18:25:42 INFO executor.Executor: Sending result for 48 directly to driver
14/09/21 18:25:42 INFO executor.Executor: Finished task ID 48
14/09/21 18:25:42 INFO scheduler.TaskSetManager: Starting task 0.0:51 as TID 51 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:25:42 INFO scheduler.TaskSetManager: Serialized task 0.0:51 as 2171 bytes in 0 ms
14/09/21 18:25:42 INFO executor.Executor: Running task ID 51
14/09/21 18:25:42 INFO scheduler.TaskSetManager: Finished TID 48 in 73247 ms on localhost (progress: 48/147)
14/09/21 18:25:42 INFO scheduler.DAGScheduler: Completed ResultTask(0, 48)
14/09/21 18:25:46 INFO executor.Executor: Serialized size of result for 49 is 676
14/09/21 18:25:46 INFO executor.Executor: Sending result for 49 directly to driver
14/09/21 18:25:46 INFO executor.Executor: Finished task ID 49
14/09/21 18:25:46 INFO scheduler.TaskSetManager: Starting task 0.0:52 as TID 52 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:25:46 INFO scheduler.TaskSetManager: Serialized task 0.0:52 as 2171 bytes in 0 ms
14/09/21 18:25:46 INFO executor.Executor: Running task ID 52
14/09/21 18:25:46 INFO scheduler.DAGScheduler: Completed ResultTask(0, 49)
14/09/21 18:25:46 INFO scheduler.TaskSetManager: Finished TID 49 in 74442 ms on localhost (progress: 49/147)
14/09/21 18:26:07 INFO executor.Executor: Serialized size of result for 33 is 676
14/09/21 18:26:07 INFO executor.Executor: Sending result for 33 directly to driver
14/09/21 18:26:07 INFO executor.Executor: Finished task ID 33
14/09/21 18:26:07 INFO scheduler.TaskSetManager: Starting task 0.0:53 as TID 53 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:26:07 INFO scheduler.TaskSetManager: Serialized task 0.0:53 as 2171 bytes in 0 ms
14/09/21 18:26:07 INFO executor.Executor: Running task ID 53
14/09/21 18:26:07 INFO scheduler.DAGScheduler: Completed ResultTask(0, 33)
14/09/21 18:26:07 INFO scheduler.TaskSetManager: Finished TID 33 in 234064 ms on localhost (progress: 50/147)

14/09/21 18:26:53 INFO executor.Executor: Serialized size of result for 50 is 676
14/09/21 18:26:53 INFO executor.Executor: Sending result for 50 directly to driver
14/09/21 18:26:53 INFO executor.Executor: Finished task ID 50
14/09/21 18:26:53 INFO scheduler.TaskSetManager: Starting task 0.0:54 as TID 54 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:26:53 INFO scheduler.TaskSetManager: Serialized task 0.0:54 as 2171 bytes in 1 ms
14/09/21 18:26:53 INFO executor.Executor: Running task ID 54
14/09/21 18:26:53 INFO scheduler.DAGScheduler: Completed ResultTask(0, 50)
14/09/21 18:26:53 INFO scheduler.TaskSetManager: Finished TID 50 in 81506 ms on localhost (progress: 51/147)
14/09/21 18:27:00 INFO executor.Executor: Serialized size of result for 52 is 676
14/09/21 18:27:00 INFO executor.Executor: Sending result for 52 directly to driver
14/09/21 18:27:00 INFO executor.Executor: Finished task ID 52
14/09/21 18:27:00 INFO scheduler.TaskSetManager: Starting task 0.0:55 as TID 55 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:27:00 INFO scheduler.TaskSetManager: Serialized task 0.0:55 as 2171 bytes in 0 ms
14/09/21 18:27:00 INFO executor.Executor: Running task ID 55
14/09/21 18:27:00 INFO scheduler.DAGScheduler: Completed ResultTask(0, 52)
14/09/21 18:27:00 INFO scheduler.TaskSetManager: Finished TID 52 in 73939 ms on localhost (progress: 52/147)
14/09/21 18:27:03 INFO executor.Executor: Serialized size of result for 51 is 676
14/09/21 18:27:03 INFO executor.Executor: Sending result for 51 directly to driver
14/09/21 18:27:03 INFO executor.Executor: Finished task ID 51
14/09/21 18:27:03 INFO scheduler.TaskSetManager: Starting task 0.0:56 as TID 56 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:27:03 INFO scheduler.TaskSetManager: Serialized task 0.0:56 as 2171 bytes in 1 ms
14/09/21 18:27:03 INFO executor.Executor: Running task ID 56
14/09/21 18:27:03 INFO scheduler.DAGScheduler: Completed ResultTask(0, 51)
14/09/21 18:27:03 INFO scheduler.TaskSetManager: Finished TID 51 in 81255 ms on localhost (progress: 53/147)
14/09/21 18:27:27 INFO executor.Executor: Serialized size of result for 53 is 676
14/09/21 18:27:27 INFO executor.Executor: Sending result for 53 directly to driver
14/09/21 18:27:27 INFO executor.Executor: Finished task ID 53
14/09/21 18:27:27 INFO scheduler.TaskSetManager: Starting task 0.0:57 as TID 57 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:27:27 INFO scheduler.TaskSetManager: Serialized task 0.0:57 as 2171 bytes in 0 ms
14/09/21 18:27:27 INFO executor.Executor: Running task ID 57
14/09/21 18:27:27 INFO scheduler.TaskSetManager: Finished TID 53 in 80577 ms on localhost (progress: 54/147)
14/09/21 18:27:27 INFO scheduler.DAGScheduler: Completed ResultTask(0, 53)
14/09/21 18:28:09 INFO executor.Executor: Serialized size of result for 54 is 676
14/09/21 18:28:09 INFO executor.Executor: Sending result for 54 directly to driver
14/09/21 18:28:09 INFO executor.Executor: Finished task ID 54
14/09/21 18:28:09 INFO scheduler.TaskSetManager: Starting task 0.0:58 as TID 58 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:28:09 INFO scheduler.TaskSetManager: Serialized task 0.0:58 as 2171 bytes in 0 ms
14/09/21 18:28:09 INFO executor.Executor: Running task ID 58
14/09/21 18:28:09 INFO scheduler.DAGScheduler: Completed ResultTask(0, 54)
14/09/21 18:28:09 INFO scheduler.TaskSetManager: Finished TID 54 in 76156 ms on localhost (progress: 55/147)
14/09/21 18:28:19 INFO executor.Executor: Serialized size of result for 55 is 676
14/09/21 18:28:19 INFO executor.Executor: Sending result for 55 directly to driver
14/09/21 18:28:19 INFO executor.Executor: Finished task ID 55
14/09/21 18:28:19 INFO scheduler.TaskSetManager: Starting task 0.0:59 as TID 59 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:28:19 INFO scheduler.TaskSetManager: Serialized task 0.0:59 as 2171 bytes in 0 ms
14/09/21 18:28:19 INFO executor.Executor: Running task ID 59
14/09/21 18:28:19 INFO scheduler.DAGScheduler: Completed ResultTask(0, 55)
14/09/21 18:28:19 INFO scheduler.TaskSetManager: Finished TID 55 in 79269 ms on localhost (progress: 56/147)
14/09/21 18:28:22 INFO executor.Executor: Serialized size of result for 56 is 676
14/09/21 18:28:22 INFO executor.Executor: Sending result for 56 directly to driver
14/09/21 18:28:22 INFO executor.Executor: Finished task ID 56
14/09/21 18:28:22 INFO scheduler.TaskSetManager: Starting task 0.0:60 as TID 60 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:28:22 INFO scheduler.TaskSetManager: Serialized task 0.0:60 as 2171 bytes in 0 ms
14/09/21 18:28:22 INFO executor.Executor: Running task ID 60
14/09/21 18:28:22 INFO scheduler.DAGScheduler: Completed ResultTask(0, 56)
14/09/21 18:28:22 INFO scheduler.TaskSetManager: Finished TID 56 in 79070 ms on localhost (progress: 57/147)
14/09/21 18:28:48 INFO executor.Executor: Serialized size of result for 57 is 676
14/09/21 18:28:48 INFO executor.Executor: Sending result for 57 directly to driver
14/09/21 18:28:48 INFO executor.Executor: Finished task ID 57
14/09/21 18:28:48 INFO scheduler.TaskSetManager: Starting task 0.0:61 as TID 61 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:28:48 INFO scheduler.TaskSetManager: Serialized task 0.0:61 as 2171 bytes in 0 ms
14/09/21 18:28:48 INFO executor.Executor: Running task ID 61
14/09/21 18:28:48 INFO scheduler.TaskSetManager: Finished TID 57 in 80250 ms on localhost (progress: 58/147)
14/09/21 18:28:48 INFO scheduler.DAGScheduler: Completed ResultTask(0, 57)
14/09/21 18:29:08 ERROR executor.Executor: Exception in task ID 59
com.google.api.client.googleapis.json.GoogleJsonResponseException: 500 Internal Server Error
{
  "code" : 500,
  "errors" : [ {
    "domain" : "global",
    "message" : "Internal Error",
    "reason" : "internalError"
  } ],
  "message" : "Internal Error"
}
        at com.google.api.client.googleapis.json.GoogleJsonResponseException.from(GoogleJsonResponseException.java:145)
        at com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:113)
        at com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:40)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest$1.interceptResponse(AbstractGoogleClientRequest.java:312)
        at com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1049)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:410)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:343)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:460)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
        at scala.Option.map(Option.scala:145)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.refresh(ReadsIterator.scala:48)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.hasNext(ReadsIterator.scala:67)
        at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
        at scala.collection.Iterator$class.foreach(Iterator.scala:727)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
        at scala.collection.TraversableOnce$class.reduceLeft(TraversableOnce.scala:172)
        at scala.collection.AbstractIterator.reduceLeft(Iterator.scala:1157)
        at org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:804)
        at org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:802)
        at org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
        at org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
        at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:111)
        at org.apache.spark.scheduler.Task.run(Task.scala:51)
        at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:183)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
14/09/21 18:29:08 INFO scheduler.TaskSetManager: Starting task 0.0:62 as TID 62 on executor localhost: localhost (PROCESS_LOCAL)
14/09/21 18:29:08 INFO scheduler.TaskSetManager: Serialized task 0.0:62 as 2171 bytes in 0 ms
14/09/21 18:29:08 INFO executor.Executor: Running task ID 62
14/09/21 18:29:08 WARN scheduler.TaskSetManager: Lost TID 59 (task 0.0:59)
14/09/21 18:29:08 WARN scheduler.TaskSetManager: Loss was due to com.google.api.client.googleapis.json.GoogleJsonResponseException
com.google.api.client.googleapis.json.GoogleJsonResponseException: 500 Internal Server Error
{
  "code" : 500,
  "errors" : [ {
    "domain" : "global",
    "message" : "Internal Error",
    "reason" : "internalError"
  } ],
  "message" : "Internal Error"
}
        at com.google.api.client.googleapis.json.GoogleJsonResponseException.from(GoogleJsonResponseException.java:145)
        at com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:113)
        at com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:40)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest$1.interceptResponse(AbstractGoogleClientRequest.java:312)
        at com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1049)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:410)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:343)
        at com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:460)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
        at scala.Option.map(Option.scala:145)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.refresh(ReadsIterator.scala:48)
        at com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.hasNext(ReadsIterator.scala:67)
        at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
        at scala.collection.Iterator$class.foreach(Iterator.scala:727)
        at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
        at scala.collection.TraversableOnce$class.reduceLeft(TraversableOnce.scala:172)
        at scala.collection.AbstractIterator.reduceLeft(Iterator.scala:1157)
        at org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:804)
        at org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:802)
        at org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
        at org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
        at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:111)
        at org.apache.spark.scheduler.Task.run(Task.scala:51)
        at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:183)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
14/09/21 18:29:08 ERROR scheduler.TaskSetManager: Task 0.0:59 failed 1 times; aborting job
14/09/21 18:29:08 INFO scheduler.TaskSchedulerImpl: Cancelling stage 0
14/09/21 18:29:08 INFO executor.Executor: Executor is trying to kill task 60
14/09/21 18:29:08 INFO executor.Executor: Executor is trying to kill task 61
14/09/21 18:29:08 INFO executor.Executor: Executor is trying to kill task 58
14/09/21 18:29:08 INFO executor.Executor: Executor is trying to kill task 62
14/09/21 18:29:08 INFO scheduler.TaskSchedulerImpl: Stage 0 was cancelled
14/09/21 18:29:08 INFO scheduler.DAGScheduler: Failed to run reduce at SearchReadsExample.scala:121
[error] (run-main-0) org.apache.spark.SparkException: Job aborted due to stage failure: Task 0.0:59 failed 1 times, most recent failure: Exception failure in TID 59 on host localhost: com.google.api.client.googleapis.json.GoogleJsonResponseException: 500 Internal Server Error
[error] {
[error]   "code" : 500,
[error]   "errors" : [ {
[error]     "domain" : "global",
[error]     "message" : "Internal Error",
[error]     "reason" : "internalError"
[error]   } ],
[error]   "message" : "Internal Error"
[error] }
[error]         com.google.api.client.googleapis.json.GoogleJsonResponseException.from(GoogleJsonResponseException.java:145)
[error]         com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:113)
[error]         com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:40)
[error]         com.google.api.client.googleapis.services.AbstractGoogleClientRequest$1.interceptResponse(AbstractGoogleClientRequest.java:312)
[error]         com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1049)
[error]         com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:410)
[error]         com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:343)
[error]         com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:460)
[error]         com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
[error]         com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
[error]         scala.Option.map(Option.scala:145)
[error]         com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.refresh(ReadsIterator.scala:48)
[error]         com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.hasNext(ReadsIterator.scala:67)
[error]         scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
[error]         scala.collection.Iterator$class.foreach(Iterator.scala:727)
[error]         scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
[error]         scala.collection.TraversableOnce$class.reduceLeft(TraversableOnce.scala:172)
[error]         scala.collection.AbstractIterator.reduceLeft(Iterator.scala:1157)
[error]         org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:804)
[error]         org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:802)
[error]         org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
[error]         org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
[error]         org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:111)
[error]         org.apache.spark.scheduler.Task.run(Task.scala:51)
[error]         org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:183)
[error]         java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[error]         java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[error]         java.lang.Thread.run(Thread.java:745)
[error] Driver stacktrace:
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0.0:59 failed 1 times, most recent failure: Exception failure in TID 59 on host localhost: com.google.api.client.googleapis.json.GoogleJsonResponseException: 500 Internal Server Error
{
  "code" : 500,
  "errors" : [ {
    "domain" : "global",
    "message" : "Internal Error",
    "reason" : "internalError"
  } ],
  "message" : "Internal Error"
}
        com.google.api.client.googleapis.json.GoogleJsonResponseException.from(GoogleJsonResponseException.java:145)
        com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:113)
        com.google.api.client.googleapis.services.json.AbstractGoogleJsonClientRequest.newExceptionOnError(AbstractGoogleJsonClientRequest.java:40)
        com.google.api.client.googleapis.services.AbstractGoogleClientRequest$1.interceptResponse(AbstractGoogleClientRequest.java:312)
        com.google.api.client.http.HttpRequest.execute(HttpRequest.java:1049)
        com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:410)
        com.google.api.client.googleapis.services.AbstractGoogleClientRequest.executeUnparsed(AbstractGoogleClientRequest.java:343)
        com.google.api.client.googleapis.services.AbstractGoogleClientRequest.execute(AbstractGoogleClientRequest.java:460)
        com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
        com.google.cloud.genomics.spark.examples.rdd.ReadsIterator$$anonfun$refresh$2.apply(ReadsIterator.scala:48)
        scala.Option.map(Option.scala:145)
        com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.refresh(ReadsIterator.scala:48)
        com.google.cloud.genomics.spark.examples.rdd.ReadsIterator.hasNext(ReadsIterator.scala:67)
        scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:327)
        scala.collection.Iterator$class.foreach(Iterator.scala:727)
        scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
        scala.collection.TraversableOnce$class.reduceLeft(TraversableOnce.scala:172)
        scala.collection.AbstractIterator.reduceLeft(Iterator.scala:1157)
        org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:804)
        org.apache.spark.rdd.RDD$$anonfun$18.apply(RDD.scala:802)
        org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
        org.apache.spark.SparkContext$$anonfun$23.apply(SparkContext.scala:1119)
        org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:111)
        org.apache.spark.scheduler.Task.run(Task.scala:51)
        org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:183)
        java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        java.lang.Thread.run(Thread.java:745)
Driver stacktrace:
        at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1049)
        at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1033)
        at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1031)
        at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
        at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
        at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1031)
        at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:635)
        at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:635)
        at scala.Option.foreach(Option.scala:236)
        at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:635)
        at org.apache.spark.scheduler.DAGSchedulerEventProcessActor$$anonfun$receive$2.applyOrElse(DAGScheduler.scala:1234)
        at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498)
        at akka.actor.ActorCell.invoke(ActorCell.scala:456)
        at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
        at akka.dispatch.Mailbox.run(Mailbox.scala:219)
        at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:386)
        at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
        at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
        at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
        at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
[trace] Stack trace suppressed: run last *:run for the full output.
14/09/21 18:29:08 ERROR util.Utils: Uncaught exception in thread SparkListenerBus
java.lang.InterruptedException
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:998)
        at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
        at java.util.concurrent.Semaphore.acquire(Semaphore.java:312)
        at org.apache.spark.scheduler.LiveListenerBus$$anon$1$$anonfun$run$1.apply$mcV$sp(LiveListenerBus.scala:48)
        at org.apache.spark.scheduler.LiveListenerBus$$anon$1$$anonfun$run$1.apply(LiveListenerBus.scala:47)
        at org.apache.spark.scheduler.LiveListenerBus$$anon$1$$anonfun$run$1.apply(LiveListenerBus.scala:47)
        at org.apache.spark.util.Utils$.logUncaughtExceptions(Utils.scala:1160)
        at org.apache.spark.scheduler.LiveListenerBus$$anon$1.run(LiveListenerBus.scala:46)
14/09/21 18:29:08 ERROR spark.ContextCleaner: Error in cleaning thread
java.lang.InterruptedException
        at java.lang.Object.wait(Native Method)
        at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:142)
        at org.apache.spark.ContextCleaner$$anonfun$org$apache$spark$ContextCleaner$$keepCleaning$1.apply$mcV$sp(ContextCleaner.scala:117)
        at org.apache.spark.ContextCleaner$$anonfun$org$apache$spark$ContextCleaner$$keepCleaning$1.apply(ContextCleaner.scala:115)
        at org.apache.spark.ContextCleaner$$anonfun$org$apache$spark$ContextCleaner$$keepCleaning$1.apply(ContextCleaner.scala:115)
        at org.apache.spark.util.Utils$.logUncaughtExceptions(Utils.scala:1160)
        at org.apache.spark.ContextCleaner.org$apache$spark$ContextCleaner$$keepCleaning(ContextCleaner.scala:114)
        at org.apache.spark.ContextCleaner$$anon$3.run(ContextCleaner.scala:65)
14/09/21 18:29:08 INFO network.ConnectionManager: Selector thread was interrupted!
java.lang.RuntimeException: Nonzero exit code: 1
        at scala.sys.package$.error(package.scala:27)
[trace] Stack trace suppressed: run last compile:run for the full output.
[error] (compile:run) Nonzero exit code: 1
[error] Total time: 506 s, completed Sep 21, 2014 6:29:08 PM
$
```