Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for
Community Platform Discussions
Connect with fellow community members to discuss general topics related to the Databricks platform, industry trends, and best practices. Share experiences, ask questions, and foster collaboration within the community.
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for
- Databricks Community
- Community Platform Discussions
- Using nested dataframes with databricks-connect>13...
Options
- Subscribe to RSS Feed
- Mark Topic as New
- Mark Topic as Read
- Float this Topic for Current User
- Bookmark
- Subscribe
- Mute
- Printer Friendly Page
Using nested dataframes with databricks-connect>13.x
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-06-2023 06:37 AM - edited 12-06-2023 06:43 AM
We needed to move to databricks-connect>13.x. Now I facing the issue that when I work with a nested dataframe of the structure
```
root
|-- a: string (nullable = true)
|-- b: array (nullable = true)
| |-- element: struct (containsNull = true)
| | |-- c: string (nullable = true)
| | |-- f: struct (nullable = true)
| | | |-- g: string (nullable = true)
| | | |-- h: struct (nullable = true)
| | | | |-- supplier_id: string (nullable = true)
| | |-- i: string (nullable = true)
| | |-- j: array (nullable = true)
| | | |-- element: struct (containsNull = true)
| | | | |-- k: string (nullable = true)
| | | | |-- l: array (nullable = true)
| | | | | |-- element: struct (containsNull = true)
| | | | | | |-- m: string (nullable = true)
| | | | | | |-- n: array (nullable = true)
| | | | | | | |-- element: struct (containsNull = true)
| | | | | | | | |-- o: string (nullable = true)
| | | | | | |-- p: array (nullable = true)
| | | | | | | |-- element: struct (containsNull = true)
| | | | | | | | |-- q: string (nullable = true)
| | |-- r: boolean (nullable = true)
|-- s: integer (nullable = true)
|-- t: string (nullable = true)
```
I get the error on the cluster (13.3 LTS (includes Apache Spark 3.4.1, Scala 2.12):
```
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.
```
1 REPLY 1
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-07-2023 06:56 AM - edited 12-07-2023 06:57 AM
In addition here is the full stack trace
23/12/07 14:51:56 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable@33dfd6ec
grpc_shaded.io.grpc.StatusRuntimeException: INTERNAL: Invalid protobuf byte sequence
at grpc_shaded.io.grpc.Status.asRuntimeException(Status.java:526)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:218)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:118)
at grpc_shaded.io.grpc.MethodDescriptor.parseRequest(MethodDescriptor.java:307)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:318)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:301)
at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:834)
at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
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.
at grpc_shaded.com.google.protobuf.InvalidProtocolBufferException.recursionLimitExceeded(InvalidProtocolBufferException.java:148)
at grpc_shaded.com.google.protobuf.CodedInputStream.checkRecursionLimit(CodedInputStream.java:200)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:886)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15215)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15158)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:85)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:9)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15215)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15158)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:85)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:9)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15215)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15158)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:85)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:9)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:69)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:57)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:9)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:308)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:57)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:9)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:308)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:59)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:9)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:574)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:59)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:9)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:574)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:59)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:9)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:574)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Drop.<init>(Drop.java:59)
at org.apache.spark.connect.proto.Drop.<init>(Drop.java:9)
at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1131)
at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:336)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:58)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:58)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:71)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:58)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Drop.<init>(Drop.java:59)
at org.apache.spark.connect.proto.Drop.<init>(Drop.java:9)
at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1131)
at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:336)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Plan.<init>(Plan.java:57)
at org.apache.spark.connect.proto.Plan.<init>(Plan.java:9)
at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:897)
at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:891)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.<init>(AnalyzePlanRequest.java:362)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.<init>(AnalyzePlanRequest.java:315)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:894)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:888)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.AnalyzePlanRequest.<init>(AnalyzePlanRequest.java:85)
at org.apache.spark.connect.proto.AnalyzePlanRequest.<init>(AnalyzePlanRequest.java:9)
at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12441)
at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12435)
at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:86)
at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:48)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parseFrom(ProtoLiteUtils.java:223)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:215)
... 10 more
23/12/07 14:51:56 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@451e646a
java.lang.IllegalStateException: call already closed
at grpc_shaded.com.google.common.base.Preconditions.checkState(Preconditions.java:502)
at grpc_shaded.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:214)
at grpc_shaded.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:207)
at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.$anonfun$getCurrentWorkloadId$1(AuthenticationInterceptor.scala:301)
at scala.Option.getOrElse(Option.scala:189)
at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.getCurrentWorkloadId(AuthenticationInterceptor.scala:299)
at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.onComplete(AuthenticationInterceptor.scala:481)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:359)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:350)
at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:913)
at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
23/12/07 14:52:01 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable@323d10bc
grpc_shaded.io.grpc.StatusRuntimeException: INTERNAL: Invalid protobuf byte sequence
at grpc_shaded.io.grpc.Status.asRuntimeException(Status.java:526)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:218)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:118)
at grpc_shaded.io.grpc.MethodDescriptor.parseRequest(MethodDescriptor.java:307)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailableInternal(ServerCallImpl.java:318)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.messagesAvailable(ServerCallImpl.java:301)
at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1MessagesAvailable.runInContext(ServerImpl.java:834)
at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
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.
at grpc_shaded.com.google.protobuf.InvalidProtocolBufferException.recursionLimitExceeded(InvalidProtocolBufferException.java:148)
at grpc_shaded.com.google.protobuf.CodedInputStream.checkRecursionLimit(CodedInputStream.java:200)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:886)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15215)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15158)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:85)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:9)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15215)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction.<init>(Expression.java:15158)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16168)
at org.apache.spark.connect.proto.Expression$UnresolvedFunction$1.parsePartialFrom(Expression.java:16162)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:85)
at org.apache.spark.connect.proto.Expression.<init>(Expression.java:9)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26074)
at org.apache.spark.connect.proto.Expression$1.parsePartialFrom(Expression.java:26068)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:69)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:57)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:9)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:308)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:57)
at org.apache.spark.connect.proto.WithColumnsRenamed.<init>(WithColumnsRenamed.java:9)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:874)
at org.apache.spark.connect.proto.WithColumnsRenamed$1.parsePartialFrom(WithColumnsRenamed.java:868)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:308)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:59)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:9)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:574)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:59)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:9)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:574)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:59)
at org.apache.spark.connect.proto.NAFill.<init>(NAFill.java:9)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1131)
at org.apache.spark.connect.proto.NAFill$1.parsePartialFrom(NAFill.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:574)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Drop.<init>(Drop.java:59)
at org.apache.spark.connect.proto.Drop.<init>(Drop.java:9)
at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1131)
at org.apache.spark.connect.proto.Drop$1.parsePartialFrom(Drop.java:1125)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:336)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:72)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:60)
at org.apache.spark.connect.proto.Aggregate.<init>(Aggregate.java:9)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2702)
at org.apache.spark.connect.proto.Aggregate$1.parsePartialFrom(Aggregate.java:2696)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:168)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Join.<init>(Join.java:59)
at org.apache.spark.connect.proto.Join.<init>(Join.java:9)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2173)
at org.apache.spark.connect.proto.Join$1.parsePartialFrom(Join.java:2167)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:112)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:58)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:58)
at org.apache.spark.connect.proto.WithColumns.<init>(WithColumns.java:9)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:939)
at org.apache.spark.connect.proto.WithColumns$1.parsePartialFrom(WithColumns.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:364)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Project.<init>(Project.java:58)
at org.apache.spark.connect.proto.Project.<init>(Project.java:9)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:939)
at org.apache.spark.connect.proto.Project$1.parsePartialFrom(Project.java:933)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:84)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:71)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:58)
at org.apache.spark.connect.proto.SetOperation.<init>(SetOperation.java:9)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1271)
at org.apache.spark.connect.proto.SetOperation$1.parsePartialFrom(SetOperation.java:1265)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:126)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:56)
at org.apache.spark.connect.proto.Filter.<init>(Filter.java:9)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:776)
at org.apache.spark.connect.proto.Filter$1.parsePartialFrom(Filter.java:770)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:98)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:58)
at org.apache.spark.connect.proto.Deduplicate.<init>(Deduplicate.java:9)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:964)
at org.apache.spark.connect.proto.Deduplicate$1.parsePartialFrom(Deduplicate.java:958)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:238)
at org.apache.spark.connect.proto.Relation.<init>(Relation.java:9)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11357)
at org.apache.spark.connect.proto.Relation$1.parsePartialFrom(Relation.java:11351)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.Plan.<init>(Plan.java:57)
at org.apache.spark.connect.proto.Plan.<init>(Plan.java:9)
at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:897)
at org.apache.spark.connect.proto.Plan$1.parsePartialFrom(Plan.java:891)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.<init>(AnalyzePlanRequest.java:362)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema.<init>(AnalyzePlanRequest.java:315)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:894)
at org.apache.spark.connect.proto.AnalyzePlanRequest$Schema$1.parsePartialFrom(AnalyzePlanRequest.java:888)
at grpc_shaded.com.google.protobuf.CodedInputStream$ArrayDecoder.readMessage(CodedInputStream.java:889)
at org.apache.spark.connect.proto.AnalyzePlanRequest.<init>(AnalyzePlanRequest.java:85)
at org.apache.spark.connect.proto.AnalyzePlanRequest.<init>(AnalyzePlanRequest.java:9)
at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12441)
at org.apache.spark.connect.proto.AnalyzePlanRequest$1.parsePartialFrom(AnalyzePlanRequest.java:12435)
at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:86)
at grpc_shaded.com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:48)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parseFrom(ProtoLiteUtils.java:223)
at grpc_shaded.io.grpc.protobuf.lite.ProtoLiteUtils$MessageMarshaller.parse(ProtoLiteUtils.java:215)
... 10 more
23/12/07 14:52:01 ERROR SerializingExecutor: Exception while executing runnable grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed@70bc910c
java.lang.IllegalStateException: call already closed
at grpc_shaded.com.google.common.base.Preconditions.checkState(Preconditions.java:502)
at grpc_shaded.io.grpc.internal.ServerCallImpl.closeInternal(ServerCallImpl.java:214)
at grpc_shaded.io.grpc.internal.ServerCallImpl.close(ServerCallImpl.java:207)
at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.$anonfun$getCurrentWorkloadId$1(AuthenticationInterceptor.scala:301)
at scala.Option.getOrElse(Option.scala:189)
at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.getCurrentWorkloadId(AuthenticationInterceptor.scala:299)
at com.databricks.spark.connect.service.AuthenticationInterceptor$AuthenticatedServerCallListener.onComplete(AuthenticationInterceptor.scala:481)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closedInternal(ServerCallImpl.java:359)
at grpc_shaded.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.closed(ServerCallImpl.java:350)
at grpc_shaded.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1Closed.runInContext(ServerImpl.java:913)
at grpc_shaded.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
at grpc_shaded.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Connect with Databricks Users in Your Area
Join a Regional User Group to connect with local Databricks users. Events will be happening in your city, and you won’t want to miss the chance to attend and share knowledge.
If there isn’t a group near you, start one and help create a community that brings people together.
Request a New Group
Announcements
Related Content
- read file from local machine(my computer) and create a dataframe in Get Started Discussions
- Data loss after writing a transformed pyspark dataframe to delta table in unity catalog in Community Platform Discussions
- SQL to Spark Dataframe in Get Started Discussions
- RDD Issue in Unity Catalog in Community Platform Discussions
- jdbc errors when parameter is a boolean in Community Platform Discussions