We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ebc3609 commit 65d3bbaCopy full SHA for 65d3bba
modules/grpc/common/grpc-source.cpp
@@ -47,10 +47,13 @@ SourceDriver::init()
47
48
::grpc::EnableDefaultHealthCheckService(true);
49
50
- this->super->super.worker_options.super.init_window_size /= super->super.num_workers;
51
-
52
if (fetch_limit == -1)
53
- 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;
54
+ else
55
+ fetch_limit = 100;
56
+ }
57
58
return log_threaded_source_driver_init_method(&this->super->super.super.super.super);
59
}
0 commit comments