Fix datanode thread pool conversion to int

kysre · Feb 13, 2024 · bb6ccf2 · bb6ccf2
1 parent 17559ab
commit bb6ccf2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datanode/src/datanode_server.py b/datanode/src/datanode_server.py
@@ -206,7 +206,7 @@ def serve():
 
     server = grpc.server(
         futures.ThreadPoolExecutor(
-            max_workers=ConfigManager.get_prop('server_thread_pool_size')
+            max_workers=int(ConfigManager.get_prop('server_thread_pool_size'))
         )
     )
     datanode = DataNode(partitions_count, home_path, datanode_name)