请教一个问题 flinksql 中 kafka 关联 多个 hbase 之后，有遇到过的吗？
请教一个问题 flinksql 中 kafka 关联 多个 hbase 之后，使用 Event Time Temporal Join 关联，然后我的kafka数据字段就变成null了 有遇到过的吗？from kafka_rcsp_label_table t1
left join hbase_mb_videomanage for system_time as of t1.procTime as t2
on t1.videoCode=t2.rowkey
left join hbase_mb6_page_bus for system_time as of t1.procTime as t3
on t1.mbk_usdf_evnt_id=t3.rowkey
写回答
-
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。根据您的描述，Flink SQL 使用 Event Time Temporal Join 关联多个 HBase 后，Kafka 数据的某个字段变为 null 的情况可能是由于在关联时处理时间或事件时间计算出现错误导致的。
首先，请确保您使用的 Kafka 和 HBase 数据源都是基于 Flink SQL 官方支持的数据源连接器，并且它们都已正确配置并可以正常工作。
其次，请仔细检查您的 Flink SQL 语句中涉及时间相关参数的部分，例如“for system_time as of t1.procTime”等，确保它们所引用的时间属性字段是在 Kafka 或 HBase 中实际存在的，并且其值是可以用于关联操作的。
另外，请检查您的 Flink SQL 语句中的 ON 子句，确保它所包含的关键字和操作符与 Flink SQL 的语法要求相符，避免因为语法错误导致的查询结果异常。
2023-11-06 13:40:43赞同 1 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
