-werners-
Esteemed Contributor III

A stream-stream left join needs a watermark.

f.e.:

stream_df = stream_df.withWatermark("timestamp_column", "30 minutes")
joined_df = stream_df.join(other_stream_df, "join_key")