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 79a88889ee2 Update test catalog data for GHA workflow run 30312651643
79a88889ee2 is described below
commit 79a88889ee2530ec8d08a5e584c1a73db884a95a
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jul 28 03:11:54 2026 +0000
Update test catalog data for GHA workflow run 30312651643
Commit:
https://github.com/apache/kafka/commit/8001408711059edc5dda803d2f50e551a7e7e7a9
GitHub Run: https://github.com/apache/kafka/actions/runs/30312651643
---
test-catalog/streams/integration-tests/tests.yaml | 11 +++++
test-catalog/streams/tests.yaml | 50 ++++++++++++++++++++---
2 files changed, 56 insertions(+), 5 deletions(-)
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
index 4e7c1d7d08f..632a4a6720b 100644
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ b/test-catalog/streams/integration-tests/tests.yaml
@@ -106,16 +106,27 @@
org.apache.kafka.streams.integration.IQv2HeadersStoreIntegrationTest:
- shouldFailWithUnknownQueryTypeForKeyQueryAgainstNonHeadersStore
- shouldFailWithUnknownQueryTypeForRangeQueryAgainstNonHeadersStore
- shouldFailWithUnknownQueryTypeForWindowKeyQueryAgainstNonHeadersStore
+-
shouldFailWithUnknownQueryTypeForWindowRangeQueryAgainstNonHeadersSessionStore
+- shouldFailWithUnknownQueryTypeForWindowRangeQueryAgainstNonHeadersStore
+- shouldFailWithUnknownQueryTypeWhenWithKeySubmittedToWindowStore
+- shouldFailWithUnknownQueryTypeWhenWithWindowStartRangeSubmittedToSessionStore
- shouldHandleTimestampedKeyWithHeadersQuery
- shouldHandleTimestampedRangeWithHeadersQuery
- shouldHandleTimestampedWindowKeyWithHeadersQuery
+- shouldHandleTimestampedWindowRangeWithHeadersQuery
+- shouldHandleTimestampedWindowRangeWithHeadersQueryOnSessionStore
- shouldNotSeeUnflushedWriteInRangeQueryWhenCachingEnabled
- shouldNotSeeUnflushedWriteInWindowKeyQueryWhenCachingEnabled
+- shouldNotSeeUnflushedWriteInWindowRangeQueryOnSessionStoreWhenCachingEnabled
+- shouldNotSeeUnflushedWriteInWindowRangeQueryWhenCachingEnabled
- shouldReturnEmptyHeadersForTimestampedRangeWithHeadersQueryOnAdapterStore
- shouldReturnEmptyHeadersForTimestampedWindowKeyWithHeadersQueryOnAdapterStore
+-
shouldReturnEmptyHeadersForTimestampedWindowRangeWithHeadersQueryOnAdapterStore
+-
shouldReturnEmptyHeadersForTimestampedWindowRangeWithHeadersQueryOnSessionAdapterStore
- shouldServeCacheHitWhenCachingEnabledAndRecordNotYetFlushed
- shouldThrowForTimestampedRangeWithHeadersQueryOnPlainSupplier
- shouldThrowForTimestampedWindowKeyWithHeadersQueryOnPlainSupplier
+- shouldThrowForTimestampedWindowRangeWithHeadersQueryOnPlainSupplier
org.apache.kafka.streams.integration.IQv2IntegrationTest:
- CLASSIC
- STREAMS
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 3e8139c34c0..fbad04bc770 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -5301,6 +5301,7 @@
org.apache.kafka.streams.state.internals.MeteredSessionStoreWithHeadersTest:
- shouldBackwardFindSessionRangeFromStoreAndRecordFetchMetric
- shouldBackwardFindSessionsFromStoreAndRecordFetchMetric
- shouldCloseInnerStore
+-
shouldDecrementOpenIteratorsTwiceWhenClosedTwiceForTimestampedWindowRangeWithHeadersQuery
- shouldDelegateInit
- shouldDelegateUnknownQueryToWrappedStore
- shouldFailWindowRangeQueryWithoutKey
@@ -5309,8 +5310,12 @@
org.apache.kafka.streams.state.internals.MeteredSessionStoreWithHeadersTest:
- shouldFetchSessionAndReturnValueWithHeaders
- shouldFindSessionRangeFromStoreAndRecordFetchMetric
- shouldFindSessionsFromStoreAndRecordFetchMetric
+- shouldForwardRawKeyQueryForTimestampedWindowRangeWithHeadersQuery
+- shouldHandleTimestampedWindowRangeWithHeadersQueryWithKey
- shouldHandleWindowRangeQueryWithKeyAndUnwrapHeaders
+- shouldPropagateWrappedStoreFailureForTimestampedWindowRangeWithHeadersQuery
- shouldRecordRestoreTime
+- shouldRejectWithWindowStartRangeFormForTimestampedWindowRangeWithHeadersQuery
- shouldRemoveFromStoreAndRecordRemoveMetric
- shouldRemoveMetricsEvenIfWrappedStoreThrowsOnClose
- shouldRemoveMetricsOnClose
@@ -5321,6 +5326,8 @@
org.apache.kafka.streams.state.internals.MeteredSessionStoreWithHeadersTest:
- shouldThrowNullPointerOnPutIfWrappedKeyIsNull
- shouldThrowNullPointerOnRemoveIfKeyIsNull
- shouldTimeIteratorDuration
+- shouldTolerateNullValueForTimestampedWindowRangeWithHeadersQuery
+- shouldTrackNumOpenIteratorsForTimestampedWindowRangeWithHeadersQuery
- shouldTrackOldestOpenIteratorTimestamp
- shouldTrackOpenIteratorsMetric
- shouldUseHeadersFromValueToDeserializeKeyInBackwardFetch
@@ -5406,16 +5413,23 @@
org.apache.kafka.streams.state.internals.MeteredTimestampedWindowStoreTest:
org.apache.kafka.streams.state.internals.MeteredTimestampedWindowStoreWithHeadersTest:
- shouldCloseUnderlyingStore
-
shouldDecrementOpenIteratorsTwiceWhenClosedTwiceForTimestampedWindowKeyWithHeadersQuery
+-
shouldDecrementOpenIteratorsTwiceWhenClosedTwiceForTimestampedWindowRangeWithHeadersQuery
- shouldDelegateInit
- shouldLeaveIteratorOpenWhenNextThrowsAndNotClosed
+-
shouldLeaveIteratorOpenWhenNextThrowsAndNotClosedForTimestampedWindowRangeWithHeadersQuery
- shouldNotExceptionIfFetchReturnsNull
- shouldNotThrowExceptionIfSerdesCorrectlySetFromConstructorParameters
- shouldNotThrowExceptionIfSerdesCorrectlySetFromProcessorContext
- shouldPassChangelogTopicNameToStateStoreSerde
- shouldPassDefaultChangelogTopicNameToStateStoreSerdeIfLoggingDisabled
- shouldPropagateWindowKeyQueryBoundsForTimestampedWindowKeyWithHeadersQuery
+- shouldPropagateWindowRangeBoundsForTimestampedWindowRangeWithHeadersQuery
- shouldPropagateWrappedStoreFailureForTimestampedWindowKeyWithHeadersQuery
+- shouldPropagateWrappedStoreFailureForTimestampedWindowRangeWithHeadersQuery
+- shouldRejectWithKeyFormForTimestampedWindowRangeWithHeadersQuery
+- shouldThrowForNullStoredValueForTimestampedWindowRangeWithHeadersQuery
- shouldTrackNumOpenIteratorsForTimestampedWindowKeyWithHeadersQuery
+- shouldTrackNumOpenIteratorsForTimestampedWindowRangeWithHeadersQuery
- shouldUseHeadersFromValueToDeserializeKeyInAll
- shouldUseHeadersFromValueToDeserializeKeyInBackwardAll
- shouldUseHeadersFromValueToDeserializeKeyInBackwardFetchAll
@@ -5423,6 +5437,7 @@
org.apache.kafka.streams.state.internals.MeteredTimestampedWindowStoreWithHeader
- shouldUseHeadersFromValueToDeserializeKeyInFetchAll
- shouldUseHeadersFromValueToDeserializeKeyInFetchRange
- shouldUseHeadersFromValueToDeserializeKeyInReadOnlyFetchAll
+- shouldUseWindowFromRawResultForTimestampedWindowRangeWithHeadersQuery
org.apache.kafka.streams.state.internals.MeteredVersionedKeyValueStoreTest:
- shouldDelegateAndAddExecutionInfoOnCustomQuery
- shouldDelegateAndRecordMetricsOnCommit
@@ -5764,8 +5779,8 @@
org.apache.kafka.streams.state.internals.RocksDBSessionStoreTest:
- testIteratorPeekBackward
org.apache.kafka.streams.state.internals.RocksDBSessionStoreWithHeadersTest:
- shouldCollectExecutionInfoWhenRequested
+- shouldHandleWindowRangeQuery
- shouldNotCollectExecutionInfoWhenNotRequested
-- shouldReturnUnknownQueryTypeForWindowRangeQuery
org.apache.kafka.streams.state.internals.RocksDBStoreCloseLeakTest:
- shouldCloseColumnFamilyHandlesWhenAccessorPutThrowsDuringClose
- shouldCloseOffsetsCfOptionsOnStoreClose
@@ -5952,8 +5967,8 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionSchemaWithoutI
- stagedWritesShouldNotAdvanceCommittedPositionUntilCommit
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithHeadersTest:
- shouldCollectExecutionInfoWhenRequested
+- shouldHandleWindowRangeQuery
- shouldNotCollectExecutionInfoWhenNotRequested
-- shouldReturnUnknownQueryTypeForWindowRangeQuery
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedSessionStoreWithIndexTest:
- shouldBackwardFetchAllSessionsWithSameRecordKey
- shouldBackwardFetchAllSessionsWithinKeyRange
@@ -6101,8 +6116,8 @@
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowSchemaWithoutIn
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithHeadersTest:
- shouldCollectExecutionInfoWhenRequested
- shouldHandleWindowKeyQuery
+- shouldHandleWindowRangeQuery
- shouldNotCollectExecutionInfoWhenNotRequested
-- shouldReturnUnknownQueryTypeForWindowRangeQuery
org.apache.kafka.streams.state.internals.RocksDBTimeOrderedWindowStoreWithHeadersWithIndexTest:
- shouldBackwardFetchAllInTimeRange
-
shouldCloseOpenIteratorsWhenStoreIsClosedAndNotThrowInvalidStateStoreExceptionOnHasNext
@@ -6508,8 +6523,8 @@
org.apache.kafka.streams.state.internals.RocksDBTimestampedStoreWithHeadersTest:
org.apache.kafka.streams.state.internals.RocksDBTimestampedWindowStoreWithHeadersTest:
- shouldCollectExecutionInfoWhenRequested
- shouldHandleWindowKeyQuery
+- shouldHandleWindowRangeQuery
- shouldNotCollectExecutionInfoWhenNotRequested
-- shouldReturnUnknownQueryTypeForWindowRangeQuery
org.apache.kafka.streams.state.internals.RocksDBTransactionBufferTest:
- shouldAllowStageAfterDeleteRangeToOverride
- shouldCommitRangeDeleteToRocksDB
@@ -6701,6 +6716,24 @@
org.apache.kafka.streams.state.internals.SessionStoreBuilderTest:
- shouldThrowNullPointerIfTimeIsNull
org.apache.kafka.streams.state.internals.SessionStoreFetchTest:
- testStoreConfig
+org.apache.kafka.streams.state.internals.SessionStoreWithHeadersBuilderTest$BuilderTests:
+- shouldHaveCachingAndChangeLoggingWhenBothEnabled
+- shouldHaveCachingStoreWhenEnabled
+- shouldHaveChangeLoggingStoreByDefault
+- shouldHaveChangeLoggingStoreWhenLoggingEnabled
+- shouldHaveMeteredStoreAsOuterStore
+- shouldNotHaveChangeLoggingStoreWhenDisabled
+- shouldNotWrapHeadersByteStore
+- shouldThrowNullPointerIfInnerIsNull
+- shouldWrapPlainStoreAsHeadersStore
+org.apache.kafka.streams.state.internals.SessionStoreWithHeadersBuilderTest$QueryTests:
+-
shouldCollectExecutionInfoForTimestampedWindowRangeWithHeadersQueryWhenRequested
+-
shouldNotCollectExecutionInfoForTimestampedWindowRangeWithHeadersQueryWhenNotRequested
+- shouldNotThrowForPlainSessionStoreSinceTimestampIsSessionWindowEnd
+- shouldRejectWithWindowStartRangeFormAgainstSessionStore
+-
shouldReturnEmptyHeadersForTimestampedWindowRangeWithHeadersQueryOnAdapterStore
+-
shouldReturnHeadersForTimestampedWindowRangeWithHeadersQueryOnHeaderPersistingStore
+- shouldReturnIdenticalResultsForNativeAndAdapterBuiltStores
org.apache.kafka.streams.state.internals.SessionStoreWithHeadersSerializerSideEffectTest:
- shouldPropagateSerializerHeaderSideEffectToChangelog
org.apache.kafka.streams.state.internals.SessionToHeadersIteratorAdapterTest:
@@ -7116,12 +7149,19 @@
org.apache.kafka.streams.state.internals.TimestampedWindowStoreWithHeadersBuilde
- shouldWrapTimestampedStoreAsHeadersStore
org.apache.kafka.streams.state.internals.TimestampedWindowStoreWithHeadersBuilderTest$QueryTests:
-
shouldCollectExecutionInfoForTimestampedWindowKeyWithHeadersQueryWhenRequested
+-
shouldCollectExecutionInfoForTimestampedWindowRangeWithHeadersQueryWhenRequested
-
shouldNotCollectExecutionInfoForTimestampedWindowKeyWithHeadersQueryWhenNotRequested
+-
shouldNotCollectExecutionInfoForTimestampedWindowRangeWithHeadersQueryWhenNotRequested
- shouldReturnEmptyHeadersForTimestampedWindowKeyWithHeadersQueryOnAdapterStore
+-
shouldReturnEmptyHeadersForTimestampedWindowRangeWithHeadersQueryOnAdapterStore
-
shouldReturnHeadersForTimestampedWindowKeyWithHeadersQueryOnHeaderPersistingStore
-- shouldReturnIdenticalResultsForNativeAndAdapterBuiltStores
+-
shouldReturnHeadersForTimestampedWindowRangeWithHeadersQueryOnHeaderPersistingStore
+- shouldReturnIdenticalResultsForNativeAndAdapterBuiltStoresForWindowKeyQuery
+- shouldReturnIdenticalResultsForNativeAndAdapterBuiltStoresForWindowRangeQuery
- shouldThrowForNegativeStoredTimestampForTimestampedWindowKeyWithHeadersQuery
+-
shouldThrowForNegativeStoredTimestampForTimestampedWindowRangeWithHeadersQuery
- shouldThrowForTimestampedWindowKeyWithHeadersQueryOnPlainSupplier
+- shouldThrowForTimestampedWindowRangeWithHeadersQueryOnPlainSupplier
org.apache.kafka.streams.state.internals.TimestampedWindowStoreWithHeadersSerializerSideEffectTest:
- shouldPropagateSerializerHeaderSideEffectToChangelog
org.apache.kafka.streams.state.internals.UtilsTest:
