Apache Flink写入HBase仅RowKey生效，列值为空问题求助

以下是针对该问题的具体排查步骤：

• 检查HBase表结构匹配度
  Flink HBase Connector中，ROW类型字段名对应HBase的列族名，ROW子字段对应列族下的列名。你需要：

  1. 用HBase Shell执行describe 'test1'，确认存在名为persona_data的列族
  2. 确认该列族下支持动态列（HBase默认支持），或已提前创建age和name列
  3. 注意大小写匹配：HBase的列族、列名大小写敏感，必须和Flink表定义的persona_data、age、name完全一致

• 验证Kafka源表的数据读取有效性
  先确认kafka_source能正常读取到非Null的age和name值：

  1. 执行Flink SQL：SELECT age, name FROM kafka_source LIMIT 10;，查看输出结果
  2. 如果结果中age或name为Null，检查Kafka源表的格式定义（比如JSON解析规则、Avro Schema匹配度），确保字段映射正确

• 检查Flink表定义与Connector规范的一致性
  你的HBase表定义中，ROW类型的映射必须严格符合Connector要求：

  • 确保persona_data作为列族名，在HBase中存在且处于可写状态
  • 避免字段类型不匹配：比如Kafka源的age是String类型，但Flink表定义为INT，会导致转换后值为Null

• 查看Flink任务日志定位异常
  检查Flink TaskManager的日志文件，重点关注：

  • HBase写入相关的警告/错误（比如权限不足、ZooKeeper连接异常、列族元数据加载失败）
  • 字段转换失败的报错（比如类型不兼容导致的Null值）

• 简化逻辑做对比测试
  先跳过Kafka源，直接写入固定值到HBase，验证Connector本身是否正常：

  INSERT INTO hTable SELECT 3 as rowkey, ROW(25, 'test_user') as persona_data;
  

  如果该操作能成功写入列值，说明问题出在Kafka源的数据读取环节；如果仍失败，则聚焦排查HBase表结构或Connector配置

• 确认版本兼容性
  确保Flink版本与HBase 2.2 Connector版本兼容（比如Flink 1.13+适配HBase 2.2 Connector），版本不兼容可能导致字段映射逻辑异常

内容的提问来源于stack exchange，提问作者Aly Ayman