yuqi1129 commented on code in PR #11364:
URL: https://github.com/apache/gravitino/pull/11364#discussion_r3345510458
##########
iceberg/iceberg-rest-server/src/main/java/org/apache/gravitino/iceberg/RESTService.java:
##########
@@ -119,9 +123,25 @@ protected javax.servlet.Filter
createAuthenticationFilter() {
skipAuthorizationForRestBackend,
icebergCatalogWrapperManager);
this.icebergMetricsManager = new IcebergMetricsManager(icebergConfig);
+ if (auxMode) {
+ // Async cleanup reuses the entity store's shared relational backend
(connection pool +
+ // per-backend SQL), which is only available when running embedded in
the Gravitino server
+ // (auxiliary mode). In standalone mode the cleanup manager stays empty
and purge requests
+ // fall back to synchronous purge.
+ this.cleanupManager =
+ Optional.of(
+ new IcebergCleanupManager(
+ new
IcebergCleanupJobStore(GravitinoEnv.getInstance().idGenerator()),
+ icebergConfig));
+ } else {
+ this.cleanupManager = Optional.empty();
+ LOG.info(
+ "Async Iceberg table cleanup is only available in auxiliary mode; "
+ + "purge requests fall back to synchronous purge.");
Review Comment:
purge requests with async mode will ...
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
