正在寻找Flink RemoteStreamEnvironment示例项目

Question

我正在寻找一个示例项目，它将帮助我了解如何使用Flink RemoteStreamEnvironment api。有人链接到一个示例项目吗？

Answer 1

通常不需要使用RemoteStreamEnvironment或LocalStreamEnvironment。通常你可以做

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

运行时将使用本地或远程流执行环境，这取决于Flink的启动方式(例如，如果从IDE中获得本地迷你集群，并且使用CLI或RESTAPI，则可以直接向集群提交作业(。

但是，如果您想直接使用RemoteStreamEnvironment，您可以使用StreamExecutionEnvironment#createRemoteEnvironment(…(方法之一来创建远程执行环境，然后像使用其他方法一样使用该环境来设置作业图并执行作业。