https://community.databricks.com/t5/data-engineering/if-multiple-streams-as-jar-is-running-and-one-fail-will-it-fails/m-p/17898#M11817 <P>Hi Team, IHAC who is running multiple stream in the jar based job, one of the streams got terminated, but other streams are processing without termination.</P><P>Is this know behaviour in case of jar based streaming application? Any insight please?&nbsp;(edited)</P> Mon, 28 Jun 2021 07:46:28 GMT User16826994223 2021-06-28T07:46:28Z https://community.databricks.com/t5/data-engineering/if-multiple-streams-as-jar-is-running-and-one-fail-will-it-fails/m-p/17898#M11817 <P>Hi Team, IHAC who is running multiple stream in the jar based job, one of the streams got terminated, but other streams are processing without termination.</P><P>Is this know behaviour in case of jar based streaming application? Any insight please?&nbsp;(edited)</P> Mon, 28 Jun 2021 07:46:28 GMT https://community.databricks.com/t5/data-engineering/if-multiple-streams-as-jar-is-running-and-one-fail-will-it-fails/m-p/17898#M11817 User16826994223 2021-06-28T07:46:28Z https://community.databricks.com/t5/data-engineering/if-multiple-streams-as-jar-is-running-and-one-fail-will-it-fails/m-p/17899#M11818 <UL><LI>Failure in any of the active streaming queries causes the active run to fail and terminate all the other streaming queries. You do not need to use&nbsp; </LI></UL><PRE><CODE>streamingQuery.awaitTermination()or spark.streams.awaitAnyTermination()</CODE></PRE><P></P><UL><LI>&nbsp;at the end of your notebook. Jobs automatically prevent a run from completing when a streaming query is active.</LI></UL><P></P><P></P><P>But seems like You have to call the above two function to fail all streams</P> Mon, 28 Jun 2021 07:52:08 GMT https://community.databricks.com/t5/data-engineering/if-multiple-streams-as-jar-is-running-and-one-fail-will-it-fails/m-p/17899#M11818 User16826994223 2021-06-28T07:52:08Z