Hello,
I am running strucutred streaming pipeline with 5 models loaded using pyfunc.spark_udf. Lately we have been noticing very strange issue of tasks getting hanged and batch is taking very long time finishing its execution.
CPU utilization is around 90% and Memory utilization is steady.
Issue:
Configs:
DBR 15.4
Job Compute
1 driver and 4 workers
