update connector runtime

xwm1992 · Apr 24, 2024 · 69f4c1e · 69f4c1e
1 parent 43e00b6
commit 69f4c1e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...esh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntime.java b/...esh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntime.java
@@ -68,7 +68,7 @@ public class ConnectorRuntime implements Runtime {
     private final ExecutorService startService =
         ThreadPoolFactory.createSingleExecutor("eventMesh-sourceWorker-startService");
 
-    private final ScheduledExecutorService heartBeatExecutor = Executors.newSingleThreadScheduledExecutor();;
+    private final ScheduledExecutorService heartBeatExecutor = Executors.newSingleThreadScheduledExecutor();
 
     private final BlockingQueue<ConnectRecord> queue;
 
@@ -84,6 +84,8 @@ public ConnectorRuntime(RuntimeInstanceConfig runtimeInstanceConfig) {
     public void init() throws Exception {
         connectorRuntimeConfig = ConfigService.getInstance().buildConfigInstance(ConnectorRuntimeConfig.class);
 
+        //TODO: 根据connectorRuntimeConfig中的jobId，从adminServer获取connectorRuntimeConfig信息，然后初始化connector
+
         ConnectorCreateService<?> sourceConnectorCreateService = ConnectorPluginFactory.createConnector(
             connectorRuntimeConfig.getSourceConnectorType());
         sourceConnector = (Source)sourceConnectorCreateService.create();
@@ -133,7 +135,6 @@ public void onCompleted() {
 
         requestObserver = adminStub.invokeBiStream(responseObserver);
 
-        //TODO: 根据connectorRuntimeConfig中的
 
         heartBeatExecutor.scheduleAtFixedRate(() -> {