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

Posted 2021-05-16 九师兄

文章目录

• 1.概述
• 2.场景1
• • 2.1 概述
  • 2.2 解决

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