Package com.linkedin.venice.stats.dimensions

Enum Class VeniceIngestionFailureReason

java.lang.Object
java.lang.Enum<VeniceIngestionFailureReason>
com.linkedin.venice.stats.dimensions.VeniceIngestionFailureReason
All Implemented Interfaces:
VeniceDimensionInterface, Serializable, Comparable<VeniceIngestionFailureReason>, Constable
public enum VeniceIngestionFailureReason extends Enum<VeniceIngestionFailureReason> implements VeniceDimensionInterface
Dimension values for the VeniceMetricsDimensions.VENICE_INGESTION_FAILURE_REASON dimension, representing the categorized reason for an ingestion task failure.

Ingestion tasks can fail for various reasons during the consumption and processing of data from Kafka topics. This dimension categorizes the failure reason, enabling operators to quickly identify the root cause of ingestion issues through metric dashboards and alerts.

Used by the ingestion.failure.count metric to count ingestion failures by reason.

See Also:

  • Enum Constant Details

    • TASK_KILLED

      public static final VeniceIngestionFailureReason TASK_KILLED
      The ingestion task was explicitly killed (e.g., during version swap or shutdown)

    • CHECKSUM_VERIFICATION_FAILURE

      public static final VeniceIngestionFailureReason CHECKSUM_VERIFICATION_FAILURE
      A checksum verification failure was detected on ingested data, indicating data corruption

    • SERVING_VERSION_BOOTSTRAP_TIMEOUT

      public static final VeniceIngestionFailureReason SERVING_VERSION_BOOTSTRAP_TIMEOUT
      A serving (current/backup) version partition's bootstrap exceeded the time limit; the task stays alive

    • FUTURE_VERSION_PUSH_TIMEOUT

      public static final VeniceIngestionFailureReason FUTURE_VERSION_PUSH_TIMEOUT
      A future version's ingestion task was killed because bootstrap timed out (VeniceTimeoutException)

    • REMOTE_BROKER_UNREACHABLE

      public static final VeniceIngestionFailureReason REMOTE_BROKER_UNREACHABLE
      A remote Kafka broker in another region was unreachable during cross-region replication

    • GENERAL

      public static final VeniceIngestionFailureReason GENERAL
      A general/uncategorized ingestion failure that does not match any specific reason above

  • Method Details

    • values

      public static VeniceIngestionFailureReason[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared

    • valueOf

      public static VeniceIngestionFailureReason valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)
      Parameters:
      name - the name of the enum constant to be returned.
      Returns:
      the enum constant with the specified name
      Throws:
      IllegalArgumentException - if this enum class has no constant with the specified name
      NullPointerException - if the argument is null

    • getDimensionName

      public VeniceMetricsDimensions getDimensionName()
      All instances of this enum share the same dimension name. Refer to VeniceDimensionInterface.getDimensionName() for more details.
      Specified by:
      getDimensionName in interface VeniceDimensionInterface