From 67a4de25fe3e69f5f6ec4520d88e6ced18f35633 Mon Sep 17 00:00:00 2001 From: Max Thonagel <12283268+thoniTUB@users.noreply.github.com> Date: Tue, 25 Feb 2025 10:48:33 +0100 Subject: [PATCH] fix missing argument adoption --- .../bakdata/conquery/mode/cluster/ClusterConnectionManager.java | 2 +- .../bakdata/conquery/mode/cluster/ClusterManagerProvider.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterConnectionManager.java b/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterConnectionManager.java index 9d0748a325..96b92b2dc1 100644 --- a/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterConnectionManager.java +++ b/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterConnectionManager.java @@ -68,7 +68,7 @@ public void messageReceived(IoSession session, Object message) { final NetworkSession nwSession; if (shardNodeInformation == null) { - // In case the shard is not yet registered, we wont have a shardNodeInformation to pull the session from + // In case the shard is not yet registered, we won't have a shardNodeInformation to pull the session from nwSession = new NetworkSession(session, config.getCluster().getNetworkSessionMaxQueueLength()); } else { diff --git a/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterManagerProvider.java b/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterManagerProvider.java index 9f93b0c108..2bc52bc559 100644 --- a/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterManagerProvider.java +++ b/backend/src/main/java/com/bakdata/conquery/mode/cluster/ClusterManagerProvider.java @@ -31,7 +31,7 @@ public ClusterManager provideManager(ConqueryConfig config, Environment environm final DatasetRegistry datasetRegistry = ManagerProvider.createDatasetRegistry(namespaceHandler, config, internalMapperFactory); final ClusterConnectionManager connectionManager = - new ClusterConnectionManager(datasetRegistry, jobManager, environment.getValidator(), config, internalMapperFactory, clusterState); + new ClusterConnectionManager(datasetRegistry, jobManager, config, internalMapperFactory, clusterState); final ImportHandler importHandler = new ClusterImportHandler(datasetRegistry); final StorageListener extension = new ClusterStorageListener(jobManager, datasetRegistry);