[fix-34812][redis] 去除在with参数的primaryKeys，在CREATE语句中定义主键

Author: FlechazoW

impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java

@@ -34,7 +34,6 @@
 import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
-import java.rmi.RemoteException;
 import java.security.PrivilegedExceptionAction;
 import java.sql.Connection;
 import java.sql.DriverManager;
@@ -52,7 +51,6 @@
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicReference;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;

redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/table/RedisSinkParser.java

@@ -53,12 +53,6 @@ public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<S
             redisTableInfo.setKeyExpiredTime(Integer.parseInt(MathUtil.getString(props.get(RedisTableInfo.KEY_EXPIRED_TIME.toLowerCase()))));
         }
 
-        String primaryKeysStr = MathUtil.getString(props.get(RedisTableInfo.PRIMARY_KEYS_NAME));
-        List<String> primaryKeysList = Lists.newArrayList();
-        if (!StringUtils.isEmpty(primaryKeysStr)) {
-            primaryKeysList = Arrays.asList(StringUtils.split(primaryKeysStr, ","));
-        }
-        redisTableInfo.setPrimaryKeys(primaryKeysList);
         redisTableInfo.setParallelism(MathUtil.getIntegerVal(props.get(RedisTableInfo.PARALLELISM_KEY.toLowerCase())));
 
         return redisTableInfo;

redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/table/RedisTableInfo.java

@@ -47,8 +47,6 @@ public class RedisTableInfo extends AbstractTargetTableInfo {
 
     public static final String MASTER_NAME = "masterName";
 
-    public static final String PRIMARY_KEYS_NAME = "primarykeys";
-
     public static final String KEY_EXPIRED_TIME = "keyExpiredTime";
 
     public RedisTableInfo(){