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

["Carl (Jira)" <ji...@apache.org>]

Carl created BAHIR-262:
--------------------------

             Summary: Add Redis Table Sink in cluster mode connect with redis by password.
                 Key: BAHIR-262
                 URL: https://issues.apache.org/jira/browse/BAHIR-262
             Project: Bahir
          Issue Type: Improvement
          Components: Flink Streaming Connectors
    Affects Versions: Flink-Next
         Environment: bahir-master branch
            Reporter: Carl
             Fix For: Flink-Next


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

RedisTableSinkFactory:

@Override
public List<String> supportedProperties() {
 List<String> properties = new ArrayList<>();
 properties.add(REDIS_MODE);
 properties.add(REDIS_COMMAND);
 properties.add(REDIS_NODES);
 properties.add(REDIS_MASTER_NAME);
 properties.add(REDIS_SENTINEL);
 properties.add(REDIS_KEY_TTL);
 // schema
 properties.add(SCHEMA + ".#." + SCHEMA_DATA_TYPE);
 properties.add(SCHEMA + ".#." + SCHEMA_NAME);
 properties.add(SCHEMA + ".#." + SCHEMA_FROM);
 // format wildcard
 properties.add(FORMAT + ".*");
 properties.add(CONNECTOR + ".*");
 return properties;
}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)