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

fanjia pushed a commit to branch cdc-multiple-table
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/cdc-multiple-table by this 
push:
     new 6ef28e53d [Improve] Improve FactoryUtil Ignore Case (#4211)
6ef28e53d is described below

commit 6ef28e53d11899220c0be3b088fbe38611c4eb3c
Author: Hisoka <[email protected]>
AuthorDate: Fri Feb 24 18:53:33 2023 +0800

    [Improve] Improve FactoryUtil Ignore Case (#4211)
---
 .../main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java
 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java
index 23a5d0a92..e67604e2b 100644
--- 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java
+++ 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java
@@ -141,7 +141,7 @@ public final class FactoryUtil {
         }
         final List<T> matchingFactories =
                 foundFactories.stream()
-                        .filter(f -> 
f.factoryIdentifier().equals(factoryIdentifier))
+                        .filter(f -> 
f.factoryIdentifier().equalsIgnoreCase(factoryIdentifier))
                         .collect(Collectors.toList());
         if (matchingFactories.isEmpty()) {
             return Optional.empty();
@@ -163,7 +163,7 @@ public final class FactoryUtil {
 
         final List<T> matchingFactories =
                 foundFactories.stream()
-                        .filter(f -> 
f.factoryIdentifier().equals(factoryIdentifier))
+                        .filter(f -> 
f.factoryIdentifier().equalsIgnoreCase(factoryIdentifier))
                         .collect(Collectors.toList());
 
         if (matchingFactories.isEmpty()) {

Reply via email to