先编译正确后，再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"
+
