一、描述
执行flink代码 E2eExactlyOnceTestCase,报如下错误
Error:(29, 15) java: 无法访问com.esotericsoftware.kryo.Serializer
找不到com.esotericsoftware.kryo.Serializer的类文件
二、解决方法
添加kryo依赖,如下
<dependency>
<groupId>com.esotericsoftware.kryo</groupId>
<artifactId>kryo</artifactId>
<version>2.24.0</version>
</dependency>
具体参见flink pom文件
注意:本文归作者所有,未经作者允许,不得转载