我写了flink作业来使用数据集和数据流api。我已经从同一个main()方法启动了这两个程序,但是现在当我将作业提交到flink dashboard时。只有datasetapi程序正在运行, Jmeter 板显示job get finished和流没有被触发,flink Jmeter 板也没有显示任何关于数据流执行的信息。但是当我从eclipse运行时,dataset和datastreamapi程序都在运行。有没有其他方法把工作提交给flink工作经理来完成这两项工作?。
我写了flink作业来使用数据集和数据流api。我已经从同一个main()方法启动了这两个程序,但是现在当我将作业提交到flink dashboard时。只有datasetapi程序正在运行, Jmeter 板显示job get finished和流没有被触发,flink Jmeter 板也没有显示任何关于数据流执行的信息。但是当我从eclipse运行时,dataset和datastreamapi程序都在运行。有没有其他方法把工作提交给flink工作经理来完成这两项工作?。
2条答案
按热度按时间yrdbyhpb1#
解决办法是把这两个程序分成不同的类,例如。
MyStreamingProgram
以及MyBatchProgram
,每个都有一个main
方法。然后,将每个程序分别提交给flink,以便创建两个独立的工作。你提到你观察到了行为上的一些变化,这取决于提交作业的方式。在引擎盖下,flink使用各种策略来执行
main
方法获取程序计划。在一次执行中产生大量的计划main
不支持(afaik)。5tmbdcev2#
除了使用web Jmeter 板,还可以使用命令行界面和restapi将作业提交给flink。
不过,听起来您可能正在尝试一个同时使用dataset和datastream API的flink作业。这行不通。