[rocketmq-connect] branch master updated: [ISSUE #449] Stop connector fail bug fix

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new fa989df4 [ISSUE #449] Stop connector fail bug fix
fa989df4 is described below

commit fa989df455b90ba6d1530489434f0fcd5856679d
Author: zhoubo <877036...@qq.com>
AuthorDate: Mon Apr 3 15:23:47 2023 +0800

    [ISSUE #449] Stop connector fail bug fix
---
 .../connect/runtime/service/AbstractConfigManagementService.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java
index 8dbf4838..1ce8940f 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java
@@ -248,7 +248,7 @@ public abstract class AbstractConfigManagementService 
implements ConfigManagemen
         struct.put(FIELD_EPOCH, System.currentTimeMillis());
         struct.put(FIELD_DELETED, true);
         byte[] config = converter.fromConnectData(topic, 
CONNECTOR_DELETE_CONFIGURATION_V1, struct);
-        notify(CONNECTOR_KEY(connectorName), config);
+        notify(DELETE_CONNECTOR_KEY(connectorName), config);
     }
 
     /**