开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

请教一个问题 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

展开
收起
真的很搞笑 2023-11-06 12:03:19 63 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    根据您的描述,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 集群和引擎,提高作业开发运维效率。

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载