Re: K8s部署Flink 作业，无法在Web UI查看TaskManger的STDOUT日志

2022-03-02 文章 吴Janick
可以通过降低restratstrategy的统计灵敏度，短时间持续出现同个异常导致的failed只会计数一次，目前已经有相关patch，具体可看： https://issues.apache.org/jira/browse/FLINK-26315 > 2022年3月2日 下午4:35，Yang Wang > 写道： > > Standalone Flink on K8s 和 native K8s都会有你说的这个问题 >

Flink On K8s ???????? SSL????????

2022-03-02 文章 hjw
K8sk8s~/.kube/config.SSL??kubectl??k8s (kubectl get pod -n namespace ??)?? Flink: 1.13.6 ~/.kube/config apiVersion:v1 kind:config cluster: -name: "yf-dev-cluster1" cluster: server: "https://in-acp

Re:回复: Flink FailureRateRestartStrategy策略异常

2022-03-02 文章 janke
可以通过降低restratstrategy的统计灵敏度，短时间持续出现同个异常导致的failed只会计数一次，目前已经有相关patch，具体可看： https://issues.apache.org/jira/browse/FLINK-26315 在 2022-03-02 12:04:39，"刘 家锹" 写道： >你好，感谢回答我的疑问 > >我想我大概找到原因了，跟你说的一样。使用pipelined-region的failover策略，而作业本身切分了6个reion，在一次container失败当中就会全部失败。 >目前我们作业改为使用full的faio

退订

2022-03-02 文章 孙洪龙
退订

Re: 使用CUMULATE WINDOW 消费upsertkafka遇到的问题

2022-03-02 文章 Caizhi Weng
Hi！ window tvf 目前不支持消费 changelog，也就是说只能消费 insert 数据。upsert-kafka source 是一个会产生 changelog 的 source，因此下游不能接 window tvf。 赵旭晨 于2022年3月1日周二 15:23写道： > sql如下： > with effective_chargeorder as ( > select > o.recordcreatedtime,o.recordcreateduser,o.status,o._is_delete,o.appointmentid, > o.id,o.tenantid,

Re: K8s部署Flink 作业，无法在Web UI查看TaskManger的STDOUT日志

2022-03-02 文章 Yang Wang
Standalone Flink on K8s 和 native K8s都会有你说的这个问题 主要原因是标准输出打印到的pod console了，所以通过kubectl logs可以查看stdout日志，但webUI上就没有 你可以参考这个commit[1]自己编译一个Flink binary来实现 [1]. https://github.com/wangyang0918/flink/commit/2454b6daa2978f9ea9669435f92a9f2e78de357a Best, Yang xinzhuxiansheng 于2022年3月2日周三 15:00写道：