This is an automated email from the ASF dual-hosted git repository.
github-actions[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 82b6fc05fcd Update test catalog data for GHA workflow run 29459614767
82b6fc05fcd is described below
commit 82b6fc05fcd128d4fbb8ebd8717f9b8194131744
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Jul 16 03:48:45 2026 +0000
Update test catalog data for GHA workflow run 29459614767
Commit:
https://github.com/apache/kafka/commit/75e66426bf533b97898e7c558bd96712dd61c440
GitHub Run: https://github.com/apache/kafka/actions/runs/29459614767
---
test-catalog/clients/tests.yaml | 3 ++
test-catalog/core/tests.yaml | 4 ++
test-catalog/group-coordinator/tests.yaml | 47 ++++++++++++++++++++---
test-catalog/streams/integration-tests/tests.yaml | 2 +-
test-catalog/streams/tests.yaml | 39 +++++++++++++++++++
test-catalog/tools/tests.yaml | 2 +-
6 files changed, 90 insertions(+), 7 deletions(-)
diff --git a/test-catalog/clients/tests.yaml b/test-catalog/clients/tests.yaml
index 11e675796f3..80ce6935675 100644
--- a/test-catalog/clients/tests.yaml
+++ b/test-catalog/clients/tests.yaml
@@ -2028,6 +2028,7 @@
org.apache.kafka.clients.consumer.internals.FetchRequestManagerTest:
- testReadCommittedLagMetric
- testReadCommittedWithCommittedAndAbortedTransactions
- testReadCommittedWithCompactedTopic
+- testRecordLatencyOnFetchResponseLevelError
- testReturnAbortedTransactionsInUncommittedMode
- testReturnCommittedTransactions
- testSeekBeforeException
@@ -2119,6 +2120,7 @@ org.apache.kafka.clients.consumer.internals.FetcherTest:
- testReadCommittedLagMetric
- testReadCommittedWithCommittedAndAbortedTransactions
- testReadCommittedWithCompactedTopic
+- testRecordLatencyOnFetchResponseLevelError
- testReturnAbortedTransactionsInUncommittedMode
- testReturnCommittedTransactions
- testSeekBeforeException
@@ -2357,6 +2359,7 @@
org.apache.kafka.clients.consumer.internals.ShareConsumeRequestManagerTest:
- testPiggybackAcknowledgementsOnInitialShareSessionError
- testPiggybackAcknowledgementsOnInitialShareSessionErrorSubscriptionChange
- testPiggybackAcknowledgementsOnInitialShareSession_ShareSessionNotFound
+- testRecordLatencyOnFetchResponseLevelError
- testResultHandlerCompleteIfEmpty
- testResultHandlerOnCommitAsync
- testResultHandlerOnCommitSync
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 87e4e039b80..2ca4985b571 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -2380,6 +2380,8 @@ kafka.server.metadata.ClientQuotaMetadataManagerTest:
- testTransferToClientQuotaEntity
kafka.server.share.DelayedShareFetchTest:
- testAsyncReadExceptionReleasesLocks
+- testAsyncReadMinBytesNotSatisfiedClearsAcquiredStateForOnComplete
+- testAsyncReadMinBytesNotSatisfiedClearsAcquiredStateForRetry
- testCombineLogReadResponse
- testDelayedShareFetchTryCompleteReturnsFalseDueToNonAcquirablePartitions
- testDelayedShareFetchTryCompleteReturnsTrue
@@ -2399,6 +2401,8 @@ kafka.server.share.DelayedShareFetchTest:
-
testRemoteStorageFetchCompletionPostRegisteringCallbackByPendingFetchesCompletion
- testRemoteStorageFetchCompletionPostRegisteringCallbackByTimerTaskCompletion
- testRemoteStorageFetchHappensForAllTopicPartitions
+- testRemoteStorageFetchLocalReadCompletionFailureReleasesLocks
+- testRemoteStorageFetchLocalReadFailureReleasesLocks
- testRemoteStorageFetchPartitionLeaderChanged
- testRemoteStorageFetchRequestCompletionAlongWithLocalLogRead
- testRemoteStorageFetchRequestCompletionOnFutureCompletionFailure
diff --git a/test-catalog/group-coordinator/tests.yaml
b/test-catalog/group-coordinator/tests.yaml
index d74ee544d0e..49ecfb2f595 100644
--- a/test-catalog/group-coordinator/tests.yaml
+++ b/test-catalog/group-coordinator/tests.yaml
@@ -233,10 +233,17 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTest:
- testSyncGroupWhenNotStarted
- testSyncGroupWithException
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTest:
+- testClassicJoinDeletesTopologyBeforeConvertingEmptyStreamsGroup
+- testClassicJoinFailsWhenPluginDeleteFailsAndDoesNotConvert
+- testClassicJoinSkipsPluginDeleteWhenBarrierWriteFindsGroupChanged
+- testClassicJoinSkipsPluginDeleteWhenGroupAlreadyClassic
+- testClassicJoinThrottlesPluginDeleteAfterFailure
- testCleanupCycleBatchesClearWritesPerPartition
- testCleanupCycleClearsBackoffOnPluginSuccess
- testCleanupCycleClearsStoredEpochOnPluginSuccess
- testCleanupCycleEmptyEligibility
+- testCleanupCycleFinalizesAfterDeleteNotPlainClear
+- testCleanupCycleMarksUncertainThenDeletesThenFinalizes
- testCleanupCycleNoOpWhenNoPlugin
- testCleanupCyclePreservesBackoffOnPluginFailure
- testCleanupCycleSingleFlightHoldsFlagUntilClearWriteSettles
@@ -245,12 +252,19 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
-
testCleanupCycleSingleFlightReleasesFlagOnSynchronousThrowDuringChainConstruction
- testCleanupCycleSingleFlightSkipsConcurrentCycle
- testCleanupCycleSkipsClearOnPluginFailure
+- testCleanupCycleSkipsDeleteForRevivedGroup
- testCleanupCycleSkipsFollowUpWorkOncePastShutdown
+- testCleanupCycleSwallowsMarkWriteFailure
+- testDeleteGroupsClearsBackoffOnPluginSuccess
+- testDeleteGroupsMarksUncertainBeforePluginDelete
- testDeleteGroupsMixedPluginOutcome
- testDeleteGroupsPluginFailureReturnsGroupDeletionFailed
- testDeleteGroupsPluginSuccessProceedsToTombstone
+- testDeleteGroupsPreservesBackoffOnPluginFailure
- testDeleteGroupsSkipsPluginCallWhenNoStoredTopology
+- testDeleteGroupsSkipsPluginDeleteForRevivedGroup
- testDeleteGroupsWithoutPluginSkipsPluginCall
+- testDescribeAtUncertainEpochYieldsNotStored
- testDescribeAttachesAvailableWhenPluginReturnsTopology
- testDescribeAvailableRecordsGetSuccessSensor
- testDescribeConversionErrorRecordsGetErrorSensor
@@ -265,6 +279,7 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testDescribeSetsNotStoredWhenNoPluginConfigured
- testDescribeSynchronousThrowRecordsGetErrorSensor
- testDescribeWithIncludeFlagDisabledLeavesStatusDefault
+- testHalfPushedGroupIsDeleteEligibleViaUncertain
- testHeartbeatArmSuppressReSolicitCycle
- testHeartbeatDecorationFailurePreservesCommittedResponse
- testHeartbeatNeverSetsFlagWithoutPlugin
@@ -274,9 +289,11 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testHeartbeatSkipsFlagWhenFailedAtCurrentEpoch
- testHeartbeatSkipsFlagWhenStaleTopologyStatusPresent
- testHeartbeatSkipsFlagWhenStoredMatchesCurrent
+- testPushMarksUncertainBeforePluginSetThenAdvances
- testShutdownCancelsScheduledCleanupTask
- testShutdownClosesPlugin
- testShutdownSafeWhenNoCleanupTaskScheduled
+- testUncertainStoredEpochSolicitsOnHeartbeat
- testUpdateBackoffArmedWhenStoredEpochWriteFailsAfterPluginSuccess
- testUpdateGroupDisappearsBetweenPluginSuccessAndWriteDropsBackoffEntry
- testUpdatePermanentFailurePersistsFailedEpoch
@@ -289,6 +306,7 @@
org.apache.kafka.coordinator.group.GroupCoordinatorServiceTopologyDescriptionTes
- testUpdateRejectsEmptyGroupId
- testUpdateRejectsEmptyMemberId
- testUpdateReturnsUnsupportedVersionWhenNoPlugin
+- testUpdateSkipsPluginWhenBarrierWriteFindsGroupGone
- testUpdateSuccessPersistsStoredEpoch
- testUpdateSuccessRecordsSetSuccessSensor
- testUpdateTransientFailureRecordsSetErrorSensor
@@ -298,8 +316,6 @@
org.apache.kafka.coordinator.group.GroupCoordinatorShardTest:
- testCleanupGroupMetadataForShareGroup
- testCleanupGroupMetadataKeepsOffsetTombstonesWhenGroupRefusesToExpire
- testCleanupGroupMetadataTombstonesWhenGroupAgreesToExpire
-- testClearStoredDescriptionTopologyEpochBatchConcatenatesGMMRecords
-- testClearStoredDescriptionTopologyEpochDelegatesToGroupMetadataManager
- testCommitOffset
- testCommitTransactionalOffset
- testCompleteDeleteShareGroupOffsetsSuccess
@@ -314,7 +330,10 @@
org.apache.kafka.coordinator.group.GroupCoordinatorShardTest:
- testInitiateDeleteShareGroupOffsetsSuccess
- testInitiateDeleteShareGroupOffsetsSuccessWithErrorTopics
- testListStreamsGroupsNeedingTopologyCleanupFiltersByAllPredicates
+- testListStreamsGroupsNeedingTopologyCleanupIncludesUncertainEpoch
- testListStreamsGroupsNeedingTopologyCleanupSwallowsPerGroupError
+- testMarkUncertainBatchReturnsOnlyEligibleSubset
+- testMarkUncertainEmitsRecordForStreamsGroupAndReturnsTrue
- testOnLoaded
- testOnMetadataUpdate
- testOnTopicsDeleted
@@ -377,6 +396,9 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testClassicGroupHeartbeatToConsumerWithIllegalGenerationId
- testClassicGroupHeartbeatToConsumerWithMemberNotUsingClassicProtocol
- testClassicGroupHeartbeatToConsumerWithUnknownMember
+- testClassicGroupJoinDetectsEmptyStreamsGroupWithStoredTopology
+- testClassicGroupJoinDoesNotDetectForNonEligibleGroups
+- testClassicGroupJoinDoesNotDetectWhenTopologyCleanupHandled
- testClassicGroupJoinInconsistentProtocolType
- testClassicGroupJoinOnShareGroup
- testClassicGroupJoinOnStreamsGroup
@@ -403,9 +425,6 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testClassicGroupSyncToConsumerGroupWithInconsistentGroupProtocol
- testClassicGroupSyncToConsumerGroupWithUnknownMemberId
- testClassicMemberJoinToConsumerGroupWithDisabledMigrationPolicy
-- testClearStoredDescriptionTopologyEpochClearsWhenEpochMatches
-- testClearStoredDescriptionTopologyEpochNoOpsForMissingGroup
-- testClearStoredDescriptionTopologyEpochNoOpsWhenEpochMismatches
- testCombineInitMaps
- testCompleteDeleteShareGroupOffsets
- testCompleteDeleteShareGroupOffsetsEmptyResult
@@ -469,6 +488,12 @@
org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testDynamicMembersJoinGroupWithMaxSizeAndNotRequiredKnownMember
- testDynamicMembersJoinGroupWithMaxSizeAndRequiredKnownMember
- testExistingMemberJoinDeadGroup
+- testFinalizeAfterDeleteBatchIsNonAtomic
+- testFinalizeAfterDeleteClearsUncertainToNone
+- testFinalizeAfterDeleteForcesUncertainWhenEpochRacedPush
+- testFinalizeAfterDeleteNoOpForMissingGroup
+- testFinalizeAfterDeleteNoOpForNonStreamsGroup
+- testFinalizeAfterDeleteNoOpWhenAlreadyNone
- testGenerateRecordsOnNewClassicGroup
- testGenerateRecordsOnNewClassicGroupFailureTransformsError
- testGenerationIdIncrementsOnRebalance
@@ -536,6 +561,14 @@
org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testLeavingMemberBumpsGroupEpoch
- testLeavingStaticMemberBumpsGroupEpoch
- testListGroups
+- testMarkUncertainBatchReturnsOnlyEligibleSubset
+- testMarkUncertainIdempotentWhenAlreadyUncertain
+- testMarkUncertainMarksNonEmptyGroupForPushCallers
+- testMarkUncertainMarksNoneWhenMarkWhenNoneTrue
+- testMarkUncertainMarksStoredEpochAndReturnsTrue
+- testMarkUncertainSkipsNonStreamsGroup
+- testMarkUncertainSkipsNoneWhenMarkWhenNoneFalse
+- testMarkUncertainSkipsRevivedGroupForDeleteCallers
- testMaybeCleanupShareGroupStateEmptyTopicIds
- testMaybeCleanupShareGroupStateInitDeletedTopicsPresent
- testMemberCanRejoinWithEpochZeroInStableState
@@ -633,6 +666,9 @@ org.apache.kafka.coordinator.group.GroupMetadataManagerTest:
- testSessionTimeoutExpirationForShareMember
- testSessionTimeoutExpirationStaticMember
- testSessionTimeoutLifecycle
+- testSetFailedEpochPreservesUncertainBarrier
+- testSetStoredEpochReArmsUncertainWhenBarrierWasCleared
+- testSetStoredEpochWritesPushedEpochWhenBarrierPreserved
- testShareGroupAssignmentInterval
- testShareGroupDeleteRequestNoDeletingTopics
- testShareGroupDeleteRequestWithAlreadyDeletingTopics
@@ -1418,6 +1454,7 @@
org.apache.kafka.coordinator.group.streams.StreamsGroupTest:
- testRemoveTaskProcessIds
- testSetConfiguredTopologyClearsCache
- testShouldExpireFalseWhenPluginConfiguredAndEpochStored
+- testShouldExpireFalseWhenStoredEpochUncertain
- testShouldExpireTrueWhenNoPluginConfigured
- testShouldExpireTrueWhenStoredEpochIsDefault
- testShutdownRequestedMethods
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
index 30543f1011b..41964237432 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -501,7 +501,7 @@
org.apache.kafka.streams.integration.TopologyDescriptionNoPluginIntegrationTest:
- shouldRunStreamsApplicationAgainstBrokerWithoutTopologyDescriptionPlugin
org.apache.kafka.streams.integration.TopologyDescriptionPluginExpirationIntegrationTest:
- shouldDeleteStoredTopologyDescriptionWhenGroupExpires
-- shouldExpireGroupWithoutDeleteTopologyWhenPushPermanentlyFailed
+- shouldReclaimUncertainPluginStateWhenPushPermanentlyFailed
org.apache.kafka.streams.integration.TopologyDescriptionPluginIntegrationTest:
- shouldInvokeDeleteTopologyOnDeleteGroups
- shouldPushTopologyDescriptionOnlyOnceForTwoMembers
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 43f67cb1dfc..e8b709716ef 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -2308,6 +2308,7 @@
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldInitializeOffsetsFromCheckpointFileAndDeleteIfEOSEnabled
- shouldLoadMissingFileAsEmptyPosition
- shouldLogAWarningIfCheckpointThrowsAnIOException
+- shouldNotRefreshTaskDirectoryModificationTimeWhenClosingStartupTask
- shouldNotThrowTaskCorruptedExceptionAfterCheckpointing
- shouldNotThrowTaskCorruptedWithoutCheckpointAndNonEmptyDirWhenTransactional
- shouldNotThrowTaskCorruptedWithoutInMemoryStoreCheckpointAndNonEmptyDir
@@ -2317,6 +2318,7 @@
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldPreserveStreamsExceptionOnCloseIfStoreThrows
- shouldPreserveStreamsExceptionOnCommitIfStoreThrows
- shouldRecycleAndReinitializeStore
+- shouldRefreshTaskDirectoryModificationTimeOnClose
- shouldRegisterNonPersistentStore
- shouldRegisterPersistentStores
- shouldRegisterPersistentUnloggedStore
@@ -5301,6 +5303,7 @@
org.apache.kafka.streams.state.internals.MeteredSessionStoreWithHeadersTest:
- shouldUseHeadersFromValueToDeserializeKeyInFindSessions
- shouldUseHeadersFromValueToDeserializeKeyInFindSessionsByTime
- shouldUseHeadersFromValueToDeserializeKeyInFindSessionsRange
+- shouldUseHeadersFromValueToDeserializeKeyInReadOnlyFindSessions
- shouldWriteBytesToInnerStoreAndRecordPutMetric
- testMetrics
org.apache.kafka.streams.state.internals.MeteredTimestampedKeyValueStoreTest:
@@ -5384,6 +5387,7 @@
org.apache.kafka.streams.state.internals.MeteredTimestampedWindowStoreWithHeader
- shouldUseHeadersFromValueToDeserializeKeyInBackwardFetchRange
- shouldUseHeadersFromValueToDeserializeKeyInFetchAll
- shouldUseHeadersFromValueToDeserializeKeyInFetchRange
+- shouldUseHeadersFromValueToDeserializeKeyInReadOnlyFetchAll
org.apache.kafka.streams.state.internals.MeteredVersionedKeyValueStoreTest:
- shouldDelegateAndAddExecutionInfoOnCustomQuery
- shouldDelegateAndRecordMetricsOnCommit
@@ -5661,6 +5665,10 @@
org.apache.kafka.streams.state.internals.RocksDBRangeIteratorTest:
- shouldReturnTheCurrentKeyOnInvokingPeekNextKeyInForwardDirection
- shouldReturnTheCurrentKeyOnInvokingPeekNextKeyInReverseDirection
org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -5683,6 +5691,7 @@
org.apache.kafka.streams.state.internals.RocksDBSegmentedBytesStoreTest:
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest:
- shouldBackwardFetchAllSessionsWithSameRecordKey
- shouldBackwardFetchAllSessionsWithinKeyRange
@@ -5831,6 +5840,10 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedKeyValueBytesStoreTes
- shouldCreateEmptyWriteBatches
- shouldCreateWriteBatches
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithIndexSegmentedBytesStoreTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -5862,7 +5875,12 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithInde
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutIndexSegmentedBytesStoreTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -5894,6 +5912,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutI
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithHeadersTest:
- shouldCollectExecutionInfoWhenRequested
- shouldNotCollectExecutionInfoWhenNotRequested
@@ -5969,6 +5988,10 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithoutIn
- testIteratorPeek
- testIteratorPeekBackward
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithIndexSegmentedBytesStoreTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -6000,7 +6023,12 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithIndex
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithoutIndexSegmentedBytesStoreTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -6032,6 +6060,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithoutIn
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithHeadersTest:
- shouldCollectExecutionInfoWhenRequested
- shouldNotCollectExecutionInfoWhenNotRequested
@@ -6178,6 +6207,10 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithoutInd
- testValueIteratorPeek
- testWindowIteratorPeek
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -6200,7 +6233,12 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreTe
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreWithHeadersTest:
+- approximateNumUncommittedBytesShouldReflectStagedWrites
+- commitShouldMakeStagedWritesVisibleToReadCommitted
+- nonTransactionalStoreShouldReadIdenticallyAcrossIsolationLevels
+- readCommittedShouldHideStagedWritesUntilCommit
- shouldBeAbleToWriteToReInitializedStore
- shouldCreateWriteBatches
- shouldFetchAllSegments
@@ -6223,6 +6261,7 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedSegmentedBytesStoreWi
- shouldRestoreToByteStoreForStandbyTask
- shouldRollSegments
- shouldThrowTaskCorruptedExceptionIfSegmentIsInInvalidState
+- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreTest:
- commitShouldMergePendingIntoCommittedPosition
- committedPositionShouldExcludeStagedWritesUntilCommit
diff --git a/test-catalog/tools/tests.yaml b/test-catalog/tools/tests.yaml
index bfefe47b144..a6dda013cb6 100644
--- a/test-catalog/tools/tests.yaml
+++ b/test-catalog/tools/tests.yaml
@@ -445,7 +445,7 @@ org.apache.kafka.tools.LogDirsCommandTest:
- testLogDirsWithoutBrokers
org.apache.kafka.tools.MetadataQuorumCommandErrorTest:
- testDescribeOptions
-- testPropertiesFileDoesNotExists
+- testPropertiesFileDoesNotExist
- testRelativeTimeMs
- testRemoveControllerRequiresControllerDirectoryId
- testRemoveControllerRequiresControllerId
