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 26a816f06b7 Update test catalog data for GHA workflow run 12368954301
26a816f06b7 is described below
commit 26a816f06b7746a5cad21b36540bb4d9d7f382ff
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 17 12:07:46 2024 +0000
Update test catalog data for GHA workflow run 12368954301
Commit:
https://github.com/apache/kafka/commit/337fb8cec17b627bc6bf53a892462662fe51d802
GitHub Run: https://github.com/apache/kafka/actions/runs/12368954301
---
test-catalog/generator/tests.yaml | 116 +++++++
test-catalog/raft/tests.yaml | 11 -
test-catalog/streams/integration-tests/tests.yaml | 362 ---------------------
.../test-common/test-common-runtime/tests.yaml | 12 +
4 files changed, 128 insertions(+), 373 deletions(-)
diff --git a/test-catalog/generator/tests.yaml
b/test-catalog/generator/tests.yaml
new file mode 100644
index 00000000000..00bdef21f6c
--- /dev/null
+++ b/test-catalog/generator/tests.yaml
@@ -0,0 +1,116 @@
+org.apache.kafka.message.CodeBufferTest:
+- testEquals
+- testIndentMustBeNonNegative
+- testWrite
+org.apache.kafka.message.EntityTypeTest:
+- testUnknownEntityType
+- testVerifyTypeMatches
+- testVerifyTypeMismatches
+org.apache.kafka.message.IsNullConditionalTest:
+- testAnotherNullCheck
+- testNeverNull
+- testNeverNullWithBlockScope
+- testNotNullCheck
+- testNullCheck
+org.apache.kafka.message.MessageDataGeneratorTest:
+- testDuplicateTags
+- testInvalidFieldName
+- testInvalidFlexibleVersionsRange
+- testInvalidNegativeTag
+- testInvalidNullDefaultForInt
+- testInvalidNullDefaultForNullableStruct
+- testInvalidNullDefaultForPotentiallyNonNullableArray
+- testInvalidNullDefaultForPotentiallyNonNullableStruct
+- testInvalidSometimesNullableTaggedField
+- testInvalidTagWithoutTaggedVersions
+- testInvalidTaggedVersionsNotASubsetOfVersions
+- testInvalidTaggedVersionsRange
+- testInvalidTaggedVersionsWithoutTag
+- testNullDefaults
+- testNullDefaultsWithDeprecatedVersions
+org.apache.kafka.message.MessageGeneratorTest:
+- stripSuffixTest
+- testCapitalizeFirst
+- testConstants
+- testFirstIsCapitalized
+- testLowerCaseFirst
+- testToSnakeCase
+org.apache.kafka.message.StructRegistryTest:
+- testCommonStructs
+- testDuplicateCommonStructError
+- testReSpecifiedCommonStructError
+- testSingleStruct
+org.apache.kafka.message.StructSpecTest:
+- testNamesMustBeUnique
+- testTagsMustBeUnique
+org.apache.kafka.message.VersionConditionalTest:
+- testAllowMembershipCheckAlwaysFalseFails
+- testAlwaysFalseConditional
+- testAlwaysTrueConditional
+- testAlwaysTrueConditionalWithAlwaysEmitBlockScope
+- testAnotherAlwaysFalseConditional
+- testFullRangeCheck
+- testLowerRangeCheckWithElse
+- testLowerRangeCheckWithIfMember
+- testLowerRangeCheckWithIfNotMember
+- testUpperRangeCheckWithElse
+- testUpperRangeCheckWithIfMember
+- testUpperRangeCheckWithIfNotMember
+org.apache.kafka.message.VersionsTest:
+- testContains
+- testIntersections
+- testRoundTrips
+- testSubtract
+- testVersionsParse
+org.apache.kafka.message.checker.CheckerUtilsTest:
+- testMax0and1
+- testMax1and0
+- testMax5and5
+- testMin0and1
+- testMin1and0
+- testMin5and5
+- testReadMessageSpecFromFile
+- testValidateTaggedVersionsOnNontaggedField
+- testValidateTaggedVersionsOnTaggedField
+- testValidateTaggedVersionsOnTaggedFieldWithError
+org.apache.kafka.message.checker.EvolutionVerifierTest:
+- testFieldNullableVersionsMustBeInsideTopLevelVersion
+- testFieldTaggedVersionsMustBeInsideTopLevelVersion
+- testFieldVersionsMustBeInsideTopLevelVersion
+- testFlexibleVersionsIsNotASubset
+- testIncompatibleFieldTypeChange
+- testMaximumVersionOfInitialMessageIsHigher
+- testMinimumVersionOfInitialMessageIsHigher
+- testNewFieldAddition
+- testTopLevelMessageApiKeysDoNotMatch
+- testTopLevelMessageTypesDoNotMatch
+org.apache.kafka.message.checker.FieldDomainTest:
+- testBoth
+- testMessage1Only
+- testMessage2Only
+- testNeither
+org.apache.kafka.message.checker.MetadataSchemaCheckerToolTest:
+- testSuccessfulParse
+- testSuccessfulVerifyEvolution
+- testVerifyEvolutionGit
+org.apache.kafka.message.checker.UnifierTest:
+- testAddNewField
+- testArrayElementTypesDoNotMatch
+- testArrayFieldTypesMatch
+- testDefaultsChangedCausesFailure
+- testDefaultsCheckPasses
+- testFieldTypesDoNotMatch
+- testFieldTypesMatch
+- testFlexibleVersionsChangedCausesFailure1
+- testFlexibleVersionsChangedCausesFailure2
+- testFlexibleVersionsCheckPasses
+- testMaximumValidVersionForField2IsLowerThanField1
+- testMaximumValidVersionForIsReasonable1
+- testMaximumValidVersionForIsReasonable2
+- testMinimumValidVersionForField2IsHigherThanField1
+- testMinimumValidVersionForField2IsLowerThanField1
+- testMinimumValidVersionForField2IsLowerThanField1Again
+- testNullableVersionsCheckFails1
+- testNullableVersionsCheckFails2
+- testNullableVersionsCheckPasses1
+- testNullableVersionsCheckPasses2
diff --git a/test-catalog/raft/tests.yaml b/test-catalog/raft/tests.yaml
index b792c5ed744..fd62b1fd09c 100644
--- a/test-catalog/raft/tests.yaml
+++ b/test-catalog/raft/tests.yaml
@@ -457,14 +457,6 @@ org.apache.kafka.raft.QuorumStateTest:
- testUnattachedVotedToUnattachedHigherEpoch
- testUnattachedVotedToUnattachedSameEpoch
- testUnattachedVotedToUnattachedVotedSameEpoch
-org.apache.kafka.raft.RaftEventSimulationTest:
-- canElectInitialLeader
-- canElectNewLeaderAfterOldLeaderFailure
-- canElectNewLeaderAfterOldLeaderPartitionedAway
-- canMakeProgressAfterBackToBackLeaderFailures
-- canMakeProgressIfMajorityIsReachable
-- canRecoverAfterAllNodesKilled
-- canRecoverFromSingleNodeCommittedDataLoss
org.apache.kafka.raft.RaftUtilTest:
- testErrorResponse
- testSingletonBeginQuorumEpochRequestForAllVersion
@@ -585,10 +577,7 @@ org.apache.kafka.raft.internals.RecordsIteratorTest:
- testControlRecordIterationWithKraftVersion0
- testControlRecordIterationWithKraftVersion1
- testControlRecordTypeValues
-- testCrcValidation
- testEmptyRecords
-- testFileRecords
-- testMemoryRecords
- testWithAllSupportedControlRecords
org.apache.kafka.raft.internals.ThresholdPurgatoryTest:
- testCompleteAll
diff --git a/test-catalog/streams/integration-tests/tests.yaml
b/test-catalog/streams/integration-tests/tests.yaml
deleted file mode 100644
index fb18d166202..00000000000
--- a/test-catalog/streams/integration-tests/tests.yaml
+++ /dev/null
@@ -1,362 +0,0 @@
-org.apache.kafka.streams.integration.AdjustStreamThreadCountTest:
-- shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect
-- shouldAddAndRemoveThreadsMultipleTimes
-- shouldAddStreamThread
-- shouldRemoveStreamThread
-- shouldRemoveStreamThreadWithStaticMembership
-- shouldResizeCacheAfterThreadRemovalTimesOut
-- shouldResizeCacheAfterThreadReplacement
-- shouldnNotRemoveStreamThreadWithinTimeout
-- testConcurrentlyAccessThreads
-- testRebalanceHappensBeforeStreamThreadGetDown
-org.apache.kafka.streams.integration.ConsistencyVectorIntegrationTest:
-- shouldHaveSamePositionBoundActiveAndStandBy
-org.apache.kafka.streams.integration.EOSUncleanShutdownIntegrationTest:
-- shouldWorkWithUncleanShutdownWipeOutStateStore
-org.apache.kafka.streams.integration.EmitOnChangeIntegrationTest:
-- shouldEmitSameRecordAfterFailover
-org.apache.kafka.streams.integration.EosIntegrationTest:
-- shouldBeAbleToCommitMultiplePartitionOffsets
-- shouldBeAbleToCommitToMultiplePartitions
-- shouldBeAbleToPerformMultipleTransactions
-- shouldBeAbleToRestartAfterClose
-- shouldBeAbleToRunWithEosEnabled
-- shouldBeAbleToRunWithTwoSubtopologies
-- shouldBeAbleToRunWithTwoSubtopologiesAndMultiplePartitions
--
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoringStateUpdaterDisabled
--
shouldCheckpointRestoredOffsetsWhenClosingCleanDuringRestoringStateUpdaterEnabled
-- shouldCommitCorrectOffsetIfInputTopicIsTransactional
-- shouldNotViolateEosIfOneTaskFails
-- shouldNotViolateEosIfOneTaskFailsWithState
-- shouldNotViolateEosIfOneTaskGetsFencedUsingIsolatedAppInstances
-- shouldWriteLatestOffsetsToCheckpointOnShutdown
-org.apache.kafka.streams.integration.FineGrainedAutoResetIntegrationTest:
-- shouldFailForResetNone
-- shouldOnlyReadRecordsWhereEarliestSpecifiedWithInvalidCommittedOffsets
--
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithDefaultGlobalAutoOffsetResetEarliest
--
shouldOnlyReadRecordsWhereEarliestSpecifiedWithNoCommittedOffsetsWithGlobalAutoOffsetResetLatest
-- shouldResetByDuration
-- shouldThrowExceptionOverlappingPattern
-- shouldThrowExceptionOverlappingTopic
-- shouldThrowStreamsExceptionNoResetSpecified
-org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest:
-- shouldKStreamGlobalKTableJoin
-- shouldKStreamGlobalKTableLeftJoin
-- shouldNotRestoreAbortedMessages
-- shouldRestoreTransactionalMessages
-- shouldSkipOverAbortedMessagesOnRestore
-- shouldSkipOverTxMarkersOnRestore
-org.apache.kafka.streams.integration.GlobalKTableIntegrationTest:
-- shouldGetToRunningWithOnlyGlobalTopology
-- shouldKStreamGlobalKTableJoin
-- shouldKStreamGlobalKTableLeftJoin
-- shouldRestoreGlobalInMemoryKTableOnRestart
-org.apache.kafka.streams.integration.GlobalStateReprocessTest:
-- shouldReprocessWithUserProvidedStore
-org.apache.kafka.streams.integration.GlobalThreadShutDownOrderTest:
-- shouldFinishGlobalStoreOperationOnShutDown
-org.apache.kafka.streams.integration.HandlingSourceTopicDeletionIntegrationTest:
-- shouldThrowErrorAfterSourceTopicDeleted
-org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest:
-- shouldScaleOutWithWarmupTasksAndInMemoryStores
-- shouldScaleOutWithWarmupTasksAndPersistentStores
-org.apache.kafka.streams.integration.IQv2IntegrationTest:
-- shouldFailNotStarted
-- shouldFailStopped
-- shouldFailUnknownStore
-- shouldFetchExplicitlyFromAllPartitions
-- shouldFetchFromPartition
-- shouldNotRequireQueryHandler
-- shouldRejectNonRunningActive
-org.apache.kafka.streams.integration.IQv2StoreIntegrationTest:
-- verifyStore
-org.apache.kafka.streams.integration.IQv2VersionedStoreIntegrationTest:
-- verifyStore
-org.apache.kafka.streams.integration.InternalTopicIntegrationTest:
-- shouldCompactAndDeleteTopicsForWindowStoreChangelogs
-- shouldCompactTopicsForKeyValueStoreChangelogs
-- shouldGetToRunningWithWindowedTableInFKJ
-org.apache.kafka.streams.integration.JoinGracePeriodDurabilityIntegrationTest:
-- shouldRecoverBufferAfterShutdown
-org.apache.kafka.streams.integration.JoinStoreIntegrationTest:
-- providingAJoinStoreNameShouldNotMakeTheJoinResultQueryable
-- streamJoinChangelogTopicShouldBeConfiguredWithDeleteOnlyCleanupPolicy
-org.apache.kafka.streams.integration.JoinWithIncompleteMetadataIntegrationTest:
-- testShouldAutoShutdownOnJoinWithIncompleteMetadata
-org.apache.kafka.streams.integration.KStreamAggregationDedupIntegrationTest:
-- shouldGroupByKey
-- shouldReduce
-- shouldReduceWindowed
-org.apache.kafka.streams.integration.KStreamAggregationIntegrationTest:
-- shouldAggregate
-- shouldAggregateSlidingWindows
-- shouldAggregateWindowed
-- shouldCount
-- shouldCountSessionWindows
-- shouldCountUnlimitedWindows
-- shouldCountWithInternalStore
-- shouldGroupByKey
-- shouldReduce
-- shouldReduceSessionWindows
-- shouldReduceSlidingWindows
-- shouldReduceWindowed
-org.apache.kafka.streams.integration.KStreamKStreamIntegrationTest:
-- shouldOuterJoin
-org.apache.kafka.streams.integration.KStreamRepartitionIntegrationTest:
-- shouldCreateOnlyOneRepartitionTopicWhenRepartitionIsFollowedByGroupByKey
-- shouldCreateRepartitionTopicIfKeyChangingOperationWasNotPerformed
-- shouldCreateRepartitionTopicWithSpecifiedNumberOfPartitions
-- shouldDeductNumberOfPartitionsFromRepartitionOperation
--
shouldDoProperJoiningWhenNumberOfPartitionsAreValidWhenUsingRepartitionOperation
-- shouldGenerateRepartitionTopicWhenNameIsNotSpecified
-- shouldGoThroughRebalancingCorrectly
--
shouldInheritRepartitionTopicPartitionNumberFromUpstreamTopicWhenNumberOfPartitionsIsNotSpecified
-- shouldPerformKeySelectOperationWhenRepartitionOperationIsUsedWithKeySelector
-- shouldPerformSelectKeyWithRepartitionOperation
-- shouldRepartitionToMultiplePartitions
--
shouldThrowAnExceptionWhenNumberOfPartitionsOfRepartitionOperationDoNotMatchSourceTopicWhenJoining
-- shouldUseStreamPartitionerForRepartitionOperation
-org.apache.kafka.streams.integration.KTableEfficientRangeQueryTest:
-- testStoreConfig
-org.apache.kafka.streams.integration.KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest:
-- shouldInnerJoinMultiPartitionQueryable
--
shouldThrowIllegalArgumentExceptionWhenCustomPartitionerReturnsMultiplePartitions
-org.apache.kafka.streams.integration.KTableKTableForeignKeyInnerJoinMultiIntegrationTest:
-- shouldInnerJoinMultiPartitionQueryable
-org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinDistributedTest:
-- shouldBeInitializedWithDefaultSerde
-org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinIntegrationTest:
-- doJoinFromLeftThenDeleteLeftEntity
-- doJoinFromRightThenDeleteRightEntity
-- joinShouldProduceNullsWhenValueHasNonMatchingForeignKey
-- shouldEmitRecordOnNullForeignKeyForLeftJoins
-- shouldEmitRecordWhenOldAndNewFkDiffer
-- shouldEmitTombstoneWhenDeletingNonJoiningRecords
-- shouldIgnoreOutOfOrderRecordsIffVersioned
-- shouldNotEmitTombstonesWhenDeletingNonExistingRecords
-- shouldUnsubscribeOldForeignKeyIfLeftSideIsUpdated
-org.apache.kafka.streams.integration.KTableKTableForeignKeyJoinMaterializationIntegrationTest:
-- shouldEmitTombstoneWhenDeletingNonJoiningRecords
-org.apache.kafka.streams.integration.KTableSourceTopicRestartIntegrationTest:
-- shouldRestoreAndProgressWhenTopicNotWrittenToDuringRestoration
-- shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosDisabled
-- shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosV2Enabled
-org.apache.kafka.streams.integration.KafkaStreamsCloseOptionsIntegrationTest:
-- testCloseOptions
-org.apache.kafka.streams.integration.KafkaStreamsTelemetryIntegrationTest:
-- passedMetricsShouldNotLeakIntoClientMetrics
-- shouldPassCorrectMetricsDynamicInstances
-- shouldPassMetrics
-- shouldPushMetricsToBroker
-org.apache.kafka.streams.integration.LagFetchIntegrationTest:
-- shouldFetchLagsDuringRebalancingWithNoOptimization
-- shouldFetchLagsDuringRebalancingWithOptimization
-- shouldFetchLagsDuringRestoration
-org.apache.kafka.streams.integration.MetricsIntegrationTest:
-- shouldAddMetricsForSessionStore
-- shouldAddMetricsForWindowStoreAndSuppressionBuffer
-- shouldAddMetricsOnAllLevels
-org.apache.kafka.streams.integration.MetricsReporterIntegrationTest:
-- shouldBeAbleToProvideInitialMetricValueToMetricsReporter
-org.apache.kafka.streams.integration.NamedTopologyIntegrationTest:
-- shouldAddNamedTopologyToRunningApplicationWithEmptyInitialTopology
-- shouldAddNamedTopologyToRunningApplicationWithMultipleNodes
-- shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopology
--
shouldAddToEmptyInitialTopologyRemoveResetOffsetsThenAddSameNamedTopologyWithRepartitioning
-- shouldAllowMixedCollectionAndPatternSubscriptionWithMultipleNamedTopologies
-- shouldAllowPatternSubscriptionWithMultipleNamedTopologies
--
shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMultipleNodesAndResetsOffsets
-- shouldPrefixAllInternalTopicNamesWithNamedTopology
--
shouldProcessMultipleIdenticalNamedTopologiesWithInMemoryAndPersistentStateStores
-- shouldProcessSingleNamedTopologyAndPrefixInternalTopics
-- shouldRemoveAndReplaceTopologicallyIncompatibleNamedTopology
-org.apache.kafka.streams.integration.OptimizedKTableIntegrationTest:
-- shouldApplyUpdatesToStandbyStore
-org.apache.kafka.streams.integration.PauseResumeIntegrationTest:
-- pauseResumeShouldWorkAcrossInstances
-- pausedTopologyShouldNotRestoreStateStores
-- shouldAllowForNamedTopologiesToStartPaused
-- shouldAllowForTopologiesToStartPaused
-- shouldPauseAndResumeAllKafkaStreamsWithNamedTopologies
-- shouldPauseAndResumeKafkaStreams
-- shouldPauseAndResumeKafkaStreamsWithNamedTopologies
-org.apache.kafka.streams.integration.PositionRestartIntegrationTest:
-- verifyStore
-org.apache.kafka.streams.integration.ProcessingExceptionHandlerIntegrationTest:
--
shouldContinueWhenProcessingExceptionOccursFromFlushingCacheIfExceptionHandlerReturnsContinue
-- shouldContinueWhenProcessingExceptionOccursIfExceptionHandlerReturnsContinue
--
shouldFailWhenProcessingExceptionOccursFromFlushingCacheIfExceptionHandlerReturnsFail
-- shouldFailWhenProcessingExceptionOccursIfExceptionHandlerReturnsFail
--
shouldStopOnFailedProcessorWhenProcessingExceptionOccursInContinueProcessingExceptionHandler
--
shouldStopOnFailedProcessorWhenProcessingExceptionOccursInFailProcessingExceptionHandler
-- shouldStopProcessingWhenFatalUserExceptionProcessingExceptionHandler
-- shouldStopProcessingWhenProcessingExceptionHandlerReturnsNull
-org.apache.kafka.streams.integration.PurgeRepartitionTopicIntegrationTest:
-- shouldRestoreState
-org.apache.kafka.streams.integration.QueryableStateIntegrationTest:
-- shouldAllowToQueryAfterThreadDied
-- shouldBeAbleQueryStandbyStateDuringRebalance
-- shouldBeAbleToQueryDuringRebalance
-- shouldBeAbleToQueryFilterState
-- shouldBeAbleToQueryKeysWithGivenPrefix
-- shouldBeAbleToQueryMapValuesAfterFilterState
-- shouldBeAbleToQueryMapValuesState
-- shouldBeAbleToQueryStateWithNonZeroSizedCache
-- shouldBeAbleToQueryStateWithZeroSizedCache
-- shouldNotMakeStoreAvailableUntilAllStoresAvailable
-- shouldRejectNonExistentStoreName
-- shouldRejectWronglyTypedStore
-org.apache.kafka.streams.integration.RangeQueryIntegrationTest:
-- testStoreConfig
-org.apache.kafka.streams.integration.RegexSourceIntegrationTest:
-- shouldAddStateStoreToRegexDefinedSource
-- testMultipleConsumersCanReadFromPartitionedTopic
-- testNoMessagesSentExceptionFromOverlappingPatterns
-- testRegexMatchesTopicsAWhenCreated
-- testRegexMatchesTopicsAWhenDeleted
-- testRegexRecordsAreProcessedAfterNewTopicCreatedWithMultipleSubtopologies
-- testShouldReadFromRegexAndNamedTopics
-org.apache.kafka.streams.integration.RelaxedNullKeyRequirementJoinTest:
-- testDropNullKeyRecordsForRepartitionNodesWithNoRelaxedJoinDownstream
-- testRelaxedLeftStreamGlobalTableJoin
-- testRelaxedLeftStreamStreamJoin
-- testRelaxedLeftStreamTableJoin
-- testRelaxedOuterStreamStreamJoin
-org.apache.kafka.streams.integration.ResetPartitionTimeIntegrationTest:
-- shouldPreservePartitionTimeOnKafkaStreamRestart
-org.apache.kafka.streams.integration.RestoreIntegrationTest:
-- shouldInvokeUserDefinedGlobalStateRestoreListener
-- shouldProcessDataFromStoresWithLoggingDisabled
-- shouldRecycleStateFromStandbyTaskPromotedToActiveTaskAndNotRestore
-- shouldRestoreNullRecord
-- shouldRestoreStateFromChangelogTopic
-- shouldRestoreStateFromSourceTopicForGlobalTable
-- shouldRestoreStateFromSourceTopicForReadOnlyStore
-- shouldSuccessfullyStartWhenLoggingDisabled
-org.apache.kafka.streams.integration.RocksDBMetricsIntegrationTest:
-- shouldExposeRocksDBMetricsBeforeAndAfterFailureWithEmptyStateDir
-org.apache.kafka.streams.integration.SelfJoinUpgradeIntegrationTest:
-- shouldRestartWithTopologyOptimizationOn
-- shouldUpgradeWithTopologyOptimizationOff
-org.apache.kafka.streams.integration.SlidingWindowedKStreamIntegrationTest:
-- shouldAggregateWindowedWithGrace
-- shouldAggregateWindowedWithNoGrace
-- shouldRestoreAfterJoinRestart
-org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest:
-- shouldWorkWithRebalance
-org.apache.kafka.streams.integration.StandbyTaskCreationIntegrationTest:
-- shouldCreateStandByTasksForMaterializedAndOptimizedSourceTables
-- shouldNotCreateAnyStandByTasksForStateStoreWithLoggingDisabled
-org.apache.kafka.streams.integration.StandbyTaskEOSIntegrationTest:
-- shouldSurviveWithOneTaskAsStandby
-- shouldWipeOutStandbyStateDirectoryIfCheckpointIsMissing
-org.apache.kafka.streams.integration.StandbyTaskEOSMultiRebalanceIntegrationTest:
-- shouldHonorEOSWhenUsingCachingAndStandbyReplicas
-org.apache.kafka.streams.integration.StateDirectoryIntegrationTest:
-- testCleanUpStateDirIfEmpty
-- testNotCleanUpStateDirIfNotEmpty
-org.apache.kafka.streams.integration.StoreQueryIntegrationTest:
--
shouldFailWithIllegalArgumentExceptionWhenIQPartitionerReturnsMultiplePartitions
-- shouldQueryAllStalePartitionStores
-- shouldQueryOnlyActivePartitionStoresByDefault
-- shouldQuerySpecificActivePartitionStores
-- shouldQuerySpecificStalePartitionStores
-- shouldQuerySpecificStalePartitionStoresMultiStreamThreads
-- shouldQuerySpecificStalePartitionStoresMultiStreamThreadsNamedTopology
-- shouldQueryStoresAfterAddingAndRemovingStreamThread
-org.apache.kafka.streams.integration.StoreUpgradeIntegrationTest:
-- shouldMigrateInMemoryKeyValueStoreToTimestampedKeyValueStoreUsingPapi
-- shouldMigrateInMemoryWindowStoreToTimestampedWindowStoreUsingPapi
-- shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi
-- shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi
-- shouldProxyKeyValueStoreToTimestampedKeyValueStoreUsingPapi
-- shouldProxyWindowStoreToTimestampedWindowStoreUsingPapi
-org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest:
-- testInner
-- testInnerRepartitioned
-- testLeft
-- testLeftRepartitioned
-- testMultiInner
-- testOuter
-- testOuterRepartitioned
-- testSelfJoin
-org.apache.kafka.streams.integration.StreamTableJoinIntegrationTest:
-- testInner
-- testInnerWithVersionedStore
-- testLeft
-- testLeftWithVersionedStore
-org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest:
-- shouldDoStreamTableJoinWithDifferentNumberOfPartitions
-org.apache.kafka.streams.integration.StreamTableJoinWithGraceIntegrationTest:
-- testInnerWithVersionedStore
-- testLeftWithVersionedStore
-org.apache.kafka.streams.integration.StreamToTableJoinScalaIntegrationTestImplicitSerdes:
-- testShouldCountClicksPerRegion
-- testShouldCountClicksPerRegionJava
-- testShouldCountClicksPerRegionWithNamedRepartitionTopic
-org.apache.kafka.streams.integration.StreamsUncaughtExceptionHandlerIntegrationTest:
-- shouldEmitSameRecordAfterFailover
-- shouldReplaceSingleThread
-- shouldReplaceThreads
-- shouldReplaceThreadsWithoutJavaHandler
-- shouldShutDownClientIfGlobalStreamThreadWantsToReplaceThread
-- shouldShutdownClient
-- shouldShutdownMultipleThreadApplication
-- shouldShutdownSingleThreadApplication
-org.apache.kafka.streams.integration.StreamsUpgradeTestIntegrationTest:
-- testVersionProbingUpgrade
-org.apache.kafka.streams.integration.SuppressionDurabilityIntegrationTest:
-- shouldRecoverBufferAfterShutdown
-org.apache.kafka.streams.integration.SuppressionIntegrationTest:
-- shouldAllowDisablingChangelog
-- shouldAllowOverridingChangelogConfig
-- shouldCreateChangelogByDefault
-- shouldInheritSerdes
-- shouldShutdownWhenBytesConstraintIsViolated
-- shouldShutdownWhenRecordConstraintIsViolated
-- shouldUseDefaultSerdes
-org.apache.kafka.streams.integration.SwallowUnknownTopicErrorIntegrationTest:
-- shouldThrowStreamsExceptionWithMissingTopicAndDefaultExceptionHandler
-org.apache.kafka.streams.integration.TableTableJoinIntegrationTest:
-- testInner
-- testInnerInner
-- testInnerLeft
-- testInnerOuter
-- testInnerWithLeftVersionedOnly
-- testInnerWithRightVersionedOnly
-- testInnerWithVersionedStores
-- testLeft
-- testLeftInner
-- testLeftLeft
-- testLeftOuter
-- testLeftWithLeftVersionedOnly
-- testLeftWithRightVersionedOnly
-- testLeftWithVersionedStores
-- testOuter
-- testOuterInner
-- testOuterLeft
-- testOuterOuter
-- testOuterWithLeftVersionedOnly
-- testOuterWithRightVersionedOnly
-- testOuterWithVersionedStores
-org.apache.kafka.streams.integration.TaskAssignorIntegrationTest:
-- shouldProperlyConfigureTheAssignor
-org.apache.kafka.streams.integration.TaskMetadataIntegrationTest:
-- shouldReportCorrectCommittedOffsetInformation
-- shouldReportCorrectEndOffsetInformation
-org.apache.kafka.streams.integration.TimeWindowedKStreamIntegrationTest:
-- shouldAggregateWindowedWithGrace
-- shouldAggregateWindowedWithNoGrace
-- shouldRestoreAfterJoinRestart
-- shouldThrowUnlimitedWindows
-org.apache.kafka.streams.integration.VersionedKeyValueStoreIntegrationTest:
-- shouldAllowCustomIQv2ForCustomStoreImplementations
-- shouldManualUpgradeFromNonVersionedNonTimestampedToVersioned
-- shouldManualUpgradeFromNonVersionedTimestampedToVersioned
-- shouldPutGetAndDelete
-- shouldRestore
-- shouldSetChangelogTopicProperties
-org.apache.kafka.streams.integration.WordCountTest:
-- testShouldCountWords
-- testShouldCountWordsJava
-- testShouldCountWordsMaterialized
diff --git a/test-catalog/test-common/test-common-runtime/tests.yaml
b/test-catalog/test-common/test-common-runtime/tests.yaml
new file mode 100644
index 00000000000..140e3c44fc7
--- /dev/null
+++ b/test-catalog/test-common/test-common-runtime/tests.yaml
@@ -0,0 +1,12 @@
+org.apache.kafka.common.test.junit.AutoQuarantinedTestFilterTest:
+- testEmptyCatalog
+- testLoadCatalog
+- testMissingCatalog
+org.apache.kafka.common.test.junit.QuarantinedPostDiscoveryFilterTest:
+- testExistingTestFlaky
+- testExistingTestNonFlaky
+- testNewTest
+- testNoCatalogQuarantinedTest
+- testQuarantinedExistingTestFlaky
+- testQuarantinedExistingTestNonFlaky
+- testQuarantinedNewTest
