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)
