minor improvement

apache · Jul 26, 2023 · ddb9244 · ddb9244
1 parent 7cc6eba
commit ddb9244
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ce/src/main/java/org/apache/streampark/console/core/service/impl/ResourceServiceImpl.java b/...ce/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());