diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java index 2fd94c049ae..ab71d19a056 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java @@ -77,9 +77,15 @@ public class ListFilter { private String getEventSubscriptionAlertType() { String alertType = queryParams.get("alertType"); - return alertType == null - ? "" - : String.format("JSON_EXTRACT(json, '$.alertType') = '%s'", alertType); + if (alertType == null) { + return ""; + } else { + if (Boolean.TRUE.equals(DatasourceConfig.getInstance().isMySQL())) { + return String.format("JSON_EXTRACT(json, '$.alertType') = '%s'", alertType); + } else { + return String.format("json->>'alertType' = '%s'", alertType); + } + } } private String getTestCaseResolutionStatusType() {