除了使用 Jmeter 板，如何提交flink作业？

jvidinwx 于 2021-06-25 发布在 Flink

关注(0)|答案(2)|浏览(342)

我写了flink作业来使用数据集和数据流api。我已经从同一个main（）方法启动了这两个程序，但是现在当我将作业提交到flink dashboard时。只有datasetapi程序正在运行， Jmeter 板显示job get finished和流没有被触发，flink Jmeter 板也没有显示任何关于数据流执行的信息。但是当我从eclipse运行时，dataset和datastreamapi程序都在运行。有没有其他方法把工作提交给flink工作经理来完成这两项工作？。

apache-flink flink-streaming

来源：https://stackoverflow.com/questions/45059622/how-to-submit-the-flink-job-other-than-using-their-dashboard

2条答案

按热度按时间

yrdbyhpb1#

解决办法是把这两个程序分成不同的类，例如。 MyStreamingProgram 以及 MyBatchProgram ，每个都有一个 main 方法。然后，将每个程序分别提交给flink，以便创建两个独立的工作。
你提到你观察到了行为上的一些变化，这取决于提交作业的方式。在引擎盖下，flink使用各种策略来执行 main 方法获取程序计划。在一次执行中产生大量的计划 main 不支持（afaik）。

赞(0）回复(0）举报 2021-06-25

5tmbdcev2#

除了使用web Jmeter 板，还可以使用命令行界面和restapi将作业提交给flink。
不过，听起来您可能正在尝试一个同时使用dataset和datastream API的flink作业。这行不通。

赞(0）回复(0）举报 2021-06-25