jerrypeng commented on a change in pull request #7237:
URL: https://github.com/apache/pulsar/pull/7237#discussion_r442673058
##########
File path:
pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.java
##########
@@ -99,16 +98,20 @@ public void initialize() {
this.functionMetaDataTopicTailer.processRequest(this.functionMetaDataTopicTailer.getReader().readNext());
}
this.setInitializePhase(false);
- // schedule functions if necessary
- this.schedulerManager.schedule();
- // start function metadata tailer
- this.functionMetaDataTopicTailer.start();
+
} catch (Exception e) {
log.error("Failed to initialize meta data store", e);
throw new RuntimeException(e);
}
}
+
+ public void start() {
Review comment:
because we cannot start prior to the SchedulerManager is setup since
function metadata manager can invoke the scheduler. We can initialize prior to
to setting up the SchedulerManager but we cannot start
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
