[FLINK-12089] Broadcasting Dynamic Configuration

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.7.2
• Component/s: API / Scala, Runtime / Network
• Assignee: Unassigned
• Reporter: langjingxiang
• Created: 03/Apr/19 03:15
• Updated: 08/Apr/20 11:52

Description

flink Broadcasting Dynamic Configuration now the way is:

datastream :broadcasting stream to join 

dataset: broadcasting dataset 

but Intrusion to user business is relatively large ，

I think we can design an API:

evn.broadcast(confName,confFunction,SchedulingTime)

dataStream.map(new RichMapFunction(){

public void open(Configuration parameters) throws Exception {
Objec broadcastSet = getRuntimeContext().getBroadcastVariable(confName);

}})

 

Job Manager Schedule confFunction broadcast to Task Context