本地运行正常放到Flink跑状态是INITIALIZING，Failed to trigger checkpoints for job

       <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
       <flink.version>1.14.2</flink.version>
       <!--        <flink.version>1.13.1</flink.version>-->

       <scala.binary.version>2.11</scala.binary.version>
       <target.java.version>1.8</target.java.version>
       <maven.compiler.source>${target.java.version}</maven.compiler.source>
       <maven.compiler.target>${target.java.version}</maven.compiler.target>
       <slf4j.version>1.7.7</slf4j.version>
       <log4j.version>1.2.17</log4j.version>
       <lombok.version>1.18.6</lombok.version>
       <hutool.version>5.6.6</hutool.version>
       <fastjson.version>1.2.25</fastjson.version>
       <kafka.version>2.8.0</kafka.version>
       <mysql.version>8.0.32</mysql.version>
       <!--        <mysql.version>8.0.21</mysql.version>-->

       <gson.version>2.8.6</gson.version>
       <druid.version>1.2.13</druid.version>
       <slf4j-api.version>2.0.0</slf4j-api.version>
       <fastjson2.version>2.0.20</fastjson2.version>
       <drools.version>7.54.0.Final</drools.version>
       <guava.version>23.0</guava.version>

       <flink-mysql-cdc.version>2.3.0</flink-mysql-cdc.version>
       <!--        <flink-mysql-cdc.version>2.1.1</flink-mysql-cdc.version>-->

       <!--        <starrocks-connector.version>1.2.5_flink-1.13_2.12</starrocks-connector.version>-->
       <starrocks-connector.version>1.2.6_flink-1.14_2.12</starrocks-connector.version>
       <!--        <starrocks-connector.version>1.2.5_flink-1.14_2.12</starrocks-connector.version>-->
       <!--        <starrocks-connector.version>1.1.16_flink-1.13_2.12</starrocks-connector.version>-->
   </properties>

        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>${guava.version}</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>${slf4j.version}</version>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>${log4j.version}</version>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>${lombok.version}</version>
        </dependency>
        <!-- 可用组件 -->
        <dependency>
            <groupId>com.alibaba.fastjson2</groupId>
            <artifactId>fastjson2</artifactId>
            <version>${fastjson2.version}</version>
        </dependency>
        <!-- Apache Flink dependencies -->
        <!-- These dependencies are provided, because they should not be packaged into the JAR file. -->
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-java</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-clients_${scala.binary.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table-planner_${scala.binary.version}</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-table-common</artifactId>
            <version>${flink.version}</version>
        </dependency>
        <dependency>
            <groupId>com.ververica</groupId>
            <artifactId>flink-connector-mysql-cdc</artifactId>
            <version>${flink-mysql-cdc.version}</version>
        </dependency>
        <dependency>
            <groupId>com.starrocks</groupId>
            <artifactId>flink-connector-starrocks</artifactId>
            <version>${starrocks-connector.version}</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>${mysql.version}</version>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>${hutool.version}</version>
        </dependency>
    </dependencies>

pom (2).xml (10.1 KB) src.zip (21.7 KB)
附件是demo和pom

确认下flink和kafka的通信是否有问题