From da5abe5f5b93da6c6b80b2e61946a8ff51df663c Mon Sep 17 00:00:00 2001 From: Anish Shrigondekar Date: Tue, 17 Sep 2024 15:50:12 -0700 Subject: [PATCH] Address Jing's comments --- .../apache/spark/sql/streaming/TransformWithStateSuite.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/TransformWithStateSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/TransformWithStateSuite.scala index 9aab6f987d0e3..0c02fbf97820b 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/TransformWithStateSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/TransformWithStateSuite.scala @@ -1743,8 +1743,7 @@ class TransformWithStateSuite extends StateStoreMetricsTest val mostRecentAnsDf = mostRecentDf.selectExpr( "key.value AS groupingKey", - "v" + - "alue.value") + "value.value") checkAnswer(mostRecentAnsDf, Seq(Row("a", "str1"))) } }