You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by jo...@apache.org on 2022/02/23 01:51:07 UTC
[druid] branch master updated: Re-enable segment metadata cache when using external schema (#12264)
This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new b1640a7 Re-enable segment metadata cache when using external schema (#12264)
b1640a7 is described below
commit b1640a72ee1090bd3c90240bf47a5bfd5b690f5a
Author: Jonathan Wei <jo...@users.noreply.github.com>
AuthorDate: Tue Feb 22 19:50:29 2022 -0600
Re-enable segment metadata cache when using external schema (#12264)
---
.../java/org/apache/druid/sql/calcite/schema/DruidSchema.java | 10 ++--------
1 file changed, 2 insertions(+), 8 deletions(-)
diff --git a/sql/src/main/java/org/apache/druid/sql/calcite/schema/DruidSchema.java b/sql/src/main/java/org/apache/druid/sql/calcite/schema/DruidSchema.java
index 2cf8b60..702ad82 100644
--- a/sql/src/main/java/org/apache/druid/sql/calcite/schema/DruidSchema.java
+++ b/sql/src/main/java/org/apache/druid/sql/calcite/schema/DruidSchema.java
@@ -228,9 +228,7 @@ public class DruidSchema extends AbstractSchema
this.brokerInternalQueryConfig = brokerInternalQueryConfig;
this.druidSchemaManager = druidSchemaManager;
- if (druidSchemaManager == null || druidSchemaManager instanceof NoopDruidSchemaManager) {
- initServerViewTimelineCallback(serverView);
- }
+ initServerViewTimelineCallback(serverView);
}
private void initServerViewTimelineCallback(final TimelineServerView serverView)
@@ -375,11 +373,7 @@ public class DruidSchema extends AbstractSchema
@LifecycleStart
public void start() throws InterruptedException
{
- if (druidSchemaManager == null || druidSchemaManager instanceof NoopDruidSchemaManager) {
- startCacheExec();
- } else {
- initialized.countDown();
- }
+ startCacheExec();
if (config.isAwaitInitializationOnStart()) {
final long startNanos = System.nanoTime();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org