Flink 监控
通过 Flink 插件，您可以监控并提交 Apache Flink 作业。
典型工作流程：
使用反映 Apache Flink 仪表板的专用工具窗口来监控 Flink 作业
连接到 Flink 服务器
在 Big Data Tools 窗口中，点击
并选择 Flink。在打开的 Big Data Tools 对话框中，指定连接参数：
名称 ：连接名称，用于在其他连接之间加以区分。
URL ：指定您的 Apache Flink 仪表板的 URL。
可选：您可以设置：
按项目 ：选择后，仅对当前项目启用这些连接设置。 如果希望此连接在其他项目中可见，请清除此复选框。
启用连接 ：如果要禁用此连接，请清除此复选框。 默认情况下，新建的连接处于启用状态。
启用隧道 ：创建到远程主机的 SSH 隧道。 如果目标服务器位于专用网络中，但可以通过该网络中的主机建立 SSH 连接，则这将非常有用。
选中该复选框并指定 SSH 连接的配置（点击 ... 以创建新的 SSH 配置）。
启用 HTTP 基本身份验证 ：使用指定用户名和密码进行 HTTP 身份验证的连接。
代理 ：选择是否使用 IDE 代理设置 ，或指定自定义代理设置。
填写完设置后，点击 测试连接 以确保所有配置参数均正确。 然后点击 确定。
与 Flink 服务器建立连接后，将显示 Flink 工具窗口，该窗口反映 Apache Flink 仪表板。
预览作业及其配置、异常和检查点。 使用 筛选器 字段按名称筛选作业，或点击 
按状态进行筛选。 如果有正在运行的作业，您可以点击 
将其终止。
查看运行您任务的节点，查看并下载其日志、 stdout 和线程转储。
查看作业管理器，查看并下载日志和 stdout。
查看已上传的 JAR 文件，按名称或入口类进行筛选，并 提交新的 Flink 作业。
提交新作业
在 Flink 工具窗口中，打开 提交新作业 选项卡。
如果您的应用程序的 JAR 文件尚未上传到 Flink 集群，请点击
并选择一个新文件。选择已上传的文件并点击
。在打开的 提交 JAR 文件 窗口中，配置以下参数：
允许未恢复的状态 ：允许跳过无法映射到新程序的保存点状态（等同于 allowNonRestoredState 选项）。
入口类 ：输入程序入口类。
程序参数 ：输入程序参数。
并行度 ：输入任务的并行度。 如果只需要一个任务实例，请将其留空。
保存点路径 ：输入作业执行状态镜像的路径（保存点）。
提交作业后，您可以在 作业 选项卡中预览其状态、开始时间及其他参数。