You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@bahir.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2021/03/11 13:00:00 UTC
[jira] [Commented] (BAHIR-262) Add Redis Table Sink in cluster mode
connect with redis by password.
[ https://issues.apache.org/jira/browse/BAHIR-262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299541#comment-17299541 ]
ASF subversion and git services commented on BAHIR-262:
-------------------------------------------------------
Commit f968c8183fff067569a0924a0a407b0f8c5956ff in bahir-flink's branch refs/heads/master from ahern88
[ https://gitbox.apache.org/repos/asf?p=bahir-flink.git;h=f968c81 ]
[BAHIR-262] Add support to redis cluster password (#101)
* support set redis cluster password
> 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.
> *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();
--
This message was sent by Atlassian Jira
(v8.3.4#803005)