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

Hong Liang Teoh commented on FLINK-33180:
-----------------------------------------

Hi [~cprakash] Do you mind explaining the use case a little bit more? Would you 
be keen on setting up a subset of traffic by shards, or by dropping random 
records within a given shard?

Is there a reason a CustomShardAssigner cannot serve your use case?

> Implement support for processing subset of  shards/traffic
> ----------------------------------------------------------
>
>                 Key: FLINK-33180
>                 URL: https://issues.apache.org/jira/browse/FLINK-33180
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Chandra Prakash
>            Priority: Major
>
> Support processing of subset of shards/traffic. This feature is require to 
> implement canary / onebox.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to