[incubator-seatunnel] branch cdc-multiple-table updated: [Improve] Fix DataTypeConvertorFactory Can't Key Can't be found (#4136)

[fanjia]

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 b8644ef51 [Improve] Fix DataTypeConvertorFactory Can't Key Can't be 
found (#4136)
b8644ef51 is described below

commit b8644ef51ff9edd4b474e50cfbd399094a2f0e73
Author: Hisoka <fanjiaemi...@qq.com>
AuthorDate: Wed Feb 15 15:41:34 2023 +0800

    [Improve] Fix DataTypeConvertorFactory Can't Key Can't be found (#4136)
---
 .../seatunnel/api/table/factory/DataTypeConvertorFactory.java     | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/DataTypeConvertorFactory.java
 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/DataTypeConvertorFactory.java
index d9d7e5e98..d19942b95 100644
--- 
a/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/DataTypeConvertorFactory.java
+++ 
b/seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/DataTypeConvertorFactory.java
@@ -35,21 +35,15 @@ public class DataTypeConvertorFactory {
 
     public DataTypeConvertorFactory(ClassLoader classLoader) {
         ServiceLoader.load(DataTypeConvertor.class, 
classLoader).forEach(dataTypeConvertor -> {
-            dataTypeConvertorMap.put(dataTypeConvertor.getIdentity(), 
dataTypeConvertor);
+            
dataTypeConvertorMap.put(dataTypeConvertor.getIdentity().toUpperCase(), 
dataTypeConvertor);
         });
     }
 
     public DataTypeConvertor<?> getDataTypeConvertor(String convertorIdentify) 
{
         checkNotNull(convertorIdentify, "connectorIdentify can not be null");
-        if (dataTypeConvertorMap.containsKey(convertorIdentify)) {
-            return dataTypeConvertorMap.get(convertorIdentify);
-        }
         if (dataTypeConvertorMap.containsKey(convertorIdentify.toUpperCase())) 
{
             return dataTypeConvertorMap.get(convertorIdentify.toUpperCase());
         }
-        if (dataTypeConvertorMap.containsKey(convertorIdentify.toLowerCase())) 
{
-            return dataTypeConvertorMap.get(convertorIdentify.toLowerCase());
-        }
         throw new IllegalArgumentException("connectorIdentify " + 
convertorIdentify + " is not supported");
     }
 }