[BAHIR-262] Add Redis Table Sink in cluster mode connect with redis by password.

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: Flink-1.0
• Fix Version/s: Flink-1.1.0
• Component/s: Flink Streaming Connectors
• Environment: bahir-master branch
• Flags: Important
• Assignee: Unassigned
• Reporter: Carl
• Created: 11/Mar/21 08:20
• Updated: 14/Apr/21 03:21
• Resolved: 14/Apr/21 03:20

Description

RedisTableSinkFactory unsupport connect with redis cluster by password in cluster mode.

proposal:

1. RedisTableSinkFactory#supportedProperties:

add: properties.add("cluster.password");

2. FlinkJedisClusterConfigHandler#createFlinkJedisConfig:

add: String clusterPassword = properties.get("cluster.password");

modify:

if(clusterPassword !=null && !"".equals(clusterPassword))

    return new FlinkJedisClusterConfig.Builder().setNodes(nodes).setPassword(clusterPassword).build();

else

    return new FlinkJedisClusterConfig.Builder().setNodes(nodes).build();