大佬们，问下Flink CDC中有遇到过类似的情况的吗？flink 1.14.4版本使用hbase

Flink CDC 在使用过程中可能会遇到各种各样的问题，包括性能问题、稳定性问题、配置问题等等。为了更好地帮助您解决问题，需要您提供更具体的问题描述和错误信息。

基于您提供的信息，如果您在使用 Flink CDC 1.14.4 版本与 HBase 进行交互时遇到问题，可能是由于以下一些常见的原因导致的：

HBase 连接问题：在使用 Flink CDC 和 HBase 进行交互时，需要确保正确配置 HBase 的连接信息，包括 HBase 的 ZooKeeper 地址、端口号、HBase 表名等。如果连接信息配置不正确或者 HBase 服务不可用，则会导致 Flink CDC 无法正常读写数据。

HBase 表结构不一致：在使用 Flink CDC 从 HBase 中读取数据时，需要确保 Flink CDC 和 HBase 的表结构一致，包括表名、列族、列等。如果表结构不一致，则会导致 Flink CDC 无法正确读写数据。

并发度设置不合理：在 Flink CDC 的作业中，设置并发度是非常重要的，合理的并发度设置可以提高作业的性能和吞吐量。但是，如果并发度设置不合理，可能会导致作业的性能下降、任务卡顿等问题。

Flink CDC 配置问题：Flink CDC 有很多参数和配置项，需要根据实际情况进行配置和调整。如果配置不正确，可能会导致作业无法正常运行或者出现异常。

针对以上问题，您可以考虑采取以下措施进行排查和解决：

检查 HBase 的连接信息是否正确，确保 HBase 服务正常运行。

检查 Flink CDC 和 HBase 的表结构是否一致，确保 Flink CDC 可以正确读写数据。

调整 Flink CDC 的并发度设置，以提高作业的性能和吞吐量。

检查 Flink CDC 的配置参数是否正确，确保作业可以正常运行。

根据您提供的信息，Flink 1.14.4 版本中的 HBase SQL Connector 对于 Flink CDC 可能不受支持。目前，HBase SQL Connector 处于实验性阶段，可能有一些限制和局限性。

目前（截至我回答时），Flink CDC 目前主要支持以下数据源和连接器：

- MySQL - PostgreSQL - SQL Server - Oracle - Kafka

对于像文件系统、Hive 和 HBase 这样的数据源，Flink CDC 的官方文档中并没有明确说明是否支持。因此，可能无法直接使用 HBase SQL Connector 在 Flink CDC 中进行连接和操作。

解决这个问题的一个可能的方法是通过自定义 Flink 的 HBase Sink 将 CDC 数据写入 HBase。您可以编写自己的 Flink 程序，使用 Flink 提供的 HBase Sink Connector 将数据写入 HBase 表中。这将需要您编写代码来处理 CDC 数据，并将其转换为适合写入 HBase 的格式。

以下是伪代码示例，展示了如何在 Flink 中使用 HBase Sink 写入数据：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(1);

// 创建 CDC 数据源表
TableEnvironment tEnv = TableEnvironment.create(env);
tEnv.executeSql("CREATE TABLE cdc_source (field1 STRING, field2 INT) WITH (...)");
Table cdcTable = tEnv.from("cdc_source");

// 转换 CDC 数据为 HBase 格式
DataStream<Tuple2<Put, Integer>> hbaseData = cdcTable
    .select(...)
    .toAppendStream(Row.class)
    .map(new CDCDataToHBaseMapper());

// 将数据写入 HBase 表
hbaseData.addSink(new HBaseSinkFunction(...));

env.execute("CDC to HBase");

在上述代码中，您需要实现 CDCDataToHBaseMapper 类来将 CDC 数据转换为适合写入 HBase 的 Put 对象。然后，使用 HBaseSinkFunction 将数据写入 HBase 表。

请注意，上述代码示例只是一个概念演示，并非完整的工作示例。具体实现细节和配置取决于您的 CDC 数据格式、HBase 表结构以及 Flink 和 HBase 版本等因素

我也试过了，就不支持这些，我是1.15版本，就只支持mysql,kafka。像什么文件系统或者hive/hbase这些都不支持，此回答整理自钉群“Flink CDC 社区”