undo some

This commit is contained in:
Zoltan Haindrich 2024-05-16 11:11:03 +00:00
parent b63a80e5b7
commit 93892b6524
5 changed files with 4 additions and 7 deletions

View File

@ -28,7 +28,6 @@ import org.apache.druid.discovery.DiscoveryDruidNode;
import org.apache.druid.discovery.DruidNodeDiscovery;
import org.apache.druid.discovery.DruidNodeDiscoveryProvider;
import org.apache.druid.discovery.NodeRole;
import org.apache.druid.discovery.DruidNodeDiscovery.Listener;
import org.apache.druid.guice.LazySingleton;
import org.apache.druid.guice.annotations.Json;
import org.apache.druid.query.QueryRunnerFactoryConglomerate;
@ -71,6 +70,7 @@ public class DiscovertModule extends AbstractModule {
localProps.put("druid.zk.service.enabled", "false");
localProps.put("druid.plaintextPort", "12345");
localProps.put("druid.host", "localhost");
localProps.put("druid.broker.segment.awaitInitializationOnStart","false");
return localProps;
}

View File

@ -40,7 +40,7 @@ public class BrokerSegmentWatcherConfig
private boolean watchRealtimeTasks = true;
@JsonProperty
private boolean awaitInitializationOnStart = false;
private boolean awaitInitializationOnStart = true;
public Set<String> getWatchedTiers()
{

View File

@ -21,6 +21,7 @@ package org.apache.druid.sql.calcite.schema;
import com.google.common.base.Stopwatch;
import com.google.common.collect.Sets;
import com.google.inject.Inject;
import org.apache.druid.client.InternalQueryConfig;
import org.apache.druid.client.ServerView;
import org.apache.druid.client.TimelineServerView;
@ -76,6 +77,7 @@ public class BrokerSegmentMetadataCache extends AbstractSegmentMetadataCache<Phy
private final BrokerSegmentMetadataCacheConfig config;
private final CentralizedDatasourceSchemaConfig centralizedDatasourceSchemaConfig;
@Inject
public BrokerSegmentMetadataCache(
final QueryLifecycleFactory queryLifecycleFactory,
final TimelineServerView serverView,

View File

@ -77,12 +77,10 @@ public class SqlModule implements Module
return;
}
if(false) {
PolyBind.optionBinder(binder, Key.get(ViewManager.class))
.addBinding(NoopViewManager.TYPE)
.to(NoopViewManager.class)
.in(LazySingleton.class);
}
if(false) {
PolyBind.createChoiceWithDefault(

View File

@ -45,9 +45,6 @@ import java.util.List;
*/
public class LookylooModule implements DruidModule
{
public LookylooModule() {
int asd1=1;
}
private static final String LOOKYLOO_INJECTIVE = "lookyloo121";
private static final String LOOKYLOO_CHAINED = "lookyloo-chain";