Skip to content

Commit 72df82e

Browse files
author
yanxi0227
committed
case sensitive
1 parent e4f52cd commit 72df82e

2 files changed

Lines changed: 6 additions & 6 deletions

File tree

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

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,11 @@ public TableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, O
3737
if (props.get(RedisTableInfo.TIMEOUT) != null){
3838
redisTableInfo.setTimeout(Integer.parseInt(MathUtil.getString(props.get(RedisTableInfo.TIMEOUT))));
3939
}
40-
redisTableInfo.setMaxTotal(MathUtil.getString(props.get(RedisTableInfo.MAXTOTAL.toLowerCase())));
41-
redisTableInfo.setMaxIdle(MathUtil.getString(props.get(RedisTableInfo.MAXIDLE.toLowerCase())));
42-
redisTableInfo.setMinIdle(MathUtil.getString(props.get(RedisTableInfo.MINIDLE.toLowerCase())));
43-
redisTableInfo.setRedisType(MathUtil.getString(props.get(RedisTableInfo.REDIS_TYPE.toLowerCase())));
44-
redisTableInfo.setMasterName(MathUtil.getString(props.get(RedisTableInfo.MASTER_NAME.toLowerCase())));
40+
redisTableInfo.setMaxTotal(MathUtil.getString(props.get(RedisTableInfo.MAXTOTAL)));
41+
redisTableInfo.setMaxIdle(MathUtil.getString(props.get(RedisTableInfo.MAXIDLE)));
42+
redisTableInfo.setMinIdle(MathUtil.getString(props.get(RedisTableInfo.MINIDLE)));
43+
redisTableInfo.setRedisType(MathUtil.getString(props.get(RedisTableInfo.REDIS_TYPE)));
44+
redisTableInfo.setMasterName(MathUtil.getString(props.get(RedisTableInfo.MASTER_NAME)));
4545
return redisTableInfo;
4646
}
4747
}

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public class RedisTableInfo extends TargetTableInfo {
3131

3232
public static final String PASSWORD_KEY = "password";
3333

34-
public static final String TABLENAME_KEY = "tablename";
34+
public static final String TABLENAME_KEY = "tableName";
3535

3636
public static final String TIMEOUT = "timeout";
3737

0 commit comments

Comments
 (0)