Re:flink-checkpoint 问题

我记得flink低版本有这个bug，会错误的删除某一个checkpoint的，你这个版本太老了，可以升级到新版本。 The following is the content of the forwarded email From："吴先生" <15951914...@163.com> To：user-zh Date：2024-01-10 17:54:42 Subject：flink-checkpoint 问题

Re:CUMULATE 窗口状态过大导致CK超时

HI Jiaotong： 我的建议如下： 1. 本地存储使用高吞吐的SSD 2. taskmanager.memory.managed.size 增加并且确保rocksdb memtable内存增加，减少rocksdb 刷磁盘的量 3. 如果有物化sink算子，关闭物化sink算子，减小state。 The following is the content of the forwarded email

(DISSCUSS) flink cli need load '--classpath' files

jar, So It seems a bug about the flink cli. Are you agree with me? Best,Ouywl

Re:Flink Web UI display nothing in k8s when use ingress

Hi lake:    Ok, Show the jobmanager pod logs, Can you see the jm pods is running ok? Try use cube-proxy, or NodePort, That you can see the webUI? Best,Ouywl On 03/4

When I use flink 1.9.1 and produce data to Kafka 1.1.1, The streamTask checkpoint error .

.run(Thread.java:748) Best,Ouywl

Re: [Question] How to use different filesystem between checkpointdata and user data sink

ouywl ou...@139.com

Re: [Question] How to use different filesystem between checkpointdata and user data sink

)" ouywl ou...@139.com On 12/19/2019 00:01，Piotr Nowojski wrote： Hi,As Yang Wang pointed out, you should use the new pl

[Question] How to use different filesystem between checkpoint data and user data sink

url https://ci.apache.org/projects/flink/flink-docs-stable/ops/filesystems/#pluggable-file-systems how to avoid use “Thread.currentThread().getContextClassLoader()" ouywl ou...@139.com

Re:flink 1.9 conflict jackson version

? ouywl ou...@139.com

Re: Flink on Kubernetes seems to ignore log4j.properties

.properties and logback-console.xml.

Re: Flink on Kubernetes seems to ignore log4j.properties

. ouywl

Re: [DISCUSS] Support configure remote flink jar

. ouywl ou...@139

Elasticsearch6UpsertTableSink how to trigger es delete index。

ete()  ouywl ou...@139.