Skip to content

Commit e3db2c9

Browse files
committed
ARGO-1243 Fix recomputation list initialization in batch_ar
1 parent dcf4876 commit e3db2c9

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

flink_jobs/batch_ar/src/main/java/argo/batch/CreateEndpointGroupTimeline.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -80,6 +80,7 @@ public void open(Configuration parameters) throws IOException, ParseException {
8080
this.ops = getRuntimeContext().getBroadcastVariable("ops");
8181
this.egp = getRuntimeContext().getBroadcastVariable("egp");
8282
this.ggp = getRuntimeContext().getBroadcastVariable("ggp");
83+
this.rec = getRuntimeContext().getBroadcastVariable("rec");
8384
// Initialize metric profile manager
8485
this.mpsMgr = new MetricProfileManager();
8586
this.mpsMgr.loadFromList(mps);

0 commit comments

Comments
 (0)