This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a commit to branch test-catalog
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/test-catalog by this push:
     new d13e77615b0 Update test catalog data for GHA workflow run 24103889692
d13e77615b0 is described below

commit d13e77615b05e2b230922d6941d1342187cba3ce
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Apr 8 02:26:23 2026 +0000

    Update test catalog data for GHA workflow run 24103889692
    
    Commit: 
https://github.com/apache/kafka/commit/794d2b625fa83ea2208c96682239ca8261d5cc3d
    GitHub Run: https://github.com/apache/kafka/actions/runs/24103889692
---
 test-catalog/streams/tests.yaml | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 6ed757280c6..747750334ae 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -4687,6 +4687,7 @@ 
org.apache.kafka.streams.state.internals.KeyValueSegmentsTest:
 - shouldNotCreateSegmentThatIsAlreadyExpired
 - shouldOpenExistingSegments
 - shouldRollSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 - shouldUpdateSegmentFileNameFromOldColonFormatToNewFormat
 - shouldUpdateSegmentFileNameFromOldDateFormatToNewFormat
 org.apache.kafka.streams.state.internals.KeyValueStoreBuilderTest:
@@ -4822,6 +4823,7 @@ 
org.apache.kafka.streams.state.internals.LogicalKeyValueSegmentsTest:
 - shouldNotCreateReservedSegmentFromRegularMethod
 - shouldNotCreateReservedSegmentWithNonNegativeId
 - shouldNotCreateSegmentThatIsAlreadyExpired
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 org.apache.kafka.streams.state.internals.MaybeTest:
 - shouldAnswerIsDefined
 - shouldReturnDefinedValue
@@ -5338,6 +5340,7 @@ 
org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest:
 - shouldRestoreToByteStoreForActiveTask
 - shouldRestoreToByteStoreForStandbyTask
 - shouldRollSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest:
 - shouldBackwardFetchAllSessionsWithSameRecordKey
 - shouldBackwardFetchAllSessionsWithinKeyRange
@@ -5838,6 +5841,7 @@ 
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreTe
 - shouldRestoreToByteStoreForActiveTask
 - shouldRestoreToByteStoreForStandbyTask
 - shouldRollSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreWithHeadersTest:
 - shouldBeAbleToWriteToReInitializedStore
 - shouldCreateWriteBatches
@@ -5860,6 +5864,7 @@ 
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreWi
 - shouldRestoreToByteStoreForActiveTask
 - shouldRestoreToByteStoreForStandbyTask
 - shouldRollSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest:
 - prefixScanShouldNotThrowConcurrentModificationException
 - 
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
@@ -6185,6 +6190,7 @@ 
org.apache.kafka.streams.state.internals.SessionSegmentsWithHeadersTest:
 - shouldGetSegmentsWithinTimeRange
 - shouldNotCreateSegmentThatIsAlreadyExpired
 - shouldOpenExistingSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 org.apache.kafka.streams.state.internals.SessionStoreBuilderTest:
 - shouldHaveCachingAndChangeLoggingWhenBothEnabled
 - shouldHaveCachingStoreWhenEnabled
@@ -6513,6 +6519,7 @@ 
org.apache.kafka.streams.state.internals.TimestampedSegmentsTest:
 - shouldNotCreateSegmentThatIsAlreadyExpired
 - shouldOpenExistingSegments
 - shouldRollSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 - shouldUpdateSegmentFileNameFromOldColonFormatToNewFormat
 - shouldUpdateSegmentFileNameFromOldDateFormatToNewFormat
 org.apache.kafka.streams.state.internals.TimestampedSegmentsWithHeadersTest:
@@ -6527,6 +6534,7 @@ 
org.apache.kafka.streams.state.internals.TimestampedSegmentsWithHeadersTest:
 - shouldGetSegmentsWithinTimeRange
 - shouldNotCreateSegmentThatIsAlreadyExpired
 - shouldOpenExistingSegments
+- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
 
org.apache.kafka.streams.state.internals.TimestampedToHeadersWindowStoreAdapterTest:
 - shouldCollectExecutionInfoForWindowKeyQueryWhenRequested
 - shouldCollectExecutionInfoForWindowRangeQueryWhenRequested

Reply via email to