最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

apache spark - Can we stop or pause already running optimize on delta table - Stack Overflow

programmeradmin1浏览0评论

Is there any way to stop or pause an already running optmize on delta table started using

val deltaTable = DeltaTable.forPath(spark, deltaTablePath) 
deltaTable.optimize().executeCompaction()

Is there any way to stop or pause an already running optmize on delta table started using

val deltaTable = DeltaTable.forPath(spark, deltaTablePath) 
deltaTable.optimize().executeCompaction()
Share Improve this question asked Jan 29 at 8:27 Shailendra KirtikarShailendra Kirtikar 474 bronze badges
Add a comment  | 

1 Answer 1

Reset to default 0

To stop or pause a running OPTIMIZE operation on a Delta table (started via executeCompaction()), there is no direct API in Delta Lake 2.x or earlier. If the OPTIMIZE is running as a Spark job, you can kill the associated Spark job.

发布评论

评论列表(0)

  1. 暂无评论