You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gi...@apache.org on 2024/12/09 06:23:09 UTC

(kafka) branch test-catalog updated: Update test catalog data for GHA workflow run 12228785093

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 3cb23c2fd20 Update test catalog data for GHA workflow run 12228785093
3cb23c2fd20 is described below

commit 3cb23c2fd2037d8e40a23131d8cc9505bd04b075
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Mon Dec 9 06:23:02 2024 +0000

    Update test catalog data for GHA workflow run 12228785093
    
    Commit: https://github.com/apache/kafka/commit/d5c202943473f152a77c9c7096317d13f89ece0a
    GitHub Run: https://github.com/apache/kafka/actions/runs/12228785093
---
 test-catalog/streams/streams-scala/tests.yaml |  3 +--
 test-catalog/streams/tests.yaml               | 38 +--------------------------
 2 files changed, 2 insertions(+), 39 deletions(-)

diff --git a/test-catalog/streams/streams-scala/tests.yaml b/test-catalog/streams/streams-scala/tests.yaml
index 1307cc7a60e..eca063996a7 100644
--- a/test-catalog/streams/streams-scala/tests.yaml
+++ b/test-catalog/streams/streams-scala/tests.yaml
@@ -22,8 +22,6 @@ org.apache.kafka.streams.scala.kstream.KStreamSplitTest:
 - testRouteMessagesToAnonymousConsumers
 - testRouteMessagesToConsumers
 org.apache.kafka.streams.scala.kstream.KStreamTest:
-- testCorrectlyFlatTransformValuesInRecords
-- testCorrectlyFlatTransformValuesInRecordsWithKey
 - testFilterRecordsNotSatisfyingPredicate
 - testFilterRecordsSatisfyingPredicate
 - testForeachActionsOnRecords
@@ -31,6 +29,7 @@ org.apache.kafka.streams.scala.kstream.KStreamTest:
 - testJoinTwoKStreamToTables
 - testPeekActionsOnRecords
 - testProcessCorrectlyRecords
+- testProcessValuesCorrectlyRecords
 - testRepartitionKStream
 - testSelectNewKey
 - testSettingNameOnFilter
diff --git a/test-catalog/streams/tests.yaml b/test-catalog/streams/tests.yaml
index c59c4fd1488..dd0a0f5cd3e 100644
--- a/test-catalog/streams/tests.yaml
+++ b/test-catalog/streams/tests.yaml
@@ -126,8 +126,6 @@ org.apache.kafka.streams.StreamsBuilderTest:
 - shouldUseSpecifiedDslStoreSuppliersForAllOuterJoinOperationBetweenKStreamAndKStream
 - shouldUseSpecifiedNameForAggregateOperationGivenTable
 - shouldUseSpecifiedNameForFilterOperation
-- shouldUseSpecifiedNameForFlatTransformValueOperation
-- shouldUseSpecifiedNameForFlatTransformValueWithKeyOperation
 - shouldUseSpecifiedNameForForEachOperation
 - shouldUseSpecifiedNameForGlobalStoreProcessor
 - shouldUseSpecifiedNameForGlobalTableSourceProcessor
@@ -142,6 +140,7 @@ org.apache.kafka.streams.StreamsBuilderTest:
 - shouldUseSpecifiedNameForOuterJoinOperationBetweenKStreamAndKStream
 - shouldUseSpecifiedNameForPrintOperation
 - shouldUseSpecifiedNameForProcessOperation
+- shouldUseSpecifiedNameForProcessValuesOperation
 - shouldUseSpecifiedNameForSinkProcessor
 - shouldUseSpecifiedNameForSplitOperation
 - shouldUseSpecifiedNameForStreamSourceProcessor
@@ -599,7 +598,6 @@ org.apache.kafka.streams.kstream.WindowedSerdesTest:
 - timeWindowedSerializerShouldThrowNpeOnSerializingBaseKeyIfNotInitializedProperly
 org.apache.kafka.streams.kstream.internals.AbstractStreamTest:
 - testShouldBeExtensible
-- testToInternalValueTransformerSupplierSuppliesNewTransformers
 - testToInternalValueTransformerWithKeySupplierSuppliesNewTransformers
 org.apache.kafka.streams.kstream.internals.ChangedSerdeTest:
 - serializerShouldThrowIfGivenAChangeWithBothNewAndOldValuesAsNull
@@ -792,20 +790,6 @@ org.apache.kafka.streams.kstream.internals.KStreamFlatMapTest:
 org.apache.kafka.streams.kstream.internals.KStreamFlatMapValuesTest:
 - testFlatMapValues
 - testFlatMapValuesWithKeys
-org.apache.kafka.streams.kstream.internals.KStreamFlatTransformTest:
-- shouldAllowEmptyListAsResultOfTransform
-- shouldAllowNullAsResultOfTransform
-- shouldCloseFlatTransformProcessor
-- shouldGetFlatTransformProcessor
-- shouldInitialiseFlatTransformProcessor
-- shouldTransformInputRecordToMultipleOutputRecords
-org.apache.kafka.streams.kstream.internals.KStreamFlatTransformValuesTest:
-- shouldCloseFlatTransformValuesProcessor
-- shouldEmitNoRecordIfTransformReturnsEmptyList
-- shouldEmitNoRecordIfTransformReturnsNull
-- shouldGetFlatTransformValuesProcessor
-- shouldInitializeFlatTransformValuesProcessor
-- shouldTransformInputRecordToMultipleOutputValues
 org.apache.kafka.streams.kstream.internals.KStreamForeachTest:
 - testForeach
 - testTypeVariance
@@ -880,10 +864,6 @@ org.apache.kafka.streams.kstream.internals.KStreamImplTest:
 - shouldNotAllowNullNamedOnFilter
 - shouldNotAllowNullNamedOnFilterNot
 - shouldNotAllowNullNamedOnFlatMap
-- shouldNotAllowNullNamedOnFlatTransformValuesWithFlatValueSupplier
-- shouldNotAllowNullNamedOnFlatTransformValuesWithFlatValueSupplierAndStores
-- shouldNotAllowNullNamedOnFlatTransformValuesWithFlatValueWithKeySupplier
-- shouldNotAllowNullNamedOnFlatTransformValuesWithFlatValueWithKeySupplierAndStore
 - shouldNotAllowNullNamedOnForEach
 - shouldNotAllowNullNamedOnMap
 - shouldNotAllowNullNamedOnMapValues
@@ -921,18 +901,10 @@ org.apache.kafka.streams.kstream.internals.KStreamImplTest:
 - shouldNotAllowNullRepartitionedOnRepartition
 - shouldNotAllowNullSelectorOnGroupBy
 - shouldNotAllowNullSelectorOnGroupByWithGrouped
-- shouldNotAllowNullStoreNameOnFlatTransformValuesWithFlatValueSupplier
-- shouldNotAllowNullStoreNameOnFlatTransformValuesWithFlatValueSupplierAndNamed
-- shouldNotAllowNullStoreNameOnFlatTransformValuesWithFlatValueWithKeySupplier
-- shouldNotAllowNullStoreNameOnFlatTransformValuesWithFlatValueWithKeySupplierAndNamed
 - shouldNotAllowNullStoreNameOnProcess
 - shouldNotAllowNullStoreNameOnProcessValues
 - shouldNotAllowNullStoreNameOnProcessValuesWithNamed
 - shouldNotAllowNullStoreNameOnProcessWithNamed
-- shouldNotAllowNullStoreNamesOnFlatTransformValuesWithFlatValueSupplier
-- shouldNotAllowNullStoreNamesOnFlatTransformValuesWithFlatValueSupplierAndNamed
-- shouldNotAllowNullStoreNamesOnFlatTransformValuesWithFlatValueWithKeySupplier
-- shouldNotAllowNullStoreNamesOnFlatTransformValuesWithFlatValueWithKeySupplierAndNamed
 - shouldNotAllowNullStoreNamesOnProcess
 - shouldNotAllowNullStoreNamesOnProcessValues
 - shouldNotAllowNullStoreNamesOnProcessValuesWithNamed
@@ -980,14 +952,6 @@ org.apache.kafka.streams.kstream.internals.KStreamImplTest:
 - shouldNotAllowNullValueJoinerWithKeyOnTableJoinWithJoiner
 - shouldNotAllowNullValueJoinerWithKeyOnTableLeftJoin
 - shouldNotAllowNullValueJoinerWithKeyOnTableLeftJoinWithJoined
-- shouldNotAllowNullValueTransformerSupplierOnFlatTransformValues
-- shouldNotAllowNullValueTransformerSupplierOnFlatTransformValuesWithNamed
-- shouldNotAllowNullValueTransformerSupplierOnFlatTransformValuesWithNamedAndStores
-- shouldNotAllowNullValueTransformerSupplierOnFlatTransformValuesWithStores
-- shouldNotAllowNullValueTransformerWithKeySupplierOnFlatTransformValues
-- shouldNotAllowNullValueTransformerWithKeySupplierOnFlatTransformValuesWithNamed
-- shouldNotAllowNullValueTransformerWithKeySupplierOnFlatTransformValuesWithNamedAndStores
-- shouldNotAllowNullValueTransformerWithKeySupplierOnFlatTransformValuesWithStores
 - shouldNotMaterializedKTableFromKStream
 - shouldPreserveSerdesForOperators
 - shouldProcessFromSourceThatMatchPattern