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 87ec27863d1 Update test catalog data for GHA workflow run 19823320983
87ec27863d1 is described below
commit 87ec27863d1ad80d49a29f0b41f3a7eee27e8c42
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Dec 1 16:18:09 2025 +0000
Update test catalog data for GHA workflow run 19823320983
Commit:
https://github.com/apache/kafka/commit/ea88a8ec3f06c89b2c4d72221b6530eae5ab2f79
GitHub Run: https://github.com/apache/kafka/actions/runs/19823320983
---
test-catalog/streams/tests.yaml | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index b492a132705..ca6dd966ee0 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -3023,13 +3023,13 @@
org.apache.kafka.streams.processor.internals.TaskManagerTest:
- shouldAddFailedStandbyTaskToRecycleDuringAssignmentToTaskRegistry
- shouldAddNewActiveTasks
- shouldAddNonResumedSuspendedTasks
--
shouldAddRecycledStandbyTasksFromActiveToPendingTasksToInitWithStateUpdaterEnabled
+- shouldAddRecycledStandbyTasksFromActiveToPendingTasksToInit
- shouldAddSubscribedTopicsFromAssignmentToTopologyMetadata
- shouldAddTasksToStateUpdater
-- shouldAssignActiveTaskInTasksRegistryToBeClosedCleanlyWithStateUpdaterEnabled
--
shouldAssignActiveTaskInTasksRegistryToUpdateInputPartitionsWithStateUpdaterEnabled
+- shouldAssignActiveTaskInTasksRegistryToBeClosedCleanly
+- shouldAssignActiveTaskInTasksRegistryToUpdateInputPartitions
- shouldAssignMultipleTasksInStateUpdater
-- shouldAssignMultipleTasksInTasksRegistryWithStateUpdaterEnabled
+- shouldAssignMultipleTasksInTasksRegistry
- shouldCleanAndReviveCorruptedStandbyTasksBeforeCommittingNonCorruptedTasks
- shouldCloseActiveTasksAndIgnoreExceptionsOnUncleanShutdown
- shouldCloseActiveTasksAndPropagateExceptionsOnCleanShutdownWithAlos
@@ -3130,17 +3130,17 @@
org.apache.kafka.streams.processor.internals.TaskManagerTest:
- shouldRemoveUnusedFailedActiveTaskFromStateUpdaterAndCloseDirty
- shouldRemoveUnusedFailedStandbyTaskFromStateUpdaterAndCloseDirty
- shouldRemoveUnusedStandbyTaskFromStateUpdaterAndCloseCleanly
-- shouldResumeActiveRunningTaskInTasksRegistryWithStateUpdaterEnabled
+- shouldResumeActiveRunningTaskInTasksRegistry
- shouldResumeActiveSuspendedTaskInTasksRegistryAndAddToStateUpdater
- shouldResumePollingForPartitionsWithAvailableSpaceForAllActiveTasks
-- shouldRethrowRuntimeExceptionInInitTaskWithStateUpdater
+- shouldRethrowRuntimeExceptionInInitTask
- shouldRethrowStreamsExceptionFromStateUpdater
- shouldRethrowTaskCorruptedExceptionFromInitialization
- shouldRethrowTaskCorruptedExceptionFromStateUpdater
- shouldRetryInitializationWhenLockExceptionInStateUpdater
- shouldRetryInitializationWhenTimeoutExceptionInStateUpdater
- shouldRetryInitializationWithBackoffWhenInitializationFails
-- shouldReturnCorrectBooleanWhenTryingToCompleteRestorationWithStateUpdater
+- shouldReturnCorrectBooleanWhenTryingToCompleteRestoration
-
shouldReturnFalseFromCheckStateUpdaterIfActiveTasksAreNotRestoringAndNoPendingTaskToRecycleButPendingTasksToInit
- shouldReturnFalseFromCheckStateUpdaterIfActiveTasksAreRestoring
- shouldReturnFalseWhenThereAreStillNonRunningTasks
@@ -3160,9 +3160,9 @@
org.apache.kafka.streams.processor.internals.TaskManagerTest:
- shouldSuspendAllRevokedActiveTasksAndPropagateSuspendException
- shouldSuspendAllTasksButSkipCommitIfSuspendingFailsDuringRevocation
- shouldSuspendMultipleActiveTasksWithRevokedInputPartitionsInStateUpdater
--
shouldThrowDuringAssignmentIfStandbyTaskToCloseIsFoundInTasksRegistryWithStateUpdaterEnabled
--
shouldThrowDuringAssignmentIfStandbyTaskToRecycleIsFoundInTasksRegistryWithStateUpdaterEnabled
--
shouldThrowDuringAssignmentIfStandbyTaskToUpdateInputPartitionsIsFoundInTasksRegistryWithStateUpdaterEnabled
+- shouldThrowDuringAssignmentIfStandbyTaskToCloseIsFoundInTasksRegistry
+- shouldThrowDuringAssignmentIfStandbyTaskToRecycleIsFoundInTasksRegistry
+-
shouldThrowDuringAssignmentIfStandbyTaskToUpdateInputPartitionsIsFoundInTasksRegistry
- shouldThrowIfRevokingTasksInStateUpdaterFindsFailedTasks
- shouldThrowRuntimeExceptionWhenEncounteredUnknownExceptionDuringTaskClose
- shouldThrowSameKafkaExceptionWhenEncounteredDuringTaskClose
