https://community.databricks.com/t5/get-started-discussions/using-nested-dataframes-with-databricks-connect-gt-13-x/m-p/54788#M6244 <P>&nbsp;</P><P>We needed to move to databricks-connect&gt;13.x. Now I facing the issue that when I work with a nested dataframe of the structure</P><P>```<BR />root<BR />|-- a: string (nullable = true)<BR />|-- b: array (nullable = true)<BR />| |-- element: struct (containsNull = true)<BR />| | |-- c: string (nullable = true)<BR />| | |-- f: struct (nullable = true)<BR />| | | |-- g: string (nullable = true)<BR />| | | |-- h: struct (nullable = true)<BR />| | | | |-- supplier_id: string (nullable = true)<BR />| | |-- i: string (nullable = true)<BR />| | |-- j: array (nullable = true)<BR />| | | |-- element: struct (containsNull = true)<BR />| | | | |-- k: string (nullable = true)<BR />| | | | |-- l: array (nullable = true)<BR />| | | | | |-- element: struct (containsNull = true)<BR />| | | | | | |-- m: string (nullable = true)<BR />| | | | | | |-- n: array (nullable = true)<BR />| | | | | | | |-- element: struct (containsNull = true)<BR />| | | | | | | | |-- o: string (nullable = true)<BR />| | | | | | |-- p: array (nullable = true)<BR />| | | | | | | |-- element: struct (containsNull = true)<BR />| | | | | | | | |-- q: string (nullable = true)<BR />| | |-- r: boolean (nullable = true)<BR />|-- s: integer (nullable = true)<BR />|-- t: string (nullable = true)<BR />```</P><P>I get the error on the cluster (13.3 LTS (includes Apache Spark 3.4.1, Scala 2.12):</P><P>```</P><P>Caused by: grpc_shaded.com.google.protobuf.InvalidProtocolBufferException: Protocol message had too many levels of nesting. May be malicious. Use CodedInputStream.setRecursionLimit() to increase the depth limit.</P><P>```</P> Wed, 06 Dec 2023 14:43:09 GMT Lazloo 2023-12-06T14:43:09Z https://community.databricks.com/t5/get-started-discussions/using-nested-dataframes-with-databricks-connect-gt-13-x/m-p/54788#M6244 <P>&nbsp;</P><P>We needed to move to databricks-connect&gt;13.x. Now I facing the issue that when I work with a nested dataframe of the structure</P><P>```<BR />root<BR />|-- a: string (nullable = true)<BR />|-- b: array (nullable = true)<BR />| |-- element: struct (containsNull = true)<BR />| | |-- c: string (nullable = true)<BR />| | |-- f: struct (nullable = true)<BR />| | | |-- g: string (nullable = true)<BR />| | | |-- h: struct (nullable = true)<BR />| | | | |-- supplier_id: string (nullable = true)<BR />| | |-- i: string (nullable = true)<BR />| | |-- j: array (nullable = true)<BR />| | | |-- element: struct (containsNull = true)<BR />| | | | |-- k: string (nullable = true)<BR />| | | | |-- l: array (nullable = true)<BR />| | | | | |-- element: struct (containsNull = true)<BR />| | | | | | |-- m: string (nullable = true)<BR />| | | | | | |-- n: array (nullable = true)<BR />| | | | | | | |-- element: struct (containsNull = true)<BR />| | | | | | | | |-- o: string (nullable = true)<BR />| | | | | | |-- p: array (nullable = true)<BR />| | | | | | | |-- element: struct (containsNull = true)<BR />| | | | | | | | |-- q: string (nullable = true)<BR />| | |-- r: boolean (nullable = true)<BR />|-- s: integer (nullable = true)<BR />|-- t: string (nullable = true)<BR />```</P><P>I get the error on the cluster (13.3 LTS (includes Apache Spark 3.4.1, Scala 2.12):</P><P>```</P><P>Caused by: grpc_shaded.com.google.protobuf.InvalidProtocolBufferException: Protocol message had too many levels of nesting. May be malicious. Use CodedInputStream.setRecursionLimit() to increase the depth limit.</P><P>```</P> Wed, 06 Dec 2023 14:43:09 GMT https://community.databricks.com/t5/get-started-discussions/using-nested-dataframes-with-databricks-connect-gt-13-x/m-p/54788#M6244 Lazloo 2023-12-06T14:43:09Z https://community.databricks.com/t5/get-started-discussions/using-nested-dataframes-with-databricks-connect-gt-13-x/m-p/54867#M6245 <P>In addition here is the full stack trace</P><P>23/12/07 14:51:56 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable@33dfd6ec<BR />grpc_shaded.io.grpc.StatusRuntimeException: INTERNAL: Invalid protobuf byte sequence<BR />at grpc_shaded.io.grpc.Status.asRuntimeException(Status.java:526)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:218)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:118)<BR />at grpc_shaded.io.grpc.MethodDescriptor.parseRequest(MethodDescriptor.java:307)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:318)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:301)<BR />at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:834)<BR />at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)<BR />at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)<BR />at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<BR />at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<BR />at java.lang.Thread.run(Thread.java:750)<BR />Caused by: grpc_shaded.com.google.protobuf.InvalidProtocolBufferException: Protocol message had too many levels of nesting. May be malicious. Use CodedInputStream.setRecursionLimit() to increase the depth limit.<BR />at grpc_shaded.com.google.protobuf.InvalidProtocolBufferException.recursionLimitExceeded(InvalidProtocolBufferException.java:148)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream.checkRecursionLimit(CodedInputStream.java:200)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:886)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15215)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15158)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:85)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:9)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15215)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15158)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:85)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:9)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15215)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15158)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:85)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:9)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:69)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:57)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:9)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:308)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:57)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:9)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:308)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:59)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:9)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:574)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:59)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:9)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:574)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:59)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:9)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:574)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Drop.&lt;init&gt;(Drop.java:59)<BR />at org.apache.spark.connect.proto.Drop.&lt;init&gt;(Drop.java:9)<BR />at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1131)<BR />at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:336)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:58)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:58)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:71)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:58)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Drop.&lt;init&gt;(Drop.java:59)<BR />at org.apache.spark.connect.proto.Drop.&lt;init&gt;(Drop.java:9)<BR />at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1131)<BR />at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:336)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Plan.&lt;init&gt;(Plan.java:57)<BR />at org.apache.spark.connect.proto.Plan.&lt;init&gt;(Plan.java:9)<BR />at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:897)<BR />at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:891)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.&lt;init&gt;(AnalyzePlanRequest.java:362)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.&lt;init&gt;(AnalyzePlanRequest.java:315)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:894)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:888)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest.&lt;init&gt;(AnalyzePlanRequest.java:85)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest.&lt;init&gt;(AnalyzePlanRequest.java:9)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12441)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12435)<BR />at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:86)<BR />at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:48)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parseFrom(ProtoLiteUtils.java:223)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:215)<BR />... 10 more<BR />23/12/07 14:51:56 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@451e646a<BR />java.lang.IllegalStateException: call already closed<BR />at grpc_shaded.com.google.common.base.Preconditions.checkState(Preconditions.java:502)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:214)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:207)<BR />at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.$anonfun$getCurrentWorkloadId$1(AuthenticationInterceptor.scala:301)<BR />at scala.Option.getOrElse(Option.scala:189)<BR />at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.getCurrentWorkloadId(AuthenticationInterceptor.scala:299)<BR />at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.onComplete(AuthenticationInterceptor.scala:481)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:359)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:350)<BR />at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:913)<BR />at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)<BR />at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)<BR />at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<BR />at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<BR />at java.lang.Thread.run(Thread.java:750)<BR />23/12/07 14:52:01 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable@323d10bc<BR />grpc_shaded.io.grpc.StatusRuntimeException: INTERNAL: Invalid protobuf byte sequence<BR />at grpc_shaded.io.grpc.Status.asRuntimeException(Status.java:526)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:218)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:118)<BR />at grpc_shaded.io.grpc.MethodDescriptor.parseRequest(MethodDescriptor.java:307)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:318)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:301)<BR />at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:834)<BR />at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)<BR />at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)<BR />at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<BR />at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<BR />at java.lang.Thread.run(Thread.java:750)<BR />Caused by: grpc_shaded.com.google.protobuf.InvalidProtocolBufferException: Protocol message had too many levels of nesting. May be malicious. Use CodedInputStream.setRecursionLimit() to increase the depth limit.<BR />at grpc_shaded.com.google.protobuf.InvalidProtocolBufferException.recursionLimitExceeded(InvalidProtocolBufferException.java:148)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream.checkRecursionLimit(CodedInputStream.java:200)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:886)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15215)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15158)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:85)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:9)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15215)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction.&lt;init&gt;(Expression.java:15158)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)<BR />at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:85)<BR />at org.apache.spark.connect.proto.Expression.&lt;init&gt;(Expression.java:9)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)<BR />at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:69)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:57)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:9)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:308)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:57)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed.&lt;init&gt;(WithColumnsRenamed.java:9)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)<BR />at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:308)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:59)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:9)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:574)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:59)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:9)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:574)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:59)<BR />at org.apache.spark.connect.proto.NAFill.&lt;init&gt;(NAFill.java:9)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)<BR />at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:574)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Drop.&lt;init&gt;(Drop.java:59)<BR />at org.apache.spark.connect.proto.Drop.&lt;init&gt;(Drop.java:9)<BR />at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1131)<BR />at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1125)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:336)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:72)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:60)<BR />at org.apache.spark.connect.proto.Aggregate.&lt;init&gt;(Aggregate.java:9)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)<BR />at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:168)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:59)<BR />at org.apache.spark.connect.proto.Join.&lt;init&gt;(Join.java:9)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)<BR />at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:112)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:58)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:58)<BR />at org.apache.spark.connect.proto.WithColumns.&lt;init&gt;(WithColumns.java:9)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)<BR />at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:364)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:58)<BR />at org.apache.spark.connect.proto.Project.&lt;init&gt;(Project.java:9)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)<BR />at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:84)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:71)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:58)<BR />at org.apache.spark.connect.proto.SetOperation.&lt;init&gt;(SetOperation.java:9)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)<BR />at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:126)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:56)<BR />at org.apache.spark.connect.proto.Filter.&lt;init&gt;(Filter.java:9)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)<BR />at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:98)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:58)<BR />at org.apache.spark.connect.proto.Deduplicate.&lt;init&gt;(Deduplicate.java:9)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)<BR />at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:238)<BR />at org.apache.spark.connect.proto.Relation.&lt;init&gt;(Relation.java:9)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)<BR />at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.Plan.&lt;init&gt;(Plan.java:57)<BR />at org.apache.spark.connect.proto.Plan.&lt;init&gt;(Plan.java:9)<BR />at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:897)<BR />at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:891)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.&lt;init&gt;(AnalyzePlanRequest.java:362)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.&lt;init&gt;(AnalyzePlanRequest.java:315)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:894)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:888)<BR />at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest.&lt;init&gt;(AnalyzePlanRequest.java:85)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest.&lt;init&gt;(AnalyzePlanRequest.java:9)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12441)<BR />at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12435)<BR />at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:86)<BR />at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:48)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parseFrom(ProtoLiteUtils.java:223)<BR />at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:215)<BR />... 10 more<BR />23/12/07 14:52:01 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@70bc910c<BR />java.lang.IllegalStateException: call already closed<BR />at grpc_shaded.com.google.common.base.Preconditions.checkState(Preconditions.java:502)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:214)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:207)<BR />at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.$anonfun$getCurrentWorkloadId$1(AuthenticationInterceptor.scala:301)<BR />at scala.Option.getOrElse(Option.scala:189)<BR />at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.getCurrentWorkloadId(AuthenticationInterceptor.scala:299)<BR />at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.onComplete(AuthenticationInterceptor.scala:481)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:359)<BR />at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:350)<BR />at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:913)<BR />at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)<BR />at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)<BR />at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)<BR />at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)<BR />at java.lang.Thread.run(Thread.java:750)</P> Thu, 07 Dec 2023 14:57:13 GMT https://community.databricks.com/t5/get-started-discussions/using-nested-dataframes-with-databricks-connect-gt-13-x/m-p/54867#M6245 Lazloo 2023-12-07T14:57:13Z