我有一个作业jar,它依赖于flink-json-1.7.2.jar,flink-table_2.11-1.7.2.jar。如果我将这两个jars文件添加到flink的lib文件夹中,它就可以在我的本地计算机上正常运行。我怎样才能在我的minikube集群上实现同样的效果。例如,将依赖项添加到flink。Ps。我已经按照this文档设置了我的minikube。 此外,我还可以看到在构建作业jar时创建的fat jar
在本地环境中,它工作正常,但是当我在EMR集群上部署这个Flink应用程序时,它会抛出一个与兼容性问题相关的异常。我得到的错误信息是
java.lang.RuntimeException: Could not load the TypeInformation for the class 'org.apache.hadoop.io.Writable我在POM依赖项中包含了flink-hadoop-compatibility-2.10 jar的maven依赖项。但它并没有发现它。我