Spongebob created FLINK-32274:
---------------------------------
Summary: kafka class could not be found while using appliction
mode.
Key: FLINK-32274
URL: https://issues.apache.org/jira/browse/FLINK-32274
Project: Flink
Issue Type: Bug
Components: Client / Job Submission
Affects Versions: 1.14.5
Reporter: Spongebob
While using yarn-application mode to submit my app, it would throw an
exception: `org.apache.kafka.common.config.ConfigException: Invalid value
org.apache.kafka.common.serialization.StringDeserializer for configuration
key.deserializer: Class
org.apache.kafka.common.serialization.StringDeserializer could not be found.` I
had defined KafkaProducer variation in my client code. And I think the
kafka-clients dependency was already uploaded while submitting the app.
But I found it is ok in per-job mode.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
