Shimin Huang
Shimin Huang
**2022 Plan1** - [x] 1. alluxio学习,包含概念、快速上手、与计算引擎整合等 - [x] 2. flink亚洲大会ppt学习 - [x] 产出一篇偏实践的Hudi实践公众号文章
supprot 1.13.x branch:feature_support_with_flink113x!
> 大佬,支持kudu1.10不,编译出错 支持的改下对应的kudu-client version就行
嗯嗯,目前flink1.13.x只兼容kudu1.12以上的版本,1.12以下的可以看下readMe去1.12的tag版本然后check pickly flink1.13增加的代码
>  flink版本1.13.5,用flink sql 创建catalog会出现这样的错误 看着像是依赖问题
不是flink1.13版本的吗,1.13这俩个被过期了的
>    在TableFactoryService里有这么一段判断,但我看这两个说移除了?在KuduCatalogFactory 重新加上后问题解决-。- 看了,这个flink1.13的tableService有些问题,他升级的catalogFactory提供了新的方法替代了这俩个过期的,但是tableFactoryService里却还是使用的旧的 
> 请问能提供一个基于sql 的kudu catalog创建示例吗? ```sql CREATE CATALOG catalog_name WITH (key1=val1, key2=val2, ...) ``` 这种语法硬就可以,with里的key可以看下`KuduCatalogFactory`这个类
> > 请问能提供一个基于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
support flink 1.13.x 