Re: Re: flink-cdc-mysql 使用时遇到的问题

Sun, 01 Nov 2020 19:54:45 -0800 

我在使用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/

回复