-
Bug
-
Resolution: Not a Bug
-
Major
-
None
-
None
-
None
If an exception was thrown during task execution, then Task stucks in running state.. We cannot detect failure and restart the task.
Expected result:
Task changes its state to failed just after exception been thrown.
Actual result:
Task remains in RUNNING state.
A little context what we are doing. We have an SMT which transforms the debezium connect record into our AVRO schema. When any message transformation failed we throw an exception and task.commit is called by postgres debezium connector to flush the latest LSN value to postgres. This is stuck in infinite loop and task remains in RUNNING state.
This is all happening in streaming mode