[jira] [Commented] (BAHIR-85) Redis Sink Connector should allow update of command without reinstatiation

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/BAHIR-85?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17076846#comment-17076846 ] 

ASF GitHub Bot commented on BAHIR-85:
-------------------------------------

Zentopia commented on issue #60: BAHIR-85: make it possible to change additional key without restarting
URL: https://github.com/apache/bahir-flink/pull/60#issuecomment-610145753
 
 
   Any updates on this?  #We need it. 
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> Redis Sink Connector should allow update of command without reinstatiation 
> ---------------------------------------------------------------------------
>
>                 Key: BAHIR-85
>                 URL: https://issues.apache.org/jira/browse/BAHIR-85
>             Project: Bahir
>          Issue Type: Improvement
>          Components: Flink Streaming Connectors
>            Reporter: Atharva Inamdar
>            Priority: Major
>
> ref: FLINK-5478
> `getCommandDescription()` gets called when RedisSink is instantiated. This happens only once and thus doesn't allow the command to be updated during run time.
> Use Case:
> As a dev I want to store some data by day. So each key will have some date specified. this will change over course of time. for example: `counts_for_1484265600000` for 2017-01-13. This is not limited to any particular command.
> connector: https://github.com/apache/bahir-flink/blob/master/flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java#L114
> I wish `getCommandDescription()` could be called in `invoke()` so that the key can be updated without having to restart.



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