Flink に問題がある
java.lang.NoSuchMethodError: org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo.getInfoFor(Lorg/apache/flink/api/common/typeinfo/TypeInformation;)Lorg/apache/flink/api/java/typeutils/ObjectArrayTypeInfo;
at LowLevel.FlinkImplementation.FlinkImplementation$$anon$6.<init>(FlinkImplementation.scala:28)
at LowLevel.FlinkImplementation.FlinkImplementation.<init>(FlinkImplementation.scala:28)
at IRLogic.GmqlServer.<init>(GmqlServer.scala:15)
at it.polimi.App$.main(App.scala:20)
at it.polimi.App.main(App.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
...
問題のある行はこれです
implicit val regionTypeInformation =
api.scala.createTypeInformation[FlinkDataTypes.FlinkRegionType]
FlinkRegionType
私はのArray
カスタムオブジェクトを持っています
IDE で maven プラグインを使用してアプリを開発しましたが、すべて正常に動作していますが、Web サイトからダウンロードしたバージョンに移行すると、上記のエラーが発生します
Flink 0.9 を使用しています
一部のライブラリが欠落しているのではないかと考えていましたが、すべてを処理するために maven を使用しています。さらに、 ObjectArrayTypeInfo.javaのコードを実行しても問題はないようです