From b4d1da2f730e9da3aa247faac5999054758e3fc4 Mon Sep 17 00:00:00 2001 From: Thang Long VU Date: Wed, 21 Aug 2024 10:50:05 +0200 Subject: [PATCH] Update --- .../apache/spark/sql/connect/planner/MockObserver.scala | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/MockObserver.scala b/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/MockObserver.scala index c1d950cb7fcf4..1519fb8a4675d 100644 --- a/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/MockObserver.scala +++ b/sql/connect/server/src/main/scala/org/apache/spark/sql/connect/planner/MockObserver.scala @@ -22,15 +22,16 @@ import io.grpc.stub.StreamObserver import org.apache.spark.connect.proto /* - * The [[MockObserver]] class is a mock of the [[StreamObserver]] class from the gRPC library, - * used for testing the process function of [[SparkConnectPlanner]]. + * The [[MockObserver]] class is a mock of the [[StreamObserver]] class from + * the gRPC library, used for testing the process function of [[SparkConnectPlanner]]. * * Currently, the [[MockObserver]] class is located in the test folder, * which is not shaded by sbt-assembly, unlike the main folder. * * This results in a compilation error when open-source libraries call the - * [[transform(spark: SparkSession, command: proto.Command)]] function in [[SparkConnectPlannerTestUtils]], - * which in turn calls [[SparkConnectPlanner(executeHolder).process(command, new MockObserver())]]. + * [[transform(spark: SparkSession, command: proto.Command)]] function in + * [[SparkConnectPlannerTestUtils]], which in turn calls + * [[SparkConnectPlanner(executeHolder).process(command, new MockObserver())]]. * * To resolve this, the [[MockObserver]] class should be moved to the main folder * to be shaded as well.