Hi, patricia.
Can you attach full stack about the exception. It seems the thread reading
source is stuck.
--
Best！
Xuyang
At 2023-11-23 16:18:21, "patricia lee" <[email protected]> wrote:
Hi,
Flink 1.18.0
Kafka Connector 3.0.1-1.18
Kafka v 3.2.4
JDK 17
I get error on class org.apache.flink.streaming.runtime.tasks.SourceStreamTask
on LegacySourceFunctionThread.run()
"java.util.concurrent.CompletableFuture@12d0b74 [Not completed, 1 dependents]
I am using the FlinkKafkaConsumer.
I dont get this error message on Flink 1.17.1 and JDK 11.
Because of the error, the consumed data does no longer enters my process
function.
Regards,
Pat
