这个问题可能是由于Flink的库缓存导致的。Flink在启动时会从库缓存中加载所需的库,如果库缓存中存在旧的库版本,那么Flink就会使用这个旧的版本,而不是你配置的新版本。
你可以通过以下步骤来解决这个问题:
首先,你需要停止Flink的作业。
然后,你可以在Flink的配置文件中指定新的库版本。例如,如果你的Flink作业使用的是Java,那么你可以在
conf/flink-conf.yaml
文件中添加以下配置:
execution.library-cache.class : org.apache.flink.configuration.ExecutionOptions$LibraryCacheConfig#DISABLED
- 保存配置文件,然后重新启动Flink的作业。
这样,Flink就不会再从库缓存中加载库,而是直接从指定的库版本中加载。