fix missing argument adoption

ingef · Feb 25, 2025 · 67a4de2 · 67a4de2
1 parent 795e0d9
commit 67a4de2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -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
@@ -31,7 +31,7 @@ public ClusterManager provideManager(ConqueryConfig config, Environment environm
 		final DatasetRegistry<DistributedNamespace> 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);