mirror of https://github.com/apache/druid.git
Re-enable segment metadata cache when using external schema (#12264)
This commit is contained in:
parent
b94390ba33
commit
b1640a72ee
|
@ -228,10 +228,8 @@ public class DruidSchema extends AbstractSchema
|
||||||
this.brokerInternalQueryConfig = brokerInternalQueryConfig;
|
this.brokerInternalQueryConfig = brokerInternalQueryConfig;
|
||||||
this.druidSchemaManager = druidSchemaManager;
|
this.druidSchemaManager = druidSchemaManager;
|
||||||
|
|
||||||
if (druidSchemaManager == null || druidSchemaManager instanceof NoopDruidSchemaManager) {
|
|
||||||
initServerViewTimelineCallback(serverView);
|
initServerViewTimelineCallback(serverView);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
private void initServerViewTimelineCallback(final TimelineServerView serverView)
|
private void initServerViewTimelineCallback(final TimelineServerView serverView)
|
||||||
{
|
{
|
||||||
|
@ -375,11 +373,7 @@ public class DruidSchema extends AbstractSchema
|
||||||
@LifecycleStart
|
@LifecycleStart
|
||||||
public void start() throws InterruptedException
|
public void start() throws InterruptedException
|
||||||
{
|
{
|
||||||
if (druidSchemaManager == null || druidSchemaManager instanceof NoopDruidSchemaManager) {
|
|
||||||
startCacheExec();
|
startCacheExec();
|
||||||
} else {
|
|
||||||
initialized.countDown();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (config.isAwaitInitializationOnStart()) {
|
if (config.isAwaitInitializationOnStart()) {
|
||||||
final long startNanos = System.nanoTime();
|
final long startNanos = System.nanoTime();
|
||||||
|
|
Loading…
Reference in New Issue