先编译正确后,再debug
tangzhi8...@gmail.com 于2021年6月28日周一 下午3:02写道:
> 目的:想在本地环境IDEA远程调试Flink
> 步骤:
> 1.这是Debug的配置项
> 2.报错堆栈信息:
> org.apache.flink.client.program.ProgramInvocationException: The main
> method caused an error: Failed to execute job 'Streaming WordCount'.
> at
>
Hi
只要enable了checkpoint,一定会生成checkpoint的,这与你的运行模式无关。可以检查一下日志,看看JM端是否正常触发了checkpoint
祝好
唐云
From: casel.chen
Sent: Tuesday, June 29, 2021 9:55
To: user-zh@flink.apache.org
Subject: local运行模式下不会生成checkpoint吗?
我在本地使用local运行模式运行flink sql,将数据从kafka写到mongodb,mongodb
flink运行在原生k8s上,现在想要修改Root Logger Level和动态添加 Logger Name -> Logger
Level,以及用户可以传入自定义的日志模板,目前有办法做到么?
我定义了一个kafka来源的table,sql查询时调了自定义函数, 但是发现参数不能被正确传递给自定义函数eval.
我用的flink版本是1.10.0.
l json 的ddl如下:
private static final String personKafkaTable = "CREATE TABLE
hw_person_normal_t(\n"
+ " data ARRAY>,\n"
+ " key STRING,\n"
+ " operation STRING\n"
+ ") with (\n"
+