Re: Restore from checkpoint

2024-05-19 Thread Jinzhong Li
Hi Phil, I think you can use the "-s :checkpointMetaDataPath" arg to resume the job from a retained checkpoint[1]. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/checkpoints/#resuming-from-a-retained-checkpoint Best, Jinzhong Li On Mon, May 20, 2024 at 2:

Re: Question about time-based operators with RocksDB backend

2024-03-05 Thread Jinzhong Li
right out of the box [1]. [1] https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/state_backends/#setting-default-state-backend Best, Jinzhong Li On Tue, Mar 5, 2024 at 10:59 AM Zakelly Lan wrote: > Hi Gabriele, > > Quick answer: You can use the built-in window operat

Re: Disable flink old checkpoint clean

2023-11-07 Thread Jinzhong Li
Hi Yang, I think there is no configuration option available that allow users to disable checkpoint file cleanup at runtime. Does your flink application use incremental checkpoint? 1) If yes, i think leveraging S3's lifecycle management to clean checkpoint files is not safe, because it may acciden

Re: Is State TTL possible with event-time characteristics ?

2022-01-10 Thread jinzhong li
fault-tolerance/state/#state-time-to-live-ttl [4] https://flink.apache.org/2019/05/19/state-ttl.html Best regards, Jinzhong, Li On 2022/01/10 04:39:43 Dan Hill wrote: > Hi. Any updates on this? > > How do people usually do TTLs? I want to add a backup TTL in case I have > leaky state. &g

RE: State time to live

2022-01-09 Thread jinzhong li
during the compaction process of RocksDB. For more information, you can refer to this page: https://flink.apache.org/2019/05/19/state-ttl.html Best regards, Jinzhong, Li On 2022/01/09 08:41:08 Mariam Walid wrote: > Dear All, > > I am writing to inquire about the state time to live lazy r