dubei

hi,I have the same problem, have you solved it?

hi，我也遇到了相同的问题，请问如何解决的呢？ @peaceliu123

请问能提供一个基于sql 的kudu catalog创建示例吗？

> > 请问能提供一个基于sql 的kudu catalog创建示例吗？ > > ```sql > CREATE CATALOG catalog_name > WITH (key1=val1, key2=val2, ...) > ``` > > 这种语法硬就可以，with里的key可以看下`KuduCatalogFactory`这个类 > > https://github.com/collabH/flink-connector-kudu/blob/8aa9400a4b239e4276891b21c7cad7a9cb58cf5c/src/main/java/org/colloh/flink/kudu/connector/table/catalog/KuduCatalogFactory.java#L42 多谢，基于kudu1.10.0成功创建

请问，feature_support_with_flink113x 分支版本还不支持DynmicTableSource/Sink 吧？

希望大佬能看到，并进行回复，如果解决这种问题呢？

> 具体报错的日志没发出来啊，SQL解析报错的语句是啥 [sql_parse.log](https://github.com/alibaba/canal/files/12842951/sql_parse.log) 大佬，日志中提示有多段错误，您看看

> 具体报错的日志没发出来啊，SQL解析报错的语句是啥 还有个问题大佬，版本canal-1.1.7-alpha-3，启动deployer后没有打开11112端口，不知道是不是bug，日志中没有任何相关的错误

> 具体报错的日志没发出来啊，SQL解析报错的语句是啥 > 还有个问题大佬，版本canal-1.1.7-alpha-3，启动deployer后没有打开11112端口，不知道是不是bug，日志中没有任何相关的错误 测试了，1.1.5 版本启动后正常打开了11112端口的