【发布时间】：2022-10-20 18:31:45
【问题描述】：
我有一个在计算机上运行的 Flink 服务器。 我想创建一个可以部署 SQL 的 Java Web 应用程序（Source create sql.., Sink create SQL.. and Insert into Sink select field1, ... from source table）
我了解 Table API 可用于执行 SQL。但我的问题是
- 如何使用 Table API 将上述 SQL 执行到远程 Flink Server。
- 使用时远程流环境，应用程序显示 Flink 的 /lib 文件夹中已经存在的 jar 丢失错误（flink-connector-kafka-1.15.2.jar、kafka-clients-3.1.0.jar、flink-table-common-1.15.2.罐）
当我实例化远程流环境如下所示StreamExecutionEnvironment remoteStreamEnvironment = RemoteStreamEnvironment.createRemoteEnvironment(flinkCluster, flinkClusterPort, user_Dir + "/flink-connector-kafka-1.15.2.jar", user_Dir + "/kafka-clients-3.1.0.jar", user_Dir + "/flink-table -common-1.15.2.jar");
我在这里做错了什么？当通过将这些 jars 添加到 Flink 的 lib 文件夹中删除第三个参数时。
提前致谢。
【问题讨论】：
标签： java apache-flink