rg.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String；)Lorg

约定不等于承诺〃 2022-09-13 04:06 71阅读 0赞

# 情景
    如标题所示错误，是在做flink调试的时候报错的
    
    
    # 原因
    主要是maven依赖，版本不一致问题
    
    
    # 解决
    <properties>
            <java.version>11</java.version>
            <scala.version>2.11</scala.version>
            <guava.version>23.0</guava.version>
            <flink.version>1.13.2</flink.version>
            <async.client.version>2.10.4</async.client.version>
            <typesafe.config.version>1.3.3</typesafe.config.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.apache.flink</groupId>
                <artifactId>flink-connector-kafka_${scala.version}</artifactId>
                <version>${flink.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.flink</groupId>
                <artifactId>flink-streaming-java_${scala.version}</artifactId>
                <version>${flink.version}</version>
                <scope>provided</scope>
            </dependency>
            <dependency>
                <groupId>org.apache.flink</groupId>
                <artifactId>flink-clients_${scala.version}</artifactId>
                <version>${flink.version}</version>
                <scope>provided</scope>
            </dependency>
    
    
            
            <dependency>
                <groupId>ru.yandex.clickhouse</groupId>
                <artifactId>clickhouse-jdbc</artifactId>
                <version>0.1.54</version>
            </dependency>
            <dependency>
                <groupId>com.typesafe</groupId>
                <artifactId>config</artifactId>
                <version>${typesafe.config.version}</version>
            </dependency>
            <dependency>
                <groupId>com.google.guava</groupId>
                <artifactId>guava</artifactId>
                <version>${guava.version}</version>
            </dependency>
            <dependency>
                <groupId>org.asynchttpclient</groupId>
                <artifactId>async-http-client</artifactId>
                <version>${async.client.version}</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.flink</groupId>
                <artifactId>flink-connector-elasticsearch7_${scala.version}</artifactId>
                <version>${flink.version}</version>
            </dependency>
    
    
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

rg.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String；)Lorg

发表评论取消回复

还没有评论，来说两句吧...

相关阅读