diff --git a/dev/diffs/3.4.2.diff b/dev/diffs/3.4.2.diff index 438a98fe4..5fb69e56c 100644 --- a/dev/diffs/3.4.2.diff +++ b/dev/diffs/3.4.2.diff @@ -1142,7 +1142,7 @@ index 75f440caefc..36b1146bc3a 100644 fail(s"No FileScan in query\n${df.queryExecution}") } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateDistributionSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateDistributionSuite.scala -index b597a244710..c6d11f9ba69 100644 +index b597a244710..b2e8be41065 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateDistributionSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateDistributionSuite.scala @@ -21,6 +21,7 @@ import java.io.File @@ -1153,6 +1153,15 @@ index b597a244710..c6d11f9ba69 100644 import org.apache.spark.sql.catalyst.streaming.InternalOutputModes.Update import org.apache.spark.sql.execution.streaming.{FlatMapGroupsWithStateExec, MemoryStream} import org.apache.spark.sql.internal.SQLConf +@@ -91,7 +92,7 @@ class FlatMapGroupsWithStateDistributionSuite extends StreamTest + } + + test("SPARK-38204: flatMapGroupsWithState should require StatefulOpClusteredDistribution " + +- "from children - without initial state") { ++ "from children - without initial state", IgnoreComet("TODO: fix Comet for this test")) { + // function will return -1 on timeout and returns count of the state otherwise + val stateFunc = + (key: (String, String), values: Iterator[(String, String, Long)], @@ -243,7 +244,8 @@ class FlatMapGroupsWithStateDistributionSuite extends StreamTest }