This is an automated email from the ASF dual-hosted git repository.
jmclean pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gravitino.git
The following commit(s) were added to refs/heads/main by this push:
new 555f9f633a [#10599] Improvement(core): fix ListModelFailureEvent uses
the schema name as the event identifier name on list failures (#10636)
555f9f633a is described below
commit 555f9f633ad07f21cb55a39a9767a492fb836bf9
Author: Lord of Abyss <[email protected]>
AuthorDate: Thu Apr 2 09:00:12 2026 +0800
[#10599] Improvement(core): fix ListModelFailureEvent uses the schema name
as the event identifier name on list failures (#10636)
### What changes were proposed in this pull request?
fix ListModelFailureEvent uses the schema name as the event identifier
name on list failures
### Why are the changes needed?
Fix: #10599
### Does this PR introduce _any_ user-facing change?
fix ListModelFailureEvent constructor logic.
### How was this patch tested?
local test
---
.../apache/gravitino/listener/api/event/ListModelFailureEvent.java | 4 +++-
.../java/org/apache/gravitino/listener/api/event/TestModelEvent.java | 2 ++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git
a/core/src/main/java/org/apache/gravitino/listener/api/event/ListModelFailureEvent.java
b/core/src/main/java/org/apache/gravitino/listener/api/event/ListModelFailureEvent.java
index 81b46ca7cc..430099b463 100644
---
a/core/src/main/java/org/apache/gravitino/listener/api/event/ListModelFailureEvent.java
+++
b/core/src/main/java/org/apache/gravitino/listener/api/event/ListModelFailureEvent.java
@@ -29,6 +29,8 @@ import org.apache.gravitino.annotation.DeveloperApi;
*/
@DeveloperApi
public class ListModelFailureEvent extends ModelFailureEvent {
+ private static final String LIST_MODEL_NAME = "__list_models__";
+
private final Namespace namespace;
/**
@@ -39,7 +41,7 @@ public class ListModelFailureEvent extends ModelFailureEvent {
* @param exception The exception encountered during the attempt to list
models.
*/
public ListModelFailureEvent(String user, Namespace namespace, Exception
exception) {
- super(user, NameIdentifier.of(namespace.levels()), exception);
+ super(user, NameIdentifier.of(namespace, LIST_MODEL_NAME), exception);
this.namespace = namespace;
}
diff --git
a/core/src/test/java/org/apache/gravitino/listener/api/event/TestModelEvent.java
b/core/src/test/java/org/apache/gravitino/listener/api/event/TestModelEvent.java
index 99b8c0f413..4c4234e547 100644
---
a/core/src/test/java/org/apache/gravitino/listener/api/event/TestModelEvent.java
+++
b/core/src/test/java/org/apache/gravitino/listener/api/event/TestModelEvent.java
@@ -428,6 +428,8 @@ class TestModelEvent {
Assertions.assertEquals(OperationStatus.FAILURE, event.operationStatus());
ListModelFailureEvent listModelFailureEvent = (ListModelFailureEvent)
event;
+ Assertions.assertEquals("__list_models__",
listModelFailureEvent.identifier().name());
+ Assertions.assertEquals(namespace,
listModelFailureEvent.identifier().namespace());
checkArray(namespace.levels(), listModelFailureEvent.namespace().levels());
}