[
https://issues.apache.org/jira/browse/FLINK-5478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atharva Inamdar updated FLINK-5478:
-----------------------------------
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.
was:
`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.
> 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.
> 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
(v6.3.4#6332)
