diff --git a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
index 97d8246bde..121936fe1b 100644
--- a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
+++ b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java
@@ -303,7 +303,7 @@ private boolean existsResourceByConnectorIds(List<String> connectorIds) {
   public List<FlinkConnectorResource> getConnectorResource(Resource resource) throws Exception {
 
     ApiAlertException.throwIfFalse(
-        !ResourceType.CONNECTOR.equals(resource.getResourceType()),
+        ResourceType.CONNECTOR.equals(resource.getResourceType()),
         "getConnectorId method error, resource not flink connector.");
 
     Dependency dependency = Dependency.toDependency(resource.getResource());