Fix

delta-io · Sep 17, 2024 · 34babe5 · 34babe5
1 parent c7c7bc2
commit 34babe5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/spark-connect/server/src/main/scala-spark-master/io/delta/connect/DeltaRelationPlugin.scala b/spark-connect/server/src/main/scala-spark-master/io/delta/connect/DeltaRelationPlugin.scala
@@ -45,12 +45,12 @@ import org.apache.spark.sql.types.StructType
 class DeltaRelationPlugin extends RelationPlugin with DeltaPlannerBase {
   override def transform(raw: Array[Byte], planner: SparkConnectPlanner): Optional[LogicalPlan] = {
     val relation = parseAnyFrom(raw,
-      SparkEnv.get.conf.get(4 * Connect.CONNECT_GRPC_MARSHALLER_RECURSION_LIMIT))
+      4 * SparkEnv.get.conf.get(Connect.CONNECT_GRPC_MARSHALLER_RECURSION_LIMIT))
     if (relation.is(classOf[proto.DeltaRelation])) {
       Optional.of(
         transform(
           parseRelationFrom(relation.getValue,
-            SparkEnv.get.conf.get(4 * Connect.CONNECT_GRPC_MARSHALLER_RECURSION_LIMIT)),
+            4 * SparkEnv.get.conf.get(Connect.CONNECT_GRPC_MARSHALLER_RECURSION_LIMIT)),
           planner
         ))
     } else {