[pinot] branch master updated: Invoke MetadataEventNotifier on schema delete (#8368)

[snlee]

This is an automated email from the ASF dual-hosted git repository.

snlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new 449cb72  Invoke MetadataEventNotifier on schema delete (#8368)
449cb72 is described below

commit 449cb72fa43990f4796ca60c84be3b8a0cc471ee
Author: Seunghyun Lee <sn...@linkedin.com>
AuthorDate: Mon Mar 21 20:53:47 2022 -0700

    Invoke MetadataEventNotifier on schema delete (#8368)
---
 .../pinot/controller/api/resources/PinotSchemaRestletResource.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
 
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
index 0c9461d..f2c40e3 100644
--- 
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
+++ 
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSchemaRestletResource.java
@@ -384,6 +384,8 @@ public class PinotSchemaRestletResource {
 
     LOGGER.info("Trying to delete schema {}", schemaName);
     if (_pinotHelixResourceManager.deleteSchema(schema)) {
+      LOGGER.info("Notifying metadata event for deleting schema: {}", 
schemaName);
+      _metadataEventNotifierFactory.create().notifyOnSchemaEvents(schema, 
SchemaEventType.DELETE);
       LOGGER.info("Success: Deleted schema {}", schemaName);
     } else {
       throw new ControllerApplicationException(LOGGER, String.format("Failed 
to delete schema %s", schemaName),

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org