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

Class Retries

java.lang.Object
io.github.flink.gcp.connector.base.retry.Retries
@Internal public final class Retries extends Object
Support for the connectors' hand-written retry loops. The loops themselves stay in the connectors: each pairs a RetrySchedule with its own retryability classification and per-site recovery actions, which is the part no shared executor replaces (issue #61 records the survey).

  • Method Summary

    Modifier and Type
    Method
    Description
    static void
    sleep(long millis, String interruptedMessage)
    Sleeps for the given backoff, translating an interrupt into an IOException carrying the given message — the writers and committers run on threads Flink interrupts to cancel a task, and their contracts fail via IOException.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • sleep

      public static void sleep(long millis, String interruptedMessage) throws IOException
      Sleeps for the given backoff, translating an interrupt into an IOException carrying the given message — the writers and committers run on threads Flink interrupts to cancel a task, and their contracts fail via IOException. The interrupt flag is restored. A non-positive duration returns immediately.
      Parameters:
      millis - the sleep duration
      interruptedMessage - the message of the IOException thrown on interrupt; it should name what was being waited for
      Throws:
      IOException