Support Flink 1.13.x DynmicTableSource/Sink

[collabH]

No description provided.

[collabH]

supprot 1.13.x branch：feature_support_with_flink113x!

[duokaluo88]

大佬，支持kudu1.10不，编译出错

[collabH]

大佬，支持kudu1.10不，编译出错

支持的改下对应的kudu-client version就行

[duokaluo88]

刚试了下，还要将RowDataUpsertOperationMapper将newDeleteIgnore 改回newDelete

[collabH]

嗯嗯，目前flink1.13.x只兼容kudu1.12以上的版本，1.12以下的可以看下readMe去1.12的tag版本然后check pickly flink1.13增加的代码

[duokaluo88]

flink版本1.13.5，用flink sql 创建catalog会出现这样的错误

[collabH]

flink版本1.13.5，用flink sql 创建catalog会出现这样的错误

看着像是依赖问题

[duokaluo88]

在TableFactoryService里有这么一段判断，但我看这两个说移除了？在KuduCatalogFactory 重新加上后问题解决-。-

[collabH]

不是flink1.13版本的吗，1.13这俩个被过期了的

[collabH]

在TableFactoryService里有这么一段判断，但我看这两个说移除了？在KuduCatalogFactory 重新加上后问题解决-。-

看了，这个flink1.13的tableService有些问题，他升级的catalogFactory提供了新的方法替代了这俩个过期的，但是tableFactoryService里却还是使用的旧的

[Dkbei]

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

[collabH]

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

CREATE CATALOG catalog_name
  WITH (key1=val1, key2=val2, ...)

这种语法硬就可以，with里的key可以看下KuduCatalogFactory这个类

[collabH]

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

CREATE CATALOG catalog_name
  WITH (key1=val1, key2=val2, ...)

这种语法硬就可以，with里的key可以看下KuduCatalogFactory这个类

flink-connector-kudu/src/main/java/org/colloh/flink/kudu/connector/table/catalog/KuduCatalogFactory.java

Line 42 in 8aa9400

public class KuduCatalogFactory implements CatalogFactory {

[Dkbei]

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

CREATE CATALOG catalog_name
  WITH (key1=val1, key2=val2, ...)

这种语法硬就可以，with里的key可以看下KuduCatalogFactory这个类

flink-connector-kudu/src/main/java/org/colloh/flink/kudu/connector/table/catalog/KuduCatalogFactory.java

Line 42 in 8aa9400

public class KuduCatalogFactory implements CatalogFactory {

多谢，基于kudu1.10.0成功创建

[opoioa]

时态表无法关联
Exception in thread "main" org.apache.flink.table.api.ValidationException: Could not determine a type inference for lookup function 'default_catalog.default_database.kudu_source'. Lookup functions support regular type inference. However, for convenience, the output class can simply be a Row or RowData class in which case the input and output types are derived from the table's schema with default conversion.