unexpected status when StageException occurred and can't stop the pipeline

asked 2019-04-14 20:12:39 -0500

Yingjun Li gravatar image

error message: com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to the Kafka broker: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

Sometimes, the pipepline turned into RUNNING_ERROR instead of RESTRY from RUNNING when above error occurred, i always can't stop or delete this pipeple except for restarting the service.

edit retag flag offensive close merge delete