Fail ingestion tasks when OffsetOutOfRangeException is raised by FrankChen021 · Pull Request #18226 · apache/druid

FrankChen021 · 2025-07-09T08:23:05Z

Description

When OffsetOutOfRangeException is raised, previously, it waits until task completes. This brings problems for operators that it may take long time to observe such exception is raised.

Now the exception handling is improved if auto reset is not enabled:

all ingested messages before the expired offset will be persisted and published
task will be marked as FAIL so that operators/users can take actions against problematic topics as early as possible

Release note

Tasks that encounters OffsetOutOfRangeException exception will fail immediately

Follow these steps to test:

set up a topic in Kafka

config the topic's retention time/retension size to a very small value

./kafka-configs.sh --bootstrap-server localhost:9092 --entity-type topics --entity-name a --alter --add-config retention.ms=10000 retention.bytes=16384

set up a kafka ingestion task in Druid
use kafka-producer-perf-test.sh to generate events to the test topic in very large throughput

sh kafka-producer-perf-test.sh --topic a --print-metrics --payload-file payload.txt --producer-props bootstrap.servers=localhost:9092 --num-records 1000000000 --throughput 10000000

after a while when kafka server deletes offset, we can see from task log, task pushed segments and fail at last

2025-07-09T07:53:14,267 INFO [task-runner-0-priority-0] org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Pushing [1] segments in background
2025-07-09T07:53:14,267 INFO [task-runner-0-priority-0] org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Pushing segments: [a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7]
2025-07-09T07:53:14,267 INFO [task-runner-0-priority-0] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Persisted rows[0] and (estimated) bytes[0]
2025-07-09T07:53:14,267 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Flushed in-memory data with commit metadata [AppenderatorDriverMetadata{segments={index_kafka_a_efbb0759e7aa99a_1=[SegmentWithState{segmentIdentifier=a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7, state=APPENDING}]}, lastSegmentIds={index_kafka_a_efbb0759e7aa99a_1=a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7}, callerMetadata={nextPartitions=SeekableStreamStartSequenceNumbers{stream='a', partitionSequenceNumberMap={KafkaTopicPartition{partition=0, topic='null', multiTopicPartition=false}=3009454933}, exclusivePartitions=[]}, publishPartitions=SeekableStreamEndSequenceNumbers{stream='a', partitionSequenceNumberMap={KafkaTopicPartition{partition=0, topic='null', multiTopicPartition=false}=3009454933}}}}] for segments: 
2025-07-09T07:53:14,267 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Persisted stats: processed rows: [9442198], persisted rows[0], sinks: [2], total fireHydrants (across sinks): [64], persisted fireHydrants (across sinks): [0]
2025-07-09T07:53:14,267 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-merge] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Preparing to push (stats): processed rows: [9442198], sinks: [1], fireHydrants (across sinks): [30]
2025-07-09T07:53:14,426 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-merge] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Segment[a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7] of 305,093 bytes built from 30 incremental persist(s) in 155ms; pushed to deep storage in 2ms. Load spec is: {"type":"local","path":"/Users/frank/source/open/druid/distribution/apache-druid-33.0.0/var/druid/segments/a/2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z/2025-07-08T06:55:43.564Z/7/e5a7be8f-02b8-4b51-a967-a0a8ee3708b4/index/"}
2025-07-09T07:53:14,426 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-merge] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Push complete...
2025-07-09T07:53:14,438 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-publish] org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Published [1] segments with commit metadata[{nextPartitions=SeekableStreamStartSequenceNumbers{stream='a', partitionSequenceNumberMap={KafkaTopicPartition{partition=0, topic='null', multiTopicPartition=false}=3009454933}, exclusivePartitions=[]}, publishPartitions=SeekableStreamEndSequenceNumbers{stream='a', partitionSequenceNumberMap={KafkaTopicPartition{partition=0, topic='null', multiTopicPartition=false}=3009454933}}}].
2025-07-09T07:53:14,438 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-publish] org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Published segments: [a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7]
2025-07-09T07:53:14,438 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-publish] org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver - Published segment schemas[SegmentSchemaMapping{segmentIdToMetadataMap={}, schemaFingerprintToPayloadMap={}, version='1'}].
2025-07-09T07:53:14,438 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-publish] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Published 1 segments for sequence [index_kafka_a_efbb0759e7aa99a_1] with metadata [AppenderatorDriverMetadata{segments={index_kafka_a_efbb0759e7aa99a_1=[SegmentWithState{segmentIdentifier=a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7, state=APPENDING}]}, lastSegmentIds={index_kafka_a_efbb0759e7aa99a_1=a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7}, callerMetadata={nextPartitions=SeekableStreamStartSequenceNumbers{stream='a', partitionSequenceNumberMap={KafkaTopicPartition{partition=0, topic='null', multiTopicPartition=false}=3009454933}, exclusivePartitions=[]}, publishPartitions=SeekableStreamEndSequenceNumbers{stream='a', partitionSequenceNumberMap={KafkaTopicPartition{partition=0, topic='null', multiTopicPartition=false}=3009454933}}}}].
2025-07-09T07:53:14,438 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-publish] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Published segments: [a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7]
2025-07-09T07:53:14,439 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-publish] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Saved sequence metadata to disk: []
2025-07-09T07:53:29,504 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7] at path[/druid/segments/localhost:8100/localhost:8100_indexer-executor__default_tier_2025-07-09T07:52:28.251Z_85b89ba69fc64644816411d28bf6ee161]
2025-07-09T07:53:29,505 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Unannounced segment[a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7], scheduling drop in [30000] millisecs
2025-07-09T07:53:29,505 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Successfully handed off [1] segments.
2025-07-09T07:53:29,510 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.server.coordination.BatchDataSegmentAnnouncer - Unannouncing segment[a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_6] at path[/druid/segments/localhost:8100/localhost:8100_indexer-executor__default_tier_2025-07-09T07:52:28.251Z_85b89ba69fc64644816411d28bf6ee161]
2025-07-09T07:53:29,510 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/segments/localhost:8100/localhost:8100_indexer-executor__default_tier_2025-07-09T07:52:28.251Z_85b89ba69fc64644816411d28bf6ee161]
2025-07-09T07:53:29,523 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderator - Unannounced segment[a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_6], scheduling drop in [30000] millisecs
2025-07-09T07:53:29,523 INFO [[index_kafka_a_efbb0759e7aa99a_oinmidfh]-appenderator-persist] org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver - Successfully handed off [1] segments.
2025-07-09T07:53:29,527 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Handoff complete for segments: DataSegment{binaryVersion=9, id=a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_6, loadSpec={type=>local, path=>/Users/frank/source/open/druid/distribution/apache-druid-33.0.0/var/druid/segments/a/2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z/2025-07-08T06:55:43.564Z/6/40c3824e-0308-4385-9595-c69287926478/index/}, dimensions=[value], metrics=[], shardSpec=NumberedShardSpec{partitionNum=6, partitions=0}, lastCompactionState=null, size=343313}
2025-07-09T07:53:29,527 INFO [task-runner-0-priority-0] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Handoff complete for segments: DataSegment{binaryVersion=9, id=a_2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z_2025-07-08T06:55:43.564Z_7, loadSpec={type=>local, path=>/Users/frank/source/open/druid/distribution/apache-druid-33.0.0/var/druid/segments/a/2025-05-01T00:00:00.000Z_2025-05-01T01:00:00.000Z/2025-07-08T06:55:43.564Z/7/e5a7be8f-02b8-4b51-a967-a0a8ee3708b4/index/}, dimensions=[value], metrics=[], shardSpec=NumberedShardSpec{partitionNum=7, partitions=0}, lastCompactionState=null, size=305093}
2025-07-09T07:53:29,531 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Metrics scheduler closed
2025-07-09T07:53:29,531 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.metrics.JmxReporter
2025-07-09T07:53:29,531 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Closing reporter org.apache.kafka.common.telemetry.internals.ClientTelemetryReporter
2025-07-09T07:53:29,531 INFO [task-runner-0-priority-0] org.apache.kafka.common.metrics.Metrics - Metrics reporters closed
2025-07-09T07:53:29,534 INFO [task-runner-0-priority-0] org.apache.kafka.common.utils.AppInfoParser - App info kafka.consumer for consumer-kafka-supervisor-ofmlhdlj-1 unregistered
2025-07-09T07:53:29,534 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/internal-discovery/PEON/localhost:8100]
2025-07-09T07:53:29,540 INFO [task-runner-0-priority-0] org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer - Unannounced self [{"druidNode":{"service":"druid/middleManager","host":"localhost","bindOnHost":false,"plaintextPort":8100,"port":-1,"tlsPort":-1,"enablePlaintextPort":true,"enableTlsPort":false},"nodeType":"peon","services":{"dataNodeService":{"type":"dataNodeService","tier":"_default_tier","maxSize":0,"type":"indexer-executor","serverType":"indexer-executor","priority":0},"lookupNodeService":{"type":"lookupNodeService","lookupTier":"__default"}},"startTime":"2025-07-09T07:51:29.426Z"}].
2025-07-09T07:53:29,541 INFO [task-runner-0-priority-0] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/announcements/localhost:8100]
2025-07-09T07:53:29,549 INFO [task-runner-0-priority-0] org.apache.druid.indexing.worker.executor.ExecutorLifecycle - Task completed with status: {
  "id" : "index_kafka_a_efbb0759e7aa99a_oinmidfh",
  "status" : "FAILED",
  "duration" : 120144,
  "errorMsg" : "Fetch position FetchPosition{offset=3009454933, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[10.22.64.229:9092 (id: 0 rack: null)], epoch=0}} is out of range for partition a-0\nThis may happen when given offsets have been deleted at the Kafka server due to the retention configuration. \nYou can use supervisor's reset API to set the offset to a valid position.",
  "location" : {
    "host" : null,
    "port" : -1,
    "tlsPort" : -1
  }
}
2025-07-09T07:53:29,551 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [ANNOUNCEMENTS]
2025-07-09T07:53:29,554 INFO [main] org.apache.druid.curator.announcement.Announcer - Unannouncing [/druid/segments/localhost:8100/localhost:8100_indexer-executor__default_tier_2025-07-09T07:51:29.441Z_4a9f27198f324d99a3832da84e8fcc8f0]
2025-07-09T07:53:29,560 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [SERVER]
2025-07-09T07:53:29,564 INFO [main] org.eclipse.jetty.server.AbstractConnector - Stopped ServerConnector@118f2486{HTTP/1.1, (http/1.1)}{0.0.0.0:8100}
2025-07-09T07:53:29,565 INFO [main] org.eclipse.jetty.server.session - node0 Stopped scavenging
2025-07-09T07:53:29,566 INFO [main] org.eclipse.jetty.server.handler.ContextHandler - Stopped o.e.j.s.ServletContextHandler@61ec2cb5{/,null,STOPPED}
2025-07-09T07:53:29,567 INFO [main] org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner - Starting graceful shutdown of task[index_kafka_a_efbb0759e7aa99a_oinmidfh].
2025-07-09T07:53:29,567 INFO [main] org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner - Stopping forcefully (status: [PUBLISHING])
2025-07-09T07:53:29,567 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [NORMAL]
2025-07-09T07:53:29,567 INFO [main] org.apache.druid.server.coordination.SegmentBootstrapper - Stopping...
2025-07-09T07:53:29,567 INFO [main] org.apache.druid.server.coordination.SegmentBootstrapper - Stopped.
2025-07-09T07:53:29,567 INFO [main] org.apache.druid.server.coordination.ZkCoordinator - Stopping ZkCoordinator for [DruidServerMetadata{name='localhost:8100', hostAndPort='localhost:8100', hostAndTlsPort='null', maxSize=0, tier='_default_tier', type=indexer-executor, priority=0}]
2025-07-09T07:53:29,571 INFO [LookupExtractorFactoryContainerProvider-MainThread] org.apache.druid.query.lookup.LookupReferencesManager - Lookup Management loop exited. Lookup notices are not handled anymore.
2025-07-09T07:53:29,572 INFO [Curator-Framework-0] org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting
2025-07-09T07:53:29,680 INFO [main] org.apache.zookeeper.ZooKeeper - Session: 0x100120c32ee0040 closed
2025-07-09T07:53:29,680 INFO [main-EventThread] org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x100120c32ee0040
2025-07-09T07:53:29,683 INFO [main] org.apache.druid.java.util.common.lifecycle.Lifecycle - Stopping lifecycle [module] stage [INIT]

On the task view, it's state is displayed as FAIIL

The status of task records the out of range exception

This PR has:

Copilot

Pull Request Overview

This PR improves Kafka ingestion tasks by failing immediately on OffsetOutOfRangeException when auto-reset is disabled, ensuring messages before the expired offset are persisted and published.

Introduces TaskStatusException to propagate task state and error messages.
Updates SeekableStreamIndexTaskRunner to catch TaskStatusException and report task failure.
Modifies KafkaIndexTaskRunner to throw TaskStatusException.fail on offset-out-of-range when auto-reset is off.

Reviewed Changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 2 comments.

File	Description
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/TaskStatusException.java	New exception class encapsulating a `TaskState` and message
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java	Catches `TaskStatusException` around `getRecords` and adjusts `onFailure` to return a failure status
extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskRunner.java	Throws `TaskStatusException.fail` on `OffsetOutOfRangeException` when automatic reset is disabled

Comments suppressed due to low confidence (3)

indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/TaskStatusException.java:25

[nitpick] Add a class-level Javadoc explaining the purpose of this exception and how it should be used to signal task status changes.

public class TaskStatusException extends Exception

indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java:2092

[nitpick] This @throws description is unclear and grammatically awkward. Consider rephrasing to: Throws TaskStatusException when an OffsetOutOfRangeException occurs (with messages persisted), and clarifying other exception paths.

   * @throws TaskStatusException all ingested message will be persisted and published.

extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskRunner.java:94

No unit or integration tests appear to cover the new failure path when auto-reset is disabled and OffsetOutOfRangeException is thrown. Consider adding a test to verify immediate task failure and message persistence.

      return recordSupplier.poll(task.getIOConfig().getPollTimeout());

...fka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskRunner.java

capistrant · 2025-07-16T21:06:27Z

merging master in should help with CI as the QTest timeouts are now less likely

github-actions · 2025-09-21T00:25:27Z

This pull request has been marked as stale due to 60 days of inactivity.
It will be closed in 4 weeks if no further activity occurs. If you think
that's incorrect or this pull request should instead be reviewed, please simply
write any comment. Even if closed, you can still revive the PR at any time or
discuss it on the dev@druid.apache.org list.
Thank you for your contributions.

GWphua · 2025-10-15T16:03:54Z

@FrankChen021 looks like there's some unit test failures that are related to your changes.

github-actions · 2025-12-15T00:28:20Z

This pull request has been marked as stale due to 60 days of inactivity.
It will be closed in 4 weeks if no further activity occurs. If you think
that's incorrect or this pull request should instead be reviewed, please simply
write any comment. Even if closed, you can still revive the PR at any time or
discuss it on the dev@druid.apache.org list.
Thank you for your contributions.

github-actions · 2026-01-12T00:28:24Z

This pull request/issue has been closed due to lack of activity. If you think that
is incorrect, or the pull request requires review, you can revive the PR at any time.

GWphua

LGTM, one comment about the exception message.

Can merge after CI passes.

GWphua · 2026-02-16T02:09:17Z

...fka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskRunner.java

+      if (!task.getTuningConfig().isResetOffsetAutomatically()) {
+        throw TaskStatusException.fail(
+            e.getMessage()
+            + "\nThis may happen when given offsets have been deleted at the Kafka server due to the retention configuration. "
+            + "\nYou can use supervisor's reset API to set the offset to a valid position."
+        );
+      }


Since this block fails with isResetOffsetAutomatically, I think we can also include a message to tell users that we can set a config to reset offset automatically, instead of needing to manually reset everytime.

Something like:
... use supervisor's reset API to set the offset to a valid position, or turn on resetOffsetAutomatically

GWphua · 2026-03-17T03:33:50Z

Hi @FrankChen021
You can try merging from master again to see if the test failures are fixed. Some flaky tests have been fixed recently.

FrankChen021 added 2 commits July 9, 2025 16:01

Handle Kafka OffsetOutOfRangeException

f6e1489

Update doc

c81a611

github-actions bot added Area - Streaming Ingestion Area - Ingestion labels Jul 9, 2025

FrankChen021 requested a review from Copilot July 9, 2025 08:24

Copilot AI reviewed Jul 9, 2025

View reviewed changes

...fka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskRunner.java Show resolved Hide resolved

...fka-indexing-service/src/main/java/org/apache/druid/indexing/kafka/KafkaIndexTaskRunner.java Show resolved Hide resolved

FrankChen021 added this to the 34.0.0 milestone Jul 9, 2025

FrankChen021 added the jacoco:skip label Jul 9, 2025

FrankChen021 closed this Jul 9, 2025

FrankChen021 reopened this Jul 9, 2025

Merge branch 'master' into offset-exception

a167795

This was referenced Jul 18, 2025

Correctly reset kafka offset if auto reset is enabled #18282

Open

Improve offset auto reset #18301

Open

Merge branch 'master' into offset-exception

ceefa22

cryptoe removed this from the 34.0.0 milestone Jul 22, 2025

github-actions bot added the stale label Sep 21, 2025

github-actions bot removed the stale label Oct 16, 2025

github-actions bot added the stale label Dec 15, 2025

github-actions bot closed this Jan 12, 2026

FrankChen021 reopened this Feb 13, 2026

github-actions bot removed the stale label Feb 14, 2026

GWphua approved these changes Feb 16, 2026

View reviewed changes

Merge branch 'master' into offset-exception

d7af67d

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Fail ingestion tasks when OffsetOutOfRangeException is raised#18226

Fail ingestion tasks when OffsetOutOfRangeException is raised#18226
FrankChen021 wants to merge 5 commits intoapache:masterfrom
FrankChen021:offset-exception

FrankChen021 commented Jul 9, 2025 •

edited

Loading

Uh oh!

Copilot AI left a comment

Uh oh!

Uh oh!

Uh oh!

capistrant commented Jul 16, 2025

Uh oh!

github-actions bot commented Sep 21, 2025

Uh oh!

GWphua commented Oct 15, 2025

Uh oh!

github-actions bot commented Dec 15, 2025

Uh oh!

github-actions bot commented Jan 12, 2026

Uh oh!

GWphua left a comment

Uh oh!

GWphua Feb 16, 2026

Uh oh!

GWphua commented Mar 17, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

5 participants

Conversation

FrankChen021 commented Jul 9, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Description

Release note

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull Request Overview

Reviewed Changes

Uh oh!

Uh oh!

Uh oh!

capistrant commented Jul 16, 2025

Uh oh!

github-actions bot commented Sep 21, 2025

Uh oh!

GWphua commented Oct 15, 2025

Uh oh!

github-actions bot commented Dec 15, 2025

Uh oh!

github-actions bot commented Jan 12, 2026

Uh oh!

GWphua left a comment

Choose a reason for hiding this comment

Uh oh!

GWphua Feb 16, 2026

Choose a reason for hiding this comment

Uh oh!

GWphua commented Mar 17, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

5 participants

FrankChen021 commented Jul 9, 2025 •

edited

Loading