Fix presto SQL does not start prometheus service by default (apache#7030

) Signed-off-by: xiaolong.ran <rxl@apache.org>
Huanli-Meng · Jun 1, 2020 · 666b5ed · 666b5ed
1 parent 6d6dd27
commit 666b5ed
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java b/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java
@@ -81,6 +81,10 @@ public ConnectorRecordSetProvider getRecordSetProvider() {
         return recordSetProvider;
     }
 
+    public void initConnectorCache() throws Exception {
+        PulsarConnectorCache.getConnectorCache(pulsarConnectorConfig);
+    }
+
     @Override
     public final void shutdown() {
         try {

diff --git a/...-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java b/...-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java
@@ -67,7 +67,9 @@ public Connector create(String connectorId, Map<String, String> config, Connecto
                     .setRequiredConfigurationProperties(config)
                     .initialize();
 
-            return injector.getInstance(PulsarConnector.class);
+            PulsarConnector connector = injector.getInstance(PulsarConnector.class);
+            connector.initConnectorCache();
+            return connector;
         } catch (Exception e) {
             throwIfUnchecked(e);
             throw new RuntimeException(e);