You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@iceberg.apache.org by "xloya (via GitHub)" <gi...@apache.org> on 2023/04/06 10:55:22 UTC

[GitHub] [iceberg] xloya commented on a diff in pull request #7240: Spark: Close the delete threads pool in some procedures like DeleteOrphan and ExpireSnapshots

xloya commented on code in PR #7240:
URL: https://github.com/apache/iceberg/pull/7240#discussion_r1159643825


##########
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/procedures/ExpireSnapshotsProcedure.java:
##########
@@ -46,6 +47,8 @@ public class ExpireSnapshotsProcedure extends BaseProcedure {
 
   private static final Logger LOG = LoggerFactory.getLogger(ExpireSnapshotsProcedure.class);
 
+  private ExecutorService executorService = null;

Review Comment:
   Thanks, I noticed. We are still using Spark 3.1. There is no logic like closing the threads pool in Spark 3.1. If necessary, I can open a PR to backport the relevant logic to Spark 3.1



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org