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

["shukun.lee (JIRA)" <ji...@apache.org>]

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

shukun.lee commented on BAHIR-85:
---------------------------------

hello everyone,

I have the same case when use flink-connector-redis. 
 In my use case,I need use HSET command to update data, which shcema like (ts,field,value).So I must get ts(timestamp) as addtionalKey according to input data.
 Therefore,I think it's no need to new a 'RedisCommandDescription' when every data is comming,however we need a way to update addtionalKey.

Unfortunately,I can't find any way for update it.

> 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
(v7.6.3#76005)