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()) {