实时计算 Flink版在一个jar里面执行了 tableEnv.会生成两个job吗?

实时计算 Flink版在一个jar里面执行了 tableEnv.executeSql 和 env.execute 会生成两个job吗?

flink restart策略自动重启job时会不会再执行一遍用户jar包里面的main函数?

有没有哪些同学知道flink restart策略自动重启job时会不会再执行一遍用户jar包里面的main函数?就是我以yarn-per-job模式提交了一个jar包执行flink任务,然后main函数肯定是在本地节点运行后再将整个job提交到yarn生成flink集群的,但是要是我这个flink任...

Flink CDC中写入es的job启动就报错了,我看jar包并没有缺失这个包

"Flink CDC中写入es的job启动就报错了,我看jar包并没有缺失这个包。我在两个服务器上起同样的job,一个不报错正常运行,一个报这个错,依赖的问题我也排查了,但是也没解决问题。"

flink per job不能够在同一jar包中执行两次main方法吗?

flink per job不能够在同一jar包中执行两次main方法吗?

问一下,海豚这个,能跑一个jar(含多个flink batch job)么

问一下,海豚这个,能跑一个jar(含多个flink batch job)么

提交的job有使用kafka自定义序列化器有用到第三方jar包,提交job的时候出现异常,有大佬帮

提交的job有使用kafka自定义序列化器有用到第三方jar包,提交job的时候出现异常,有大佬帮帮看看吗

我也有个问题,1.13.6的flink集群,在8081页面上传jar就直接报错,工程里面就一个job

我也有个问题,1.13.6的flink集群,在8081页面上传jar就直接报错,工程里面就一个job,本地运行好好的呀,怎么办?

WordCount中获取job对象和设置jar存储位置的代码是什么?

WordCount中获取job对象和设置jar存储位置的代码是什么?

hadoop2.4.1的" Job jar is not present"?报错

在我在两台装有hadoop的机器上运行hadoop 2.4.1自带的例子:hadoop-mapreduce-examples-2.4.1.jar时,报下面的错误:  [root@localhost hadoop-2.4.1]# hadoop jar ...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。