[rocketmq-connect] branch master updated: Fix: compare Enum with String is Never equal (#375)

[zhoubo]

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

zhoubo 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 19edbddb Fix: compare Enum with String is Never equal (#375)
19edbddb is described below

commit 19edbddb4343239b6c31714f0759d963febfdf11
Author: chenwei182729 <chenwei182...@163.com>
AuthorDate: Tue Nov 15 14:56:25 2022 +0800

    Fix: compare Enum with String is Never equal (#375)
---
 .../apache/rocketmq/connect/runtime/rest/ConnectorPluginsResource.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/ConnectorPluginsResource.java
 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/ConnectorPluginsResource.java
index 2071e757..3a1113b5 100644
--- 
a/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/ConnectorPluginsResource.java
+++ 
b/rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/ConnectorPluginsResource.java
@@ -100,7 +100,7 @@ public class ConnectorPluginsResource {
     public void listConnectorPlugins(Context context) {
         synchronized (this) {
             List<PluginInfo> pluginInfos = 
Collections.unmodifiableList(connectorPlugins.stream()
-                    .filter(p -> 
PluginType.SINK.toString().equals(p.getType()) || 
PluginType.SOURCE.toString().equals(p.getType()))
+                    .filter(p -> PluginType.SINK.equals(p.getType()) || 
PluginType.SOURCE.equals(p.getType()))
                     .collect(Collectors.toList()));
             context.json(new HttpResponse<>(context.status(), pluginInfos));
         }