[ https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16436419#comment-16436419 ]
Aljoscha Krettek commented on FLINK-9152: ----------------------------------------- Fixed on release-1.5 in 833b83b3c2 179b9bce2f 24a8f5186c 51beea6e23 > Harmonize BroadcastProcessFunction Context names > ------------------------------------------------ > > Key: FLINK-9152 > URL: https://issues.apache.org/jira/browse/FLINK-9152 > Project: Flink > Issue Type: Improvement > Components: DataStream API > Affects Versions: 1.5.0 > Reporter: Aljoscha Krettek > Assignee: Aljoscha Krettek > Priority: Blocker > Fix For: 1.5.0 > > > Currently, the {{Context}} on {{KeyedBroadcastProcessFunction}} is called > {{KeyedContext}}, which is different from the name of the context onĀ > {{BroadcastProcessFunction}}. This leads to the strange combination of > {code:java} > public abstract void processBroadcastElement(final IN2 value, final > KeyedContext ctx, final Collector<OUT> out) throws Exception; > {code} > i.e. you're processing a broadcast element but the context is called a > "keyed" context. -- This message was sent by Atlassian JIRA (v7.6.3#76005)