我刚刚开始学习Apache Flink,并找到了在EClipse IDE中开始开发的指南链接。
我按照这个开始,但得到下面的错误
00:20:26 . 993 INFO org.apache.flink.api.java.ExecutionEnvironment -作业有0个注册类型和0个默认的Kryo序列化器java.lang.NoClassDefFoundError: scala/collection/Traversableat java.lang.ClassLoader.defineClass1(Native Method)
这里我放置了错误日志日志文件…如果你需要更多的细节,请告诉我。谢谢,Nyamath
zip。ZipException: invalid LOC header (bad signature)
Maven提供的Scala jar文件似乎已经损坏。请通过在命令行上从项目文件夹执行以下命令来更新Maven依赖项:
mvn -U clean install
在Eclipse中,右键单击项目并单击Update -> Maven dependencies。如果这不起作用,您需要删除.m2/repositories/
文件夹中损坏的Jar文件。