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 76599cb5fb8 Update test catalog data for GHA workflow run 23166899152
76599cb5fb8 is described below
commit 76599cb5fb8d87855872f2e54148c6d6b0467d58
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Mar 17 01:13:34 2026 +0000
Update test catalog data for GHA workflow run 23166899152
Commit:
https://github.com/apache/kafka/commit/a40c8769ce75d77018925ff930968b452fdba1cc
GitHub Run: https://github.com/apache/kafka/actions/runs/23166899152
---
test-catalog/streams/tests.yaml | 51 +++++++++++++++++------------------------
1 file changed, 21 insertions(+), 30 deletions(-)
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 06f27dde940..2a30ee1550d 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -1915,18 +1915,18 @@
org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest:
- shouldThrowStreamsExceptionIfNoPartitionsFoundForStore
-
shouldUsePollMsPlusRequestTimeoutInPollDuringRestoreAndTimeoutWhenNoProgressDuringRestore
org.apache.kafka.streams.processor.internals.GlobalStateTaskTest:
-- shouldCheckpointDuringClose
-- shouldCheckpointDuringInitialization
-- shouldCheckpointIfReceivedEnoughRecordsAndFlushIntervalHasElapsed
--
shouldCheckpointIfReceivedEnoughRecordsFromMultipleTopicsAndFlushIntervalElapsed
-- shouldCheckpointOffsetsWhenStateIsFlushed
-- shouldFlushStateManagerWithOffsets
+- shouldCommitDuringClose
+- shouldCommitDuringInitialization
+- shouldCommitIfReceivedEnoughRecordsAndCommitIntervalHasElapsed
+- shouldCommitIfReceivedEnoughRecordsFromMultipleTopicsAndCommitIntervalElapsed
+- shouldCommitOffsetsWhenStateIsFlushed
+- shouldCommitStateManagerWithOffsets
- shouldInitializeContext
- shouldInitializeProcessorTopology
- shouldInitializeStateManager
- shouldInvokeProcessExceptionHandlerWhenEnabled
-- shouldNotCheckpointIfNotReceivedEnoughRecords
-- shouldNotCheckpointWhenFlushIntervalHasNotLapsed
+- shouldNotCommitIfNotReceivedEnoughRecords
+- shouldNotCommitWhenCommitIntervalHasNotLapsed
- shouldNotThrowStreamsExceptionWhenKeyDeserializationFailsWithSkipHandler
- shouldNotThrowStreamsExceptionWhenValueDeserializationFails
- shouldProcessRecordsForOtherTopic
@@ -2525,18 +2525,15 @@
org.apache.kafka.streams.processor.internals.SourceNodeTest:
- shouldThrowStreamsExceptionOnUndefinedValueSerde
- shouldThrowStreamsExceptionWithExplicitErrorMessage
org.apache.kafka.streams.processor.internals.StandbyTaskTest:
-- shouldAlwaysCheckpointStateIfEnforced
+- shouldAlwaysCommitStateIfEnforced
- shouldAlwaysSuspendCreatedTasks
- shouldAlwaysSuspendRunningTasks
- shouldClearTaskTimeout
- shouldCloseStateManagerOnTaskCreated
- shouldDeleteStateDirOnTaskCreatedAndEosV2UncleanClose
-- shouldFlushAndCheckpointStateManagerOnCommit
- shouldInitTaskTimeoutAndEventuallyThrow
-- shouldNotFlushAndThrowOnCloseDirty
+- shouldNotCommitAndThrowOnCloseDirty
- shouldNotThrowFromStateManagerCloseInCloseDirty
-- shouldOnlyCheckpointStateWithBigAdvanceIfNotEnforced
-- shouldOnlyNeedCommitWhenChangelogOffsetChanged
- shouldPrepareRecycleSuspendedTask
- shouldRecordRestoredRecords
- shouldRequireSuspendingCreatedTasksBeforeClose
@@ -2544,7 +2541,7 @@
org.apache.kafka.streams.processor.internals.StandbyTaskTest:
- shouldSuspendAndCommitBeforeCloseClean
- shouldThrowIfCommittingOnIllegalState
- shouldThrowLockExceptionIfFailedToLockStateDirectory
-- shouldThrowOnCloseCleanCheckpointError
+- shouldThrowOnCloseCleanCommitError
- shouldThrowOnCloseCleanError
- shouldTransitToRunningAfterInitialization
- shouldUnregisterMetricsInCloseClean
@@ -2683,7 +2680,7 @@
org.apache.kafka.streams.processor.internals.StreamTaskTest:
-
punctuateShouldThrowFailedProcessingExceptionWhenProcessingExceptionHandlerThrowsAnException
-
punctuateShouldThrowStreamsExceptionWhenProcessingExceptionHandlerRepliesWithFail
- punctuateShouldThrowStreamsExceptionWhenProcessingExceptionHandlerReturnsNull
-- shouldAlwaysCheckpointStateIfEnforced
+- shouldAlwaysCommitStateIfEnforced
- shouldAlwaysSuspendCreatedTasks
- shouldAlwaysSuspendRestoringTasks
- shouldAlwaysSuspendRunningTasks
@@ -2692,30 +2689,26 @@
org.apache.kafka.streams.processor.internals.StreamTaskTest:
- shouldBeProcessableIfAllPartitionsBuffered
- shouldBeRecordIdlingTimeIfSuspended
- shouldCallPunctuateOnPassedInProcessorNode
-- shouldCheckpointAfterRestorationWhenAtLeastOnceEnabled
-- shouldCheckpointForSuspendedRunningTaskWithLargeProgress
-- shouldCheckpointForSuspendedTask
-- shouldCheckpointOffsetsOnCommitIfSnapshotMuchChanged
-- shouldCheckpointOffsetsOnPostCommit
-- shouldCheckpointOnCloseRestoringIfNoProgress
--
shouldCheckpointWhileUpdateSnapshotWithTheConsumedOffsetsForSuspendedRunningTask
- shouldClearCommitStatusesInCloseDirty
- shouldClearTaskTimeout
- shouldCloseStateManagerEvenDuringFailureOnUncleanTaskClose
+- shouldCommitAfterRestorationWhenAtLeastOnceEnabled
- shouldCommitFetchedNextOffsetIfRecordQueueIsEmpty
+- shouldCommitForSuspendedRunningTaskWithLargeProgress
+- shouldCommitForSuspendedTask
- shouldCommitNextOffsetAndProcessorMetadataFromQueueIfAvailable
+- shouldCommitOffsetsOnPostCommit
- shouldCommitOldProcessorMetadataWhenNotDirty
+- shouldCommitOnCloseRestoringIfNoProgress
+- shouldCommitWhileUpdateSnapshotWithTheConsumedOffsetsForSuspendedRunningTask
- shouldFailOnCommitIfTaskIsClosed
- shouldFlushStateManagerAndRecordCollector
- shouldInitTaskTimeoutAndEventuallyThrow
- shouldLogNotReadyWhenStaleAfterThreshold
- shouldMaybeReturnOffsetsForRepartitionTopicsForPurging
- shouldNotAttemptToLockIfNoStores
-- shouldNotCheckpointAfterRestorationWhenExactlyOnceEnabled
-- shouldNotCheckpointForSuspendedRunningTaskWithSmallProgress
-- shouldNotCheckpointOffsetsAgainOnCommitIfSnapshotNotChangedMuch
-- shouldNotCheckpointOffsetsOnCommitIfEosIsEnabled
-- shouldNotCheckpointOnCloseCreated
+- shouldNotCommitAfterRestorationWhenExactlyOnceEnabled
+- shouldNotCommitOnCloseCreated
- shouldNotGetOffsetsIfPrepareCommitDirty
- shouldNotProcessRecordsAfterPrepareCommitWhenEosV2Enabled
- shouldNotPunctuateSystemTimeWhenIntervalNotElapsed
@@ -2723,7 +2716,6 @@
org.apache.kafka.streams.processor.internals.StreamTaskTest:
- shouldNotThrowExceptionOnAnchoredSchedule
- shouldNotThrowExceptionOnScheduleIfCurrentNodeIsNotNull
- shouldNotThrowFromStateManagerCloseInCloseDirty
-- shouldOnlyCheckpointStateWithBigAdvanceIfNotEnforced
- shouldPauseAndResumeBasedOnBufferedRecords
- shouldPrepareRecycleSuspendedTask
- shouldProcessInOrder
@@ -2749,7 +2741,6 @@
org.apache.kafka.streams.processor.internals.StreamTaskTest:
- shouldResumePartitionWhenSkippingOverRecordsWithInvalidTs
- shouldReturnStateManagerChangelogOffsets
- shouldSetProcessorNodeOnContextBackToNullAfterSuccessfulPunctuate
-- shouldSkipCheckpointingSuspendedCreatedTask
- shouldThrowExceptionOnCloseCleanError
- shouldThrowIfCleanClosingDirtyTask
- shouldThrowIfCommittingOnIllegalState
@@ -2758,7 +2749,7 @@
org.apache.kafka.streams.processor.internals.StreamTaskTest:
- shouldThrowIllegalStateExceptionIfCurrentNodeIsNotNullWhenPunctuateCalled
- shouldThrowIllegalStateExceptionOnScheduleIfCurrentNodeIsNull
- shouldThrowLockExceptionIfFailedToLockStateDirectory
-- shouldThrowOnCloseCleanCheckpointError
+- shouldThrowOnCloseCleanCommitError
- shouldThrowOnCloseCleanFlushError
- shouldThrowOnTimeoutExceptionAndBufferRecordForRetryIfEosDisabled
- shouldThrowStreamsExceptionWhenFetchCommittedFailed
