无法使用 Flink Streaming 进行流式传输

Question

我是 Flink Streaming 框架的新手，我正在尝试了解组件和流程。我正在尝试使用 DataStream 运行基本的 wordcount 示例。我正在尝试在我的 IDE 上运行代码。当我使用集合提供数据时，代码运行没有问题

    DataStream<String> text = env.fromElements(
               "To be, or not to be,--that is the question:--",
               "Whether 'tis nobler in the mind to suffer",
                "The slings and arrows of outrageous fortune",z
               "Or to take arms against a sea of troubles,"
        );

但是，每次我尝试从套接字或文件读取数据时，它都会失败，如下所示：

DataStream<String> text = env.socketTextStream("localhost", 9999);
or
DataStream<String> text = env.readTextFile("sample_file.txt");

对于套接字和文本文件，我收到以下错误：

Exception in thread "main" java.lang.reflect.InaccessibleObjectException: Unable to make field private final byte[] java.lang.String.value accessible: module java.base does not "opens java.lang" to unnamed module

Answer 1

Flink 目前（截至 Flink 1.14）仅支持 Java 8 和 Java 11。安装合适的 JDK 并重试。