The method endHeadOperatorInput(int) is undefined for the type OperatorChain

刘超 19天前 ⋅ 122 阅读   编辑

一、描述

  eclipse jdk1.8 flink1.10.1有如下错误

 

二、分析

  1、operatorChain的类型是org.apache.flink.streaming.runtime.tasks.OperatorChain,但flink-streaming-java_2.11-1.5.0的OperatorChain中没有endHeadOperatorInput方法,使用flink-streaming-java_2.11-1.10.1就可以了

三、解决方法

  引入依赖,如下

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.11</artifactId>
    <version>1.10.1</version>
</dependency>


注意:本文归作者所有,未经作者允许,不得转载

全部评论: 0

    我有话说: