kYarnSessionCli#applyDescriptorOptionToConfig"
based
on the cli option. If the "-d" is specified, "execution.attached" will be set
to false. Otherwise,
it is true.
Best,
Yang
魏烽 mailto:weif...@nequal.com>> 于2020年8月15日周六 下午10:51写道：
Hi
I try to set execution.attached: false in flink-conf.
Hi
I try to set execution.attached: false in flink-conf.yaml,but yarn logs is true
like this "2020-08-15 09:40:13,489 INFO
org.apache.flink.configuration.GlobalConfiguration - Loading configuration
property: execution.attached, true".Can you tell me why,I see the code the
default value is fals
Hi
I have a question when use flink sql 1.11.0
Error:
Exception in thread "main"
org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a
suitable table factory for 'org.apache.flink.table.delegation.ExecutorFactory'
in
the classpath.
Reason: No factory implement
if (jobID != null) {
sql_array.add(insert_sql)
drop_sql = drop_sql.replaceAll("tablename",
targetTableName).replaceAll("etlTaskId",etlTaskId)
sql_array.add(drop_sql)
//执行sql
SQLUtils.execSql(sql_array)
}
原始邮件
发件人: Chesnay Schepler
收件人: dev; 魏烽
发送时间: 2020年5月18日(周一) 14:5
Hello：
I have a question and I really want to ask everyone。
I submitted a flink batch processing task in DolphinShceduler. After the flink
task, the sql operation was performed. The sql operation failed, but the flink
task was successful. How can I solve this problem?
The code is roughly as foll
