[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1175980270 ## connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryProgressSuite.scala: ## @@ -0,0 +1,214 @@ +/* + * Licensed to the

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173602327 ## connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/streaming/progress.scala: ## @@ -17,6 +17,297 @@ package org.apache.spark.sql.streaming

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173598454 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/SparkConnectPlanner.scala: ## @@ -2182,7 +2182,7 @@ class SparkConnectPlanner(val

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173508858 ## connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/streaming/progress.scala: ## @@ -17,6 +17,297 @@ package org.apache.spark.sql.streaming

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173464572 ## connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/streaming/progress.scala: ## @@ -17,6 +17,297 @@ package org.apache.spark.sql.streaming

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173464572 ## connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/streaming/progress.scala: ## @@ -17,6 +17,297 @@ package org.apache.spark.sql.streaming

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173464572 ## connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/streaming/progress.scala: ## @@ -17,6 +17,297 @@ package org.apache.spark.sql.streaming

[GitHub] [spark] LuciferYang commented on a diff in pull request #40892: [SPARK-43128][CONNECT] Make `recentProgress` and `lastProgress` return `StreamingQueryProgress` consistent with the native Scal

LuciferYang commented on code in PR #40892: URL: https://github.com/apache/spark/pull/40892#discussion_r1173272269 ## connector/connect/client/jvm/src/main/scala/org/apache/spark/sql/streaming/progress.scala: ## @@ -17,6 +17,297 @@ package org.apache.spark.sql.streaming