Wink
Wink
目前perjob和application提交的任务自动重启后JobManager的地址和端口发生了变化就会无法监控。
这个需要通过远程调试的方式跟踪该接口来寻找问题
1.在推动中，#796。 2.目前通过flinkcdc原生配置来决定是整库迁移还是整库同步。 3.可视化构建任务是后续的内容。 4.目前支持向消息队列推送数据。
您好，请问只是单词 task 改为 job 吗？
嗯，Dinky 的 Task 概念不是 Flink Task.
> 应该是注释导致的，发布了一个无任何注释的flink sql，在运维中心能看到正常结果。 insert 前请不要加注释，这个bug将在0.6.7版本修复
> 你们的注释是什么格式 是 /**/ 这样的块注释 还是 **-- 注释信息** 这样的 注释 我目前写第二种注释 没有发现这个问题 写到;与insert关键字之间会有这个问题
非常感谢您指出的问题，这个问题在之前优化 DorisSinkBuilder 的时候进行了改进，存在不兼容的情况，以下有修复两种方式：
1.抽象类用 .startsWith("properties")，doris 重写这个 getProperties() ，doris的配置是 sink.sink.properties； 2.kafka 重写这个 getProperties()，kafka 的配置是 sink.properties。 两种方式都可，具体取决于 sink.sink.properties 和 sink.properties 哪种更普及。
您好，您的提议非常有意义。对于代码开发的 Flink Jar 任务确实更适合通过 CI/DI 的方式进行。目前我们也想实现这个方向，但是目前有限的精力主要放在了 sql 层的应用探索，心有余而力不足。不知您是否有兴趣来与我们交流和讨论该方向，从而推动其的设计与落地，非常感谢。