回复：flink 1.13.0 中cumulate window 使用

2021-05-27 文章 范瑞 
Hello
请参考官网案例，需要使用 window tvf语法。


https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sql/queries/window-tvf/#cumulate


Best
fanrui



---原始邮件---
发件人: "邹云鹤"

回复：FS StateBackend 到 RocksDB StateBackend 状态恢复问题

2021-04-01 文章 范瑞 
Hi Lake:


目前的 Flink 版本应该都是不支持的，也就是说换了 StateBackend 不能正常恢复。Flink 1.13 做了这个事情，具体参考：FLIP41 和 
FLINK-20976


https://cwiki.apache.org/confluence/display/FLINK/FLIP-41%3A+Unify+Binary+format+for+Keyed+State


https://issues.apache.org/jira/browse/FLINK-2097


Best,
fanrui

---原始邮件---
发件人: "LakeShen"

回复：Re:Re: flink1.11.2写hive分区表，hive识别不到分区

2020-12-22 文章 范瑞 
Hello


请问是使用 Sql吧？开启cp了吗？



---原始邮件---
发件人: "kingdomad"

回复：请教设置uid的最佳实践

2020-11-25 文章 范瑞 
无状态算子可以不设置


Best
fanrui



---原始邮件---
发件人: "kingdomad"

回复：Flink反压定位算子

2020-11-01 文章 范瑞 
可能是某一个 C算子的某一个 subtask 的inPoolUsage 打满了。建议查看 subtask级别的 
Metric。从原理上分析，如果B反压严重，至少有某一个 C算子的一个 subtask 的inPoolUsage 打满了。希望对你有所帮助👏
祝好
fanrui



---原始邮件---
发件人: "赵一旦"

回复：Flink反压定位算子

2020-10-30 文章 范瑞 
Hi
可以查看所有 C 算子的 InPoolUsage 这个 Metric 来定位哪个 C有问题了。inPoolUsage高才会导致上游的 B反压
祝好🤞
fanrui



---原始邮件---
发件人: "赵一旦"