当前摄取的apache hudi提交id

relj7zay  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(421)

如何获取当前摄取提交id。我知道hoodiedatasourcehelpers.latestcommit方法可用于查找最新提交。但是如果在不同的线程中有并发写操作会发生什么呢。我需要找到每一个线程

kgqe7b3p

kgqe7b3p1#

hudi目前不允许同时写作。无论如何 HoodieDataSourceHelpers.latestCommit 将始终返回最新的提交。

相关问题