hi,
感谢详细的解释和回复。那问题就清楚了。之前我们的job提交框架里统一都使用了StreamExecutionEnvironment.execute(jobName)方法,现在基于这个解释就明白了。
在 2020-07-12 22:55:34,"godfrey he" 写道:
>hi sunfulin,
>
>1.11 对 StreamTableEnvironment.execute()
>和 StreamExecutionEnvironment.execute() 的执行方式有所调整,
>简单概述为:
>1.
hi sunfulin,
1.11 对 StreamTableEnvironment.execute()
和 StreamExecutionEnvironment.execute() 的执行方式有所调整,
简单概述为:
1. StreamTableEnvironment.execute() 只能执行 sqlUpdate 和 insertInto 方法执行作业;
2. Table 转化为 DataStream 后只能通过 StreamExecutionEnvironment.execute() 来执行作业;
3. 新引入的 TableEnvironment.executeSql() 和
HI, fulin
能大致贴下代码吗?能复现异常即可。简单说下这两个方法,
TableEnvironment.executeSql(String statement)是为了用于执行单条的 sql 语句, SQL语句可以是
DDL/DML/DCL/DQL, DML(如insert)和DQL(如select)的执行是等 Flink
job提交后返回该方法的执行结果,DDL(create table ...) 和 DCL(use database …)
的执行是对应的SQL语句执行完成就返回,理解起来就是需要提交 Flink job 的SQL需要等 job
hi,
我使用flink
1.11提交sql作业,从JM日志中看到有如下异常。我的作业里会通过tEnv.executeSQL执行多个ddl语句,通过tEnv.createStatementSet
add多个dml语句,并执行execute。
如下异常可能原因是啥呢?还有个问题,这个异常虽然抛出来了,但是作业还是正常启动执行了。这又是为何?是不是不推荐在作业里同时使用executeSQL和statementset.execute?
Caused by: org.apache.flink.util.FlinkRuntimeException: Cannot have more than