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
您好，我部署flink k8s session 模式集群，但是jobmanager总是自动重启，taskmanager报错如下：
fencing token not set: Ignoring message remoteFencedMessage ..sent to akka
tcp://flink@.because the fencing token is null.
请问这个是什么原因？
hello，
您好，打扰到大家了，我使用的是flink的dataset的API，多个数据集进行join，比如，a join b join
c，最终运行报错了，报错如下：
我是需要在join的时候指定JoinHint策略么，求助，真的很感谢！
| |
Eric Yang
|
|
ymj7...@163.com
|
签名由网易邮箱大师定制
