Package io.github.flink.gcp.connector.base.retry


package io.github.flink.gcp.connector.base.retry
  • Classes
    Class
    Description
    Support for the connectors' hand-written retry loops.
    An immutable retry schedule: exponential backoff from an initial delay up to a cap, a bounded number of attempts, and optional proportional jitter (to de-synchronize parallel subtasks retrying against the same destination).