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 cdf524bccf5 Update test catalog data for GHA workflow run 23277788666
cdf524bccf5 is described below
commit cdf524bccf538c601e6ebc477d23825966791ec6
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Mar 19 05:42:53 2026 +0000
Update test catalog data for GHA workflow run 23277788666
Commit:
https://github.com/apache/kafka/commit/599d55cdb7298eeddc81f89af626fc9110bc194b
GitHub Run: https://github.com/apache/kafka/actions/runs/23277788666
---
test-catalog/streams/tests.yaml | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index 7372d4ccf0c..24cf8a5f3a4 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -1893,6 +1893,7 @@
org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest:
- shouldNotRetryWhenEndOffsetsThrowsTimeoutExceptionAndTaskTimeoutIsZero
- shouldNotRetryWhenPartitionsForThrowsTimeoutExceptionAndTaskTimeoutIsZero
- shouldNotRetryWhenPositionThrowsTimeoutExceptionAndTaskTimeoutIsZero
+- shouldNotWriteDowngradeCheckpointOnCloseWhenUpgradeFromIsNull
- shouldReadCheckpointOffsets
- shouldRestoreRecordsFromCheckpointToHighWatermark
- shouldRestoreRecordsUpToHighwatermark
@@ -1914,6 +1915,7 @@
org.apache.kafka.streams.processor.internals.GlobalStateManagerImplTest:
- shouldThrowStreamsExceptionIfFailedToReadCheckpointedOffsets
- shouldThrowStreamsExceptionIfNoPartitionsFoundForStore
-
shouldUsePollMsPlusRequestTimeoutInPollDuringRestoreAndTimeoutWhenNoProgressDuringRestore
+- shouldWriteDowngradeCheckpointOnCloseWhenUpgradeFromIsPre43
org.apache.kafka.streams.processor.internals.GlobalStateTaskTest:
- shouldCommitDuringClose
- shouldCommitDuringInitialization
@@ -2261,6 +2263,7 @@
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldCloseStateStoresOnStateManagerClose
- shouldCommitAndCloseLegacyStores
- shouldCommitGoodStoresEvenSomeThrowsException
+- shouldExcludeCorruptedStoresFromDowngradeCheckpoint
- shouldFindSingleStoreForChangelog
- shouldGetChangelogPartitionForRegisteredStore
- shouldGetRegisteredStore
@@ -2271,6 +2274,7 @@
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldNotThrowTaskCorruptedExceptionAfterCheckpointing
- shouldNotThrowTaskCorruptedWithoutInMemoryStoreCheckpointAndNonEmptyDir
- shouldNotWriteCheckpointForStoresWithoutChangelogTopic
+- shouldNotWriteDowngradeCheckpointOnCloseWhenUpgradeFromIsNull
- shouldOverrideOffsetsWhenRestoreAndProcess
- shouldPreserveStreamsExceptionOnCloseIfStoreThrows
- shouldPreserveStreamsExceptionOnCommitIfStoreThrows
@@ -2301,6 +2305,7 @@
org.apache.kafka.streams.processor.internals.ProcessorStateManagerTest:
- shouldThrowProcessorStateExceptionOnCommitIfStoreThrowsAnException
-
shouldThrowProcessorStateExceptionOnFlushCacheIfStoreThrowsAFailedProcessingException
- shouldThrowTaskCorruptedWithoutPersistentStoreCheckpointAndNonEmptyDir
+- shouldWriteDowngradeCheckpointOnCloseWhenUpgradeFromIsPre43
- shouldWritePositionCheckpointFile
org.apache.kafka.streams.processor.internals.ProcessorTopologyTest:
- inMemoryStoreShouldNotResultInPersistentLocalStore
@@ -4696,6 +4701,7 @@
org.apache.kafka.streams.state.internals.LegacyCheckpointingStateStoreTest:
- shouldAcceptNullOffsets
- shouldBeNoOpForMigrationWhenNoLegacyFileExists
- shouldBeNoOpForNonLCSSStoreInMaybeMarkCorrupted
+- shouldBeNoOpWhenUpgradeFromIsNull
- shouldCloseWrappedStoreOnClose
- shouldCommitWhenOldOffsetIsNull
- shouldDeleteCheckpointFileAfterInitUnderEOS
@@ -4739,6 +4745,10 @@
org.apache.kafka.streams.state.internals.LegacyCheckpointingStateStoreTest:
- shouldWriteCheckpointOnClose
- shouldWriteCheckpointOnCloseUnderEOS
- shouldWriteCommittedOffsetsToCheckpointFile
+- shouldWriteDowngradeCheckpointForAllPre43Versions
+- shouldWriteDowngradeCheckpointForGlobalStore
+- shouldWriteDowngradeCheckpointWhenUpgradeFromIsPre43
+- shouldWriteNullOffsetsAsOffsetUnknownInDowngradeCheckpoint
org.apache.kafka.streams.state.internals.ListValueStoreTest:
- shouldAllowDeleteWhileIterateRecords
- shouldGetAll
