时间戳

首页 > 解决方案 > 寻找 Flink RemoteStreamEnvironment 示例项目

apache-flink - 寻找 Flink RemoteStreamEnvironment 示例项目

问题描述

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

标签： apache-flinkflink-streaming

解决方案

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

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

并且运行时将使用本地或远程流执行环境，具体取决于 Flink 的启动方式（例如，如果在 IDE 中，您将获得本地迷你集群，并且使用 CLI 或 REST api 可以直接提交一个作业到一个集群）。

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

推荐阅读