dotnet / dotnet/spark

[BUG]: Executor goes stale

Open
#1,222 0 comments 0 reactions 0 assignees View on GitHub
bug
Dominant language
C#
Stars
2.1k
Forks
332
Avg merge
1d 20h
Merged PRs (30d)
9

Description

Hello,
I am reading data from parquet files as Dataframes and uploading them to iceberg using spark.
I have many small files that may write to same table .
I have an issue that after some files are written executor goes into stale state and just hangs there. the running query does not do anything,

```
df.WriteTo(fullTableName)
.Options(tableOptions)
.Append();
```
Stale yet running query looks like this:

```
append at :0

org.apache.spark.sql.DataFrameWriterV2.append(DataFrameWriterV2.scala:153)
jdk.internal.reflect.GeneratedMethodAccessor104.invoke(Unknown Source)
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
java.base/java.lang.reflect.Method.invoke(Method.java:568)
org.apache.spark.api.dotnet.DotnetBackendHandler.handleMethodCall(DotnetBackendHandler.scala:167)
org.apache.spark.api.dotnet.DotnetBackendHandler.$anonfun$handleBackendRequest$2(DotnetBackendHandler.scala:105)
org.apache.spark.api.dotnet.ThreadPool$$anon$1.run(ThreadPool.scala:34)
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
java.base/java.lang.Thread.run(Thread.java:842)
```

Nuget version: 2.3.0

spark version 3.5.3

hadoop 3.4.1

jdk-17

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.