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 ceae42d60bf Update test catalog data for GHA workflow run 29767359753
ceae42d60bf is described below
commit ceae42d60bf0e9261028a06590654c7f0c51140a
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jul 20 23:07:21 2026 +0000
Update test catalog data for GHA workflow run 29767359753
Commit:
https://github.com/apache/kafka/commit/cb69d5716e5924001ddc269ec95ae5a09e1f80f2
GitHub Run: https://github.com/apache/kafka/actions/runs/29767359753
---
test-catalog/core/tests.yaml | 35 ++++---------------------
test-catalog/streams/tests.yaml | 10 +++++++
test-catalog/transaction-coordinator/tests.yaml | 30 +++++++++++++++++++++
3 files changed, 45 insertions(+), 30 deletions(-)
diff --git a/test-catalog/core/tests.yaml b/test-catalog/core/tests.yaml
index 2ca4985b571..44e2ba28b87 100644
--- a/test-catalog/core/tests.yaml
+++ b/test-catalog/core/tests.yaml
@@ -831,36 +831,6 @@
kafka.coordinator.transaction.TransactionMarkerRequestCompletionHandlerTest:
- shouldThrowIllegalStateExceptionWhenMessageTooLargeError
- shouldThrowIllegalStateExceptionWhenRecordListTooLargeError
- shouldThrowIllegalStateExceptionWhenUnknownError
-kafka.coordinator.transaction.TransactionMetadataTest:
-- testAllTransactionStatesAreMapped
-- testAttemptedEpochBumpWithFencedEpoch
-- testAttemptedEpochBumpWithLastEpoch
-- testAttemptedEpochBumpWithNewlyCreatedMetadata
-- testBumpEpochNotAllowedIfEpochsExhausted
-- testEpochBumpOnEndTxn
-- testEpochBumpOnEndTxnOverflow
-- testEpochBumpWithCurrentEpochProvided
-- testFenceProducerAfterEpochsExhausted
-- testFenceProducerNotAllowedIfItWouldOverflow
-- testInitializeEpoch
-- testInvalidTransitionFromCompleteAbortToFence
-- testInvalidTransitionFromCompleteCommitToFence
-- testNormalEpochBump
-- testRotateProducerId
-- testRotateProducerIdInOngoingState
-- testRotateProducerIdInPrepareAbortState
-- testRotateProducerIdInPrepareCommitState
-- testTolerateTimeShiftDuringAddPartitions
-- testTolerateTimeShiftDuringCompleteAbort
-- testTolerateTimeShiftDuringCompleteCommit
-- testTolerateTimeShiftDuringPrepareAbort
-- testTolerateTimeShiftDuringPrepareCommit
-- testTolerateUpdateTimeResetDuringProducerIdRotation
-- testTolerateUpdateTimeShiftDuringEpochBump
-- testTransactionStateIdAndNameMapping
-- testTransitFromCompleteAbortToPrepareAbortInV2
-- testTransitFromCompleteCommitToPrepareAbortInV2
-- testTransitFromEmptyToPrepareAbortInV2
kafka.coordinator.transaction.TransactionStateManagerTest:
- shouldNotRemoveExpiredTransactionalIdsIfLogAppendFails
- shouldNotRemoveOngoingTransactionalIds
@@ -2382,7 +2352,9 @@ kafka.server.share.DelayedShareFetchTest:
- testAsyncReadExceptionReleasesLocks
- testAsyncReadMinBytesNotSatisfiedClearsAcquiredStateForOnComplete
- testAsyncReadMinBytesNotSatisfiedClearsAcquiredStateForRetry
+- testAsyncReadRemoteFetchRemovesNonRemotePartitionsFromAcquiredOnRelease
- testCombineLogReadResponse
+- testCompleteShareFetchAsyncRequestReleasesLocksWhenExceptionHandlingThrows
- testDelayedShareFetchTryCompleteReturnsFalseDueToNonAcquirablePartitions
- testDelayedShareFetchTryCompleteReturnsTrue
- testEmptyFutureReturnedByDelayedShareFetchOnComplete
@@ -2397,6 +2369,7 @@ kafka.server.share.DelayedShareFetchTest:
- testPartitionMaxBytesFromUniformStrategyInCombineLogReadResponse
- testPartitionMaxBytesFromUniformStrategyWhenAllPartitionsAreAcquirable
- testPartitionMaxBytesFromUniformStrategyWhenFewPartitionsAreAcquirable
+- testRemoteStorageFetchCompletionDoesNotDuplicateLocalPartitionsInActionQueue
- testRemoteStorageFetchCompletionNotTriggerActionsQueue
-
testRemoteStorageFetchCompletionPostRegisteringCallbackByPendingFetchesCompletion
- testRemoteStorageFetchCompletionPostRegisteringCallbackByTimerTaskCompletion
@@ -2414,9 +2387,11 @@ kafka.server.share.DelayedShareFetchTest:
- testToCompleteAnAlreadyCompletedFuture
- testTryCompleteAsyncCompletion
- testTryCompleteLocksReleasedOnCompleteException
+- testTryCompleteReleasesLocksWhenAsyncReadImmediatelyThrows
- testTryCompleteWhenMinBytesNotSatisfiedOnFirstFetch
- testTryCompleteWhenMinBytesNotSatisfiedOnSubsequentFetch
- testTryCompleteWhenPartitionMaxBytesStrategyThrowsException
+- testTryCompleteWithPendingRemoteFetchInFlight
kafka.server.share.ReplicaManagerLogReaderTest:
- testReadAsyncCompletesExceptionallyWhenLocalReadThrows
- testReadAsyncFollowsRemoteWhenTieredAndReadRemoteTrue
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 57d7cabb9c4..2983ad53316 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -926,22 +926,32 @@
org.apache.kafka.streams.kstream.internals.KStreamForeachTest:
- testTypeVariance
org.apache.kafka.streams.kstream.internals.KStreamGlobalKTableJoinTest:
- shouldClearGlobalTableEntryOnNullValueUpdates
+- shouldDropRecordAndRecordDroppedSensorWhenStreamValueIsNull
- shouldJoinOnNullKey
- shouldJoinOnlyIfMatchFoundOnStreamUpdates
+- shouldNameProcessorBasedOnNamedParameter
- shouldNotJoinOnGlobalTableUpdates
- shouldNotJoinOnNullKeyMapperValues
- shouldNotJoinOnNullKeyMapperValuesWithNullKeys
- shouldNotJoinWithEmptyGlobalTableOnStreamUpdates
- shouldNotRequireCopartitioning
+- shouldPassMappedKeyAndStreamKeyToJoiner
+- shouldPassStreamKeyAsReadOnlyKeyToDeprecatedJoiner
org.apache.kafka.streams.kstream.internals.KStreamGlobalKTableLeftJoinTest:
- shouldClearGlobalTableEntryOnNullValueUpdates
+- shouldDropRecordAndRecordDroppedSensorWhenStreamValueIsNull
+- shouldEmitWithNullMappedKeyWhenMapperReturnsNull
+- shouldEmitWithNullTableValueOnNoMatch
- shouldJoinOnNullKey
- shouldJoinOnNullKeyMapperValues
- shouldJoinOnNullKeyMapperValuesWithNullKeys
- shouldJoinRegardlessIfMatchFoundOnStreamUpdates
+- shouldNameProcessorBasedOnNamedParameter
- shouldNotJoinOnGlobalTableUpdates
- shouldNotJoinWithEmptyGlobalTableOnStreamUpdates
- shouldNotRequireCopartitioning
+- shouldPassMappedKeyAndStreamKeyToJoiner
+- shouldPassStreamKeyAsReadOnlyKeyToDeprecatedJoiner
org.apache.kafka.streams.kstream.internals.KStreamImplTest:
- shouldBindStateWithProcessorSupplier
- shouldMaterializeKTableFromKStream
diff --git a/test-catalog/transaction-coordinator/tests.yaml
b/test-catalog/transaction-coordinator/tests.yaml
index 52b272fb181..bbe68e186a0 100644
--- a/test-catalog/transaction-coordinator/tests.yaml
+++ b/test-catalog/transaction-coordinator/tests.yaml
@@ -39,6 +39,36 @@ org.apache.kafka.coordinator.transaction.TransactionLogTest:
- testReadReturnsUnknownValueVersionForInvalidValue
- testSerializeTransactionLogValueToFlexibleVersion
- testSerializeTransactionLogValueToHighestNonFlexibleVersion
+org.apache.kafka.coordinator.transaction.TransactionMetadataTest:
+- testAllTransactionStatesAreMapped
+- testAttemptedEpochBumpWithFencedEpoch
+- testAttemptedEpochBumpWithLastEpoch
+- testAttemptedEpochBumpWithNewlyCreatedMetadata
+- testBumpEpochNotAllowedIfEpochsExhausted
+- testEpochBumpOnEndTxn
+- testEpochBumpOnEndTxnOverflow
+- testEpochBumpWithCurrentEpochProvided
+- testFenceProducerAfterEpochsExhausted
+- testFenceProducerNotAllowedIfItWouldOverflow
+- testInitializeEpoch
+- testInvalidTransitionFromCompleteAbortToFence
+- testInvalidTransitionFromCompleteCommitToFence
+- testNormalEpochBump
+- testRotateProducerId
+- testRotateProducerIdInOngoingState
+- testRotateProducerIdInPrepareAbortState
+- testRotateProducerIdInPrepareCommitState
+- testTolerateTimeShiftDuringAddPartitions
+- testTolerateTimeShiftDuringCompleteAbort
+- testTolerateTimeShiftDuringCompleteCommit
+- testTolerateTimeShiftDuringPrepareAbort
+- testTolerateTimeShiftDuringPrepareCommit
+- testTolerateUpdateTimeResetDuringProducerIdRotation
+- testTolerateUpdateTimeShiftDuringEpochBump
+- testTransactionStateIdAndNameMapping
+- testTransitFromCompleteAbortToPrepareAbortInV2
+- testTransitFromCompleteCommitToPrepareAbortInV2
+- testTransitFromEmptyToPrepareAbortInV2
org.apache.kafka.coordinator.transaction.TransactionStateManagerConfigTest:
- ShouldDefineAllConfigInConfigDef
- ShouldGetStaticValueFromClassAttribute
