I am trying to perform a data processing in flink with table API, taking data from kafka topics fed from debezium, the pipeline works correctly but after 3 days of processing it throws the error that the heartbeat is lost with the taskmanger.