[FLINK-5478] Redis Sink Connector should allow update of command without reinstatiation

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.1.4
• Component/s: Connectors / Common
• Assignee: Unassigned
• Reporter: Atharva Inamdar
• Created: 13/Jan/17 10:24
• Updated: 01/Jul/19 20:28
• Resolved: 24/Jan/17 16:50

Description

`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.

Issue Links

• duplicates: BAHIR-85 Redis Sink Connector should allow update of command without reinstatiation