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
|
签名由网易邮箱大师定制