fixup: fix init window and fetch limit calculation

axoflow · Oct 7, 2024 · 6b20819 · 6b20819
1 parent 41fe827
commit 6b20819
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/modules/grpc/common/grpc-source.cpp b/modules/grpc/common/grpc-source.cpp
@@ -47,10 +47,13 @@ SourceDriver::init()
 
   ::grpc::EnableDefaultHealthCheckService(true);
 
-  this->super->super.worker_options.super.init_window_size /= super->super.num_workers;
-
   if (fetch_limit == -1)
-    fetch_limit = this->super->super.worker_options.super.init_window_size;
+    {
+      if (super->super.worker_options.super.init_window_size != -1)
+        fetch_limit = super->super.worker_options.super.init_window_size / super->super.num_workers;
+      else
+        fetch_limit = 100;
+    }
 
   return log_threaded_source_driver_init_method(&this->super->super.super.super.super);
 }