flink interval join 不同时间窗口计算结果相同问题

问题描述:

在10分钟时间范围与20分钟时间范围内的interval join操作所处理的数据存在一致性

需求：

有一条消费数据流，其中主要包含card_num和amount两个字段

需要输出：

card_num,

在10分钟时间段内累计的消费金额，

在20分钟时间段内累计的消费金额

当不同时间窗口得出的计算结果相同时，系统将默认依据某一特定窗口大小进行处理。

解决策略：

每隔10分钟生成一个窗口数据，并将其传输至kafka_table_1
每隔20分钟生成一个窗口数据，并将其传输至kafka_table_2
随后，将kafka_table_1与kafka_table_2进行基于时间间隔的连接操作

    -- source表
    CREATE TABLE source_table_9 (
      card_num STRING,
      ts BIGINT,
      mcou