Wink
Wink
at com.dlink.cdc.oracle.OracleCDCBuilder.build(OracleCDCBuilder.java:79) ~[dlink-client-1.15-0.6.7.jar:?] at com.dlink.trans.ddl.CreateCDCSourceOperation.build(CreateCDCSourceOperation.java:180) ~[dlink-executor-0.7.0.jar:?] 依赖没升级
1.Dinky 支持持久化的 Catalog 管理,无需 CREATE TABLE 语句。 2.Dinky 支持 FlinkSQL 行级权限。 3.其他欢迎讨论支持。
在创建整库同步时,目前阶段,dinky 没有元数据的校验。如果你报错了,还请贴下报错信息
后续会有相关支持
> dinky集群配置的配置文件路径也加下日志配置文件试试
那么还可能会有什么其他原因呢
> 看到 YarnGateway 的 initConfig() 方法里设置日志配置文件: YarnLogConfigUtil.setLogConfigFileInConfig(configuration, config.getClusterConfig().getFlinkConfigPath()); > > 而 KubernetesGateway 里没有,k8s是否也需要类似的配置吗 目前需要再跟踪下Flink源码了
可以测试环境试试dev,有数据源连接的优化
- [X] #1673
Hi. Why specify this parameter?