我正在尝试连接Flink与Cassandra。我正在从Github运行示例程序,但我得到以下错误:
main线程异常java.lang.NoSuchMethodError:org.apache.flink.streaming.api.datastream.DataStreamSink.name (Ljava/lang/String;) Lorg/apache/flink/流/api/datastream数据/DataStreamSink;在org.apache.flink.streaming.connectors.cassandra.CassandraSink CassandraPojoSinkBuilder.build美元(CassandraSink.java: 325)
NoSuchMethodError
通常表示版本不匹配。
您的程序是否针对与您试图在其上运行的群集相同的Flink版本进行编译?