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

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

     [ https://issues.apache.org/jira/browse/BAHIR-262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Carl updated BAHIR-262:
-----------------------
    Affects Version/s: Flink-1.0

> 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
>
>   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)