Re: flinkSQL join 表的历史信息保存在哪里保存多久

Wed, 11 Mar 2020 22:45:26 -0700 

应该是withIdleStateRetentionTime参数的配置时间。具体文档：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/query_configuration.html#idle-state-retention-time


在 2020/3/12 下午12:37，“wangl...@geekplus.com.cn”<wangl...@geekplus.com.cn> 写入:

    
    两个从 kafka 创建的表：
    
    tableA： key  valueA
    tableB： key  valueB 
    
    用 flink sql 提交job 运行： select  tableA.key, tableA.valueA，tableB.valueB from 
tableA join tableB on tableA.key = tableB.key;
    这两个表的历史数据在 flink 中存在哪里？存多久呢？
    
    比如我 tableA key1 先出现，很长时间以后（一个月）tableB key1 才出现，这时候还能 join 上吗？
     
    谢谢，
    王磊
    
    
    
    wangl...@geekplus.com.cn

回复