Stream-stream join using MongoDB sink

sowj02 — Mon, 03 Mar 2025 06:37:39 GMT

I am performing stream-to-stream join in Databricks using MongoDB as a source (readStream()). Both sources collections receive data at same time. Initially I tried with using watermarks

orderWithWatermark = order \

.selectExpr("order_id AS orderId","event_created AS orderWatermark","approved_date")\

.withWatermark("orderWatermark", "2 minutes")

orderstatusWithWatermark = orderstatus \

.selectExpr("order_id AS orderstatusId","event_created AS orderstatusWatermark","order_date","amount")\

.withWatermark("orderstatusWatermark", "2 minutes")

when i joined them

joined_df=orderWithWatermark.join(

orderstatusWithWatermark,

expr("""

orderId = orderstatusId AND

icb.icbWatermark >= ica.icaWatermark

"""))

and writing the joined_df using writestream to mongodb sink

I am facing an issue

[STREAM_FAILED] Query [id = 37bd39d7-dde1-4d19-8e9f-f4718c27dca4, runId = 735152c6-0398-46aa-b673-a46ac8fa1848] terminated with exception: true SQLSTATE: XXKST

I need help is there a recommended way to handle issue ?

Re: Stream-stream join using MongoDB sink

cgrant — Fri, 07 Mar 2025 17:00:57 GMT

There is not enough information in this high-level error message. Please expand the full stacktrace and feel free to post it here

topic Stream-stream join using MongoDB sink in Data Engineering

Stream-stream join using MongoDB sink

Re: Stream-stream join using MongoDB sink