[
https://issues.apache.org/jira/browse/FLINK-27226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17704519#comment-17704519
]
Wencong Liu edited comment on FLINK-27226 at 3/24/23 8:47 AM:
--------------------------------------------------------------
Hello [~Underwood] , are you trying to implement the logic by a data stream
job? I think the Z letter cannot be incremented by every record because there
is no global variable in the flink job.
was (Author: JIRAUSER281639):
Hello [~Underwood] , are you trying to implement the logic by a data stream
job? I think the Z letter cannot be incremented by every record because it's
not a global variable in the flink job.
> How to implement two partition methods for an operator at the same time?
> ------------------------------------------------------------------------
>
> Key: FLINK-27226
> URL: https://issues.apache.org/jira/browse/FLINK-27226
> Project: Flink
> Issue Type: New Feature
> Components: API / DataStream
> Affects Versions: 1.14.3
> Reporter: Underwood
> Priority: Major
>
> For example, I'm counting letters. Each letter of A ~ Y corresponds to a
> partition, and each partition records the number of times their letters
> appear, but the letter of Z needs to be counted by each partition, that is,
> in a stream, A ~ Y needs hash partition and Z needs broadcast partition. Is
> there any method to realize this?
> I want to use partitioncustom, but it seems that it can only be sent to one
> partition.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
