Juliusz Sompolski created SPARK-44676:
-----------------------------------------
Summary: Ensure Spark Connect scala client CloseableIterator is
closed in all cases where exception could be thrown
Key: SPARK-44676
URL: https://issues.apache.org/jira/browse/SPARK-44676
Project: Spark
Issue Type: Improvement
Components: Connect
Affects Versions: 4.0.0
Reporter: Juliusz Sompolski
We currently already ensure that CloseableIterator is consumed in all places,
and in ExecutePlanResponseReattachableIterator we ensure that the iterator is
closed in case of GRPC error.
We should also ensure that all places in the client that use a
CloseableIterator will close it gracefully, also in case of another exception
being thrown, including InterruptedException.
Some try \{ } finally \{ iteretor.close() } blocks may be needed for that.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
