diff --git a/datanode/src/datanode_server.py b/datanode/src/datanode_server.py index 721ccf2..d7dce37 100644 --- 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)