Aljoscha Krettek created FLINK-9152: ---------------------------------------
Summary: Harmonize BroadcastProcessFunction Context names Key: FLINK-9152 URL: https://issues.apache.org/jira/browse/FLINK-9152 Project: Flink Issue Type: Improvement Components: DataStream API Reporter: Aljoscha Krettek Assignee: Aljoscha Krettek 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)