Hello :),
I have noticed a regression in one of my job and I don't understand why.

%python
print("Hello 1")

def toto(df, _):
    print("Hello 2")

spark.readStream\
     .format("delta")\
      .load("/databricks-datasets/nyctaxi/tables/nyctaxi_yellow")\
     .writeStream\
     .foreachBatch(toto)\
     .trigger(availableNow=True)\
     .start()\
     .awaitTermination()

With a Legacy 15.3 DBR cluster, both prints are displayed.
With a Unity Catalog 15.3 cluster, only the first one is displayed.

But here is what I can find in "Standard error logs" : 

Streaming ForeachBatch worker Started batch 0 with DF id 61cb46fc-3c78-4647-9784-ac01...
Hello 2
Streaming ForeachBatch worker Completed batch 0 with DF id 61cb46fc-3c78-4647-9784-ac01.....
ERROR: Query termination received for [id....

Same behavior for a df.show(2), the result is displayed in error logs.

Any idea why this is happening?

Thanks