address how to use multiple spark streaming jobs connecting to one job cluster

Jin_Kim
New Contributor II

‎05-01-2022 10:37 PM

Hi,

We have a scenario where we need to deploy 15 spark streaming applications on databricks reading from kafka to single Job cluster.

We tried following approach:

1. create job 1 with new job cluster (C1)

2. create job2 pointing to C1

...

3. create job15 pointing to C1

But, the problem here is if the job 1 fails, it is terminating all the other 14 jobs.

One of the options we are thinking is to have a ***** kafka topic with no messages in it and ***** spark streaming job reading from ***** kafka topic (which will never fail 99.99%) which create new job cluster (C1) and rest of the 15 jobs will point to C1. We are assuming Job cluster C1 will never fail 99.99%.

Other solution we have is to create each job cluster for each job (15 Clusters for 15 jobs ) but it is going to kill our operational costs as it is continuous streaming job and some of topics have very less volume.

Could you please advice on how to address this issue.

Thanks

Jin.

Labels:

Hubert-Dudek
Databricks MVP

‎05-02-2022 12:14 AM

@Jin Kim​ ,

  • When you set tasks in a job, first put some ***** task and then every streaming as separated task depended on first (see image below how logic will look like) so there will be only one job,
  • Inside every streaming task, use spark.streams.awaitAnyTermination() to monitor it, and when failed to restart - custom logic,
  • redirect fail notifications messages to pagerduty or something to know that job is falling,
  • set maximum one concurrent job run and frequently run, like every 5 mins, so it will automatically run again when something fails.

image.png


My blog: https://databrickster.medium.com/

View solution in original post

Preview file
19 KB

Jin_Kim
New Contributor II

‎05-04-2022 02:53 AM

@Hubert Dudek​ , thanks a lot for responding.

  1. When we have setup like this, if one tasks fails, it will not terminate the entire job right?
  2. Since, the job is continously running as it is streaming app, is it possible to add new task to the job(while it is running)? We have around 100 kafka topics and each streaming app listens to only 1 topic.