Hey all,
we are currently migrating our Flink jobs from v1.9.1 to v1.10.1. The code
has been migrated as well as our Docker images (deploying on K8s using
standalone mode). Now an issue occurs if we use log4j2 and the Kafka
Appender which was working before. There are a lot of errors regarding
"Failed to load a file system via service" (NoClassDefFoundError) which
lead me searching in this direction. But as soon as I removed the Kafka
Appender config from log4j it is working again and all other exceptions
disappeared.
In the logs there is also an exception regarding Kafkas
"ByteArraySerializer Class could not be found". The Kafka Clients is still
stored within the lib/ directory but I think it is not loaded.

Any help would be appreciated. Thanks in advance.

Regards Thomas

Reply via email to