FlinkFlink1.12.0 FlinkSQL消费Kafka 使用 temporal join 关联维表Hive 最新分区数据 join 不上

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink1.12.0 FlinkSQL消费Kafka 使用 temporal join 关联维表Hive 最新分区数据 join 不上相关的知识,希望对你有一定的参考价值。


在这里插入图片描述

1.概述

2.场景1

2.1 概述

场景是这样的
Flink SQL 消费kafka 关联Hive维表 最新分区

刚开始 我往Hive维表里筛了 10条左右数据 运行Flink SQL 能输出结果 关联上

后面 我重新删除分区 重新往Hive 维表里筛了 6000多条数据 运行FLink SQL
竟然 关联不上 为什么呀?而且之前能关联上的 也关联不上 程序无报错

映射Kafka

CREATE TABLE hive.kafka.testtest (
    de STRING

以上是关于FlinkFlink1.12.0 FlinkSQL消费Kafka 使用 temporal join 关联维表Hive 最新分区数据 join 不上的主要内容,如果未能解决你的问题,请参考以下文章

KSQL与Flink SQL的比较

flink sql 知其所以然| sourcesink 原理

Flink学习之容错机制和状态一致性

Flink学习之容错机制和状态一致性

基于 Flink SQL CDC的实时数据同步方案