[Enhancement](multi-catalog) Speed up consume rate of hms event.

dutyu · Dec 2, 2023 · 268f845 · 268f845
1 parent ae77de9
commit 268f845
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/MasterCatalogExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/MasterCatalogExecutor.java
@@ -66,7 +66,7 @@ public void forward(long catalogId, long dbId) throws Exception {
  boolean isReturnToPool = false;
  try {
  TInitExternalCtlMetaResult result = client.initExternalCtlMeta(request);
- ConnectContext.get().getEnv().getJournalObservable().waitOn(result.maxJournalId, waitTimeoutMs);
+ Env.getCurrentEnv().getJournalObservable().waitOn(result.maxJournalId, waitTimeoutMs);
  if (!result.getStatus().equalsIgnoreCase(STATUS_OK)) {
  throw new UserException(result.getStatus());
  }