你上面flink sql client 中的 ClassNotFound 异常，应该是你 flink cluster 没重启导致的 (你的 sql client 是重启了，但是cluster 应该没重启)。
API 测试是另外的问题？能 share 以下你的 API 测试代码吗？ Best, Jark On Mon, 2 Nov 2020 at 11:53, yangxusun9 <[email protected]> wrote: > 我在使用API的时候导入的依赖如下， > <dependencies> > > <dependency> > <groupId>org.apache.flink</groupId> > <artifactId>flink-clients_${scala.binary.version}</artifactId> > <version>${flink.version}</version> > </dependency> > <dependency> > <groupId>com.alibaba.ververica</groupId> > > <artifactId>flink-connector-mysql-cdc</artifactId> > <version>1.1.0</version> > </dependency> > </dependencies>， > 其中flink 版本是1.11.1，<scala.binary.version>2.11</scala.binary.version>, > *当我刚运行的时候是能读到数据的*，但是我一旦对mysql中的表执行了变更操作，程序就会抛出Encountered change event for > table test.order_info whose schema isn't known to this connector > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
