fix type cast

apache · Oct 10, 2024 · d0b64de · d0b64de
1 parent cd26340
commit d0b64de
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java
@@ -672,7 +672,7 @@ public CompletableFuture<Boolean> hasSchema() {
                 .exceptionally(e -> {
                     Throwable ex = e.getCause();
                     if (brokerService.pulsar().getConfig().isSchemaLedgerForceRecovery()
-                            && !((SchemaException) ex).isRecoverable()) {
+                            && (ex instanceof SchemaException && !((SchemaException) ex).isRecoverable())) {
                         return false;
                     }
                     throw ex instanceof CompletionException ? (CompletionException) ex : new CompletionException(ex);