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 97ebaa1cec3 Update test catalog data for GHA workflow run 22973139863
97ebaa1cec3 is described below
commit 97ebaa1cec38d6991a7e4e24f028b0150779ad3c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Mar 11 23:49:53 2026 +0000
Update test catalog data for GHA workflow run 22973139863
Commit:
https://github.com/apache/kafka/commit/9834b5189c742b8c508551a4a7a7382f792dbc0e
GitHub Run: https://github.com/apache/kafka/actions/runs/22973139863
---
test-catalog/streams/tests.yaml | 72 +++++++++++++++++++++++++++++++++++++++--
1 file changed, 69 insertions(+), 3 deletions(-)
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 6b8427bdc3e..d3b57ad6a01 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -4654,6 +4654,53 @@
org.apache.kafka.streams.state.internals.LeftOrRightValueSerializerTest:
- shouldSerializeStringValue
- shouldThrowIfSerializeOtherValueAsNull
- shouldThrowIfSerializeValueAsNull
+org.apache.kafka.streams.state.internals.LegacyCheckpointingStateStoreTest:
+- shouldAcceptNullOffsets
+- shouldBeNoOpForMigrationWhenNoLegacyFileExists
+- shouldBeNoOpForNonLCSSStoreInMaybeMarkCorrupted
+- shouldCloseWrappedStoreOnClose
+- shouldCommitWhenOldOffsetIsNull
+- shouldDeleteCheckpointFileAfterInitUnderEOS
+- shouldIgnoreCheckpointEntriesForPartitionsNotInChangelogSet
+- shouldLoadOffsetsFromCheckpointFileOnInit
+- shouldLogWarningInsteadOfThrowingWhenCheckpointWriteFails
+- shouldLogWarningWhenMigratingToStoreThatDoesNotManageOffsets
+- shouldMapOffsetUnknownToNullOnInit
+- shouldMarkLCSSAsCorruptedSoCloseDoesNotWriteCheckpoint
+- shouldMigrateOffsetsFromLegacyGlobalFileAndDeleteIt
+- shouldMigrateOffsetsFromLegacyPerTaskFileAndDeleteIt
+- shouldNotDeleteCheckpointFileAfterInitUnderALOS
+- shouldNotWrapNonPersistentStore
+- shouldNotWrapOffsetManagingStore
+- shouldNotWriteCheckpointDuringCommitUnderALOSWhenDeltaDoesNotExceedThreshold
+- shouldNotWriteCheckpointDuringCommitUnderEOS
+- shouldNotWriteCheckpointForNonPersistentStore
+- shouldNotWriteCheckpointOnCloseWhenCorrupted
+- shouldNotWriteCheckpointWhenChangelogPartitionsIsEmpty
+- shouldPreserveExistingOffsetsWhenCommittingSubsetOfPartitions
+- shouldReturnCommittedOffset
+- shouldReturnFalseFromCheckpointNeededWhenDeltaBelowThreshold
+- shouldReturnFalseFromCheckpointNeededWhenDeltaEqualsThreshold
+- shouldReturnFalseFromCheckpointNeededWhenOldSnapshotIsNull
+- shouldReturnLegacyGlobalCheckpointFile
+- shouldReturnLegacyPerTaskCheckpointFile
+- shouldReturnNonLCSSStoreUnchangedFromMaybeUnwrap
+- shouldReturnNullForCommittedOffsetWhenNoneCommitted
+- shouldReturnPerStoreCheckpointFileForGlobalStore
+- shouldReturnPerStoreCheckpointFileForTask
+- shouldReturnTrueForManagesOffsets
+- shouldReturnTrueFromCheckpointNeededWhenDeltaExceedsThreshold
+- shouldSucceedOnInitWhenNoCheckpointFileExists
+- shouldThrowProcessorStateExceptionOnCorruptCheckpointFile
+- shouldThrowProcessorStateExceptionWhenMigrationFails
+- shouldUnwrapLCSSToInnerStore
+- shouldUpdateInMemoryOffsetsOnCommit
+- shouldWrapPersistentNonOffsetManagingStore
+- shouldWriteCheckpointDuringCommitUnderALOSWhenDeltaExceedsThreshold
+- shouldWriteCheckpointOnClose
+- shouldWriteCheckpointOnCloseUnderEOS
+- shouldWriteCommittedOffsetsToCheckpointFile
+- shouldWriteOffsetUnknownSentinelWhenOffsetIsNull
org.apache.kafka.streams.state.internals.ListValueStoreTest:
- shouldAllowDeleteWhileIterateRecords
- shouldGetAll
@@ -4833,11 +4880,14 @@
org.apache.kafka.streams.state.internals.MeteredSessionStoreWithHeadersTest:
- shouldBackwardFindSessionsFromStoreAndRecordFetchMetric
- shouldCloseInnerStore
- shouldDelegateInit
+- shouldDelegateUnknownQueryToWrappedStore
+- shouldFailWindowRangeQueryWithoutKey
- shouldFetchForKeyAndRecordFetchMetric
- shouldFetchRangeFromStoreAndRecordFetchMetric
- shouldFetchSessionAndReturnValueWithHeaders
- shouldFindSessionRangeFromStoreAndRecordFetchMetric
- shouldFindSessionsFromStoreAndRecordFetchMetric
+- shouldHandleWindowRangeQueryWithKeyAndUnwrapHeaders
- shouldRecordRestoreTime
- shouldRemoveFromStoreAndRecordRemoveMetric
- shouldRemoveMetricsEvenIfWrappedStoreThrowsOnClose
@@ -4912,6 +4962,12 @@
org.apache.kafka.streams.state.internals.MeteredTimestampedWindowStoreWithHeader
- shouldNotThrowExceptionIfSerdesCorrectlySetFromProcessorContext
- shouldPassChangelogTopicNameToStateStoreSerde
- shouldPassDefaultChangelogTopicNameToStateStoreSerdeIfLoggingDisabled
+- shouldUseHeadersFromValueToDeserializeKeyInAll
+- shouldUseHeadersFromValueToDeserializeKeyInBackwardAll
+- shouldUseHeadersFromValueToDeserializeKeyInBackwardFetchAll
+- shouldUseHeadersFromValueToDeserializeKeyInBackwardFetchRange
+- shouldUseHeadersFromValueToDeserializeKeyInFetchAll
+- shouldUseHeadersFromValueToDeserializeKeyInFetchRange
org.apache.kafka.streams.state.internals.MeteredVersionedKeyValueStoreTest:
- shouldDelegateAndAddExecutionInfoOnCustomQuery
- shouldDelegateAndRecordMetricsOnCommit
@@ -5205,7 +5261,9 @@
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest:
- testIteratorPeek
- testIteratorPeekBackward
org.apache.kafka.streams.state.internals.RocksDBSessionStoreWithHeadersTest:
-- shouldThrowUnsupportedOperationOnQuery
+- shouldCollectExecutionInfoWhenRequested
+- shouldNotCollectExecutionInfoWhenNotRequested
+- shouldReturnUnknownQueryTypeForWindowRangeQuery
org.apache.kafka.streams.state.internals.RocksDBStoreTest:
- prefixScanShouldNotThrowConcurrentModificationException
-
shouldAddValueProvidersWithStatisticsToInjectedMetricsRecorderWhenRecordingLevelDebug
@@ -5357,8 +5415,9 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutI
- shouldRollSegments
- shouldSkipAndRemoveDanglingIndex
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithHeadersTest:
-- shouldThrowUnsupportedOperationOnQueryWithIndex
-- shouldThrowUnsupportedOperationOnQueryWithOutIndex
+- shouldCollectExecutionInfoWhenRequested
+- shouldNotCollectExecutionInfoWhenNotRequested
+- shouldReturnUnknownQueryTypeForWindowRangeQuery
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithIndexTest:
- shouldBackwardFetchAllSessionsWithSameRecordKey
- shouldBackwardFetchAllSessionsWithinKeyRange
@@ -5932,6 +5991,13 @@
org.apache.kafka.streams.state.internals.SessionStoreBuilderTest:
- shouldThrowNullPointerIfTimeIsNull
org.apache.kafka.streams.state.internals.SessionStoreFetchTest:
- testStoreConfig
+org.apache.kafka.streams.state.internals.SessionStoreIteratorFacadeTest:
+- shouldCloseInnerIterator
+- shouldForwardHasNext
+- shouldForwardPeekNextKey
+- shouldReturnNullValueWhenAggregationWithHeadersIsNull
+- shouldReturnNullWhenInnerNextReturnsNull
+- shouldReturnPlainKeyValuePairOnNext
org.apache.kafka.streams.state.internals.SessionToHeadersIteratorAdapterTest:
- shouldAddHeadersOnNext
- shouldDelegateClose
