Unsubscribe

Unsubscribe

Job continuously failing after Checkpoint Restore

Hi, We are currently running a Flink Job that has 3 operators. Source ---> Filter ---> Sink As soon as the job is started it tries to recover from the latest Checkpoint [05-Mar-2019 13:09:55.365 UTC] INFO Restoring from latest valid checkpoint: Checkpoint 60 @ 1551788864502 for fd697c91437216e

Flink auth against Zookeeper with MD5-Digest

Hi, I was wondering if there is any plans in the near future to include support for another authentication mechanism different than Kerberos? such as MD5-Digest ? Cheers,

Re: CompletedCheckpoints are getting Stale ( Flink 1.4.2 )

ckoverflow.com/questions/44928624/apache-flink-not-deleting-old-checkpoints >> [3]: >> https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java#L437 >> >> Thanks, vino. >> >> Laura Uzcáte

CompletedCheckpoints are getting Stale ( Flink 1.4.2 )

Hello, At work, we are currently standing up a cluster with the following configuration: - Flink version: 1.4.2 - HA Enabled with Zookeeper - State backend : rocksDB - state.checkpoints.dir: hdfs://namenode:9000/flink/checkpoints - state.backend.rocksdb.checkpointdir: hdfs://n