Skip to content

Commit acd4fbb

Browse files
authored
Merge pull request #69 from kaggis/fix-recomp
ARGO-1243 Fix recomputation list initialization in batch_ar
2 parents dcf4876 + e3db2c9 commit acd4fbb

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)