Re:Re: flink 1.11 sql作业提交JM报错

2020-07-13 文章 sunfulin
hi, 感谢详细的解释和回复。那问题就清楚了。之前我们的job提交框架里统一都使用了StreamExecutionEnvironment.execute(jobName)方法,现在基于这个解释就明白了。 在 2020-07-12 22:55:34,"godfrey he" 写道: >hi sunfulin, > >1.11 对 StreamTableEnvironment.execute() >和 StreamExecutionEnvironment.execute() 的执行方式有所调整, >简单概述为: >1.

Re: flink 1.11 sql作业提交JM报错

2020-07-12 文章 godfrey he
hi sunfulin, 1.11 对 StreamTableEnvironment.execute() 和 StreamExecutionEnvironment.execute() 的执行方式有所调整, 简单概述为: 1. StreamTableEnvironment.execute() 只能执行 sqlUpdate 和 insertInto 方法执行作业; 2. Table 转化为 DataStream 后只能通过 StreamExecutionEnvironment.execute() 来执行作业; 3. 新引入的 TableEnvironment.executeSql() 和

Re: flink 1.11 sql作业提交JM报错

2020-07-11 文章 Leonard Xu
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

flink 1.11 sql作业提交JM报错

2020-07-11 文章 sunfulin
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