flink 版本视图不触发水印导致流阻塞的问题

[杨光跃 <ya...@163.com>]

 select a.card as card,a.cust as cust, b.city as city ,cast(a.ts as TIMESTAMP) ts,c.city
     from case3_TOPIC_A a
     left join cust_data FOR SYSTEM_TIME AS OF a.ts as b on a.cust = b.cust
     left join view_case3_TOPIC_B FOR SYSTEM_TIME AS OF a.ts as c on a.cust = c.cust;


view_case3_TOPIC_B  是一个版本视图，现在的问题是如果view_case3_TOPIC_B  的数据不更新，
case3_TOPIC_A 即使有新数据，也不往外输出。  
怎么才能做到 case3_TOPIC_A  有数据就会立马触发呢


| |
杨光跃
|
|
yangguangyuemail@163.com
|
签名由网易邮箱大师定制

Re: flink 版本视图不触发水印导致流阻塞的问题

[Terry Wang <zj...@gmail.com>]

Hi, 光跃~

 left join的语义下，case3_TOPIC_A有数据就会往外输出的，能否给一点更多的信息来帮助排查问题~

Best,
Terry Wang



> 2021年7月2日 下午3:14，杨光跃 <ya...@163.com> 写道：
> 
> select a.card as card,a.cust as cust, b.city as city ,cast(a.ts as TIMESTAMP) ts,c.city
>     from case3_TOPIC_A a
>     left join cust_data FOR SYSTEM_TIME AS OF a.ts as b on a.cust = b.cust
>     left join view_case3_TOPIC_B FOR SYSTEM_TIME AS OF a.ts as c on a.cust = c.cust;
> 
> 
> view_case3_TOPIC_B  是一个版本视图，现在的问题是如果view_case3_TOPIC_B  的数据不更新，
> case3_TOPIC_A 即使有新数据，也不往外输出。  
> 怎么才能做到 case3_TOPIC_A  有数据就会立马触发呢
> 
> 
> | |
> 杨光跃
> |
> |
> yangguangyuemail@163.com
> |
> 签名由网易邮箱大师定制