You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Atharva Inamdar (JIRA)" <ji...@apache.org> on 2017/01/13 10:24:26 UTC
[jira] [Created] (FLINK-5478) Redis Sink Connector should allow
update of command without reinstatiation
Atharva Inamdar created FLINK-5478:
--------------------------------------
Summary: Redis Sink Connector should allow update of command without reinstatiation
Key: FLINK-5478
URL: https://issues.apache.org/jira/browse/FLINK-5478
Project: Flink
Issue Type: Improvement
Components: Streaming Connectors
Affects Versions: 1.1.4
Reporter: Atharva Inamdar
Priority: Minor
`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.
old link to connector (not sure where this lives now): https://github.com/subhankarb/flink/blob/be6b0a9277f191f812be422e45a6fda3247de388/flink-streaming-connectors/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
(v6.3.4#6332)