[
https://issues.apache.org/jira/browse/BAHIR-262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carl updated BAHIR-262:
-----------------------
Attachment: screenshot-1.png
> 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-1.0
> Environment: bahir-master branch
> Reporter: Carl
> Priority: Major
> Fix For: Flink-Next
>
> Attachments: screenshot-1.png
>
> Original Estimate: 1h
> Remaining Estimate: 1h
>
> 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)
