Re: flink sink kafka from checkpoint run failed

我也遇到了 请问你解决了没 -- Sent from: http://apache-flink.147419.n8.nabble.com/

temporarily unavailable due to an ongoing leader election

flink1.12.2 on yarn 3.1.5 作业手动触发savepoint 成功 然后使用run -s 启动成功 但是访问flinkui 报service temporarily unavailable due to an ongoing leader election -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink1.12.2，interval join并没有 inProcessingTime() and inEventTime()

FLIP-134: Batch execution for the DataStream API Allow explicitly configuring time behaviour on KeyedStream.intervalJoin() FLINK-19479 Before Flink 1.12 the

flink1.12.2使用rocksdb状态后端，checkpoint size变大

452 COMPLETED 103/103 2021-04-22 17:29:12 2021-04-22 17:29:12 325ms 4.40 MB 0 B (5.39 KB) 451 COMPLETED 103/103 2021-04-22 17:28:12 2021-04-22 17:28:12 122ms 4.43 MB 9.36 KB (15.2 KB) 450 COMPLETED 103/103 2021-04-22 17:27:12 2021-04-22 17:27:12 124ms

Re: 疑问：当开启state.backend.incremental 后 Checkpointed Data Size 会不断变大

你好 我也遇到了 所以这个问题你知道原因了没 -- Sent from: http://apache-flink.147419.n8.nabble.com/