we use KIS to read data from Kafka.
Quite likely Kafka was down and task
couldn’t read the data.
Following couple of messages keep repeating in a log file (attached):
Sent shutdown message to worker: andruid1.dev:8091, status 200 OK
Shutdown failed for index_kafka_supervisor-flink-02_539014b40b0359d_dmlalanb! Are you sure the task was running?
I wonder how I can ged rid of this message
e.g. clear the task from a queue.
how can I find out what happened with the task.
shutdown_failed_error.log (35 KB)