我正在尝试使用Google Pub/Sub连接器与Flink,请看这里。然而,我得到了 Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.google.cloud.pubsub.v1.stub.GrpcPublisherStub 我有连接器的依赖版本是1.9.0 <dependency>
<groupId>org.<
我正在尝试设置flink并运行一个集群,尽管我得到的输出似乎是集群启动了:Starting cluster.当我转到localhost:8081时,连接被拒绝,所以我检查了flink日志,在taskexecutor日志中,我看到了以下错误:
Error: Could not find or load mainclass org.apache.flink.runtime.taskexecutor.Ta