[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1323060159 ## connector/connect/client/jvm/src/test/scala/org/apache/spark/sql/streaming/ClientStreamingQuerySuite.scala: ## @@ -175,6 +175,36 @@ class ClientStreamingQuerySuite

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330657004 ## connector/connect/server/src/test/scala/org/apache/spark/sql/connect/service/FetchErrorDetailsHandlerSuite.scala: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apach

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330656751 ## connector/connect/server/src/test/scala/org/apache/spark/sql/connect/service/FetchErrorDetailsHandlerSuite.scala: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apach

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330626485 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala: ## @@ -66,14 +137,26 @@ private[connect] object ErrorUtils extends Logg

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330611551 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala: ## @@ -66,14 +137,26 @@ private[connect] object ErrorUtils extends Logg

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330611551 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala: ## @@ -66,14 +137,26 @@ private[connect] object ErrorUtils extends Logg

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330596345 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/config/Connect.scala: ## @@ -213,4 +214,21 @@ object Connect { .version("3.5.0") .int

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330578327 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SessionHolder.scala: ## @@ -45,6 +49,15 @@ case class SessionHolder(userId: String, ses

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330443354 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectFetchErrorDetailsHandler.scala: ## @@ -0,0 +1,57 @@ +/* + * Licensed to the

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330443354 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectFetchErrorDetailsHandler.scala: ## @@ -0,0 +1,57 @@ +/* + * Licensed to the

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330327877 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectFetchErrorDetailsHandler.scala: ## @@ -0,0 +1,57 @@ +/* + * Licensed to the

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330327877 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectFetchErrorDetailsHandler.scala: ## @@ -0,0 +1,57 @@ +/* + * Licensed to the

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330261417 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala: ## @@ -57,28 +69,105 @@ private[connect] object ErrorUtils extends Logg

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330248359 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectService.scala: ## @@ -291,15 +307,16 @@ object SparkConnectService extends

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330247802 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/service/SparkConnectFetchErrorDetailsHandler.scala: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330178093 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala: ## @@ -57,28 +79,103 @@ private[connect] object ErrorUtils extends Logg

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330217235 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/config/Connect.scala: ## @@ -213,4 +205,19 @@ object Connect { .version("3.5.0") .int

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330216449 ## connector/connect/server/src/main/scala/org/apache/spark/sql/connect/utils/ErrorUtils.scala: ## @@ -57,28 +69,105 @@ private[connect] object ErrorUtils extends Logg

[GitHub] [spark] heyihong commented on a diff in pull request #42377: [SPARK-44622][SQL][CONNECT] Implement FetchErrorDetails RPC

heyihong commented on code in PR #42377: URL: https://github.com/apache/spark/pull/42377#discussion_r1330215015 ## connector/connect/common/src/main/protobuf/spark/connect/base.proto: ## @@ -778,6 +778,67 @@ message ReleaseExecuteResponse { optional string operation_id = 2;