解决flink run 提交任务成功，flink web ui 提交报错的问题_flink webui不能提交

作者：黑客灵魂 | 2024-08-07 08:11:04

踩

flink webui不能提交

问题：写了一个flink运行包，在命令行提交任务时可以执行成功，在flink web ui提交任务时，每次都执行报错。

原因：从命令行提交时查看日志可以发现提交一次任务，会出现两个jobId，也就是通过flink run命令行可以实现作业的拆分，而Flink Web UI并不提供这样的功能。也就是在代码中只能出现一次 StreamExecutionEnvironment 的execute方法，这样就不需要web ui进行拆分任务。

修改：问题点是这段代码被包含在了一个循环里，多次执行了execute方法，而web ui 无法拆分job

修改后代码：循环内不执行execute，在循环外后执行execute，保证一个环境只运行一次execute

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/黑客灵魂/article/detail/941652