Skip to content

Commit e5a9338

Browse files
authored
Fix too-many-pings on FnAPI runner under grpc mode (#37013)
* Fix too-many-pings on FnAPI runner under grpc mode * Fix lints
1 parent a6932b6 commit e5a9338

File tree

1 file changed

+9
-4
lines changed

1 file changed

+9
-4
lines changed

sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -465,10 +465,15 @@ def __init__(
465465
# received or sent over the data plane. The actual buffer size
466466
# is controlled in a layer above. Also, options to keep the server alive
467467
# when too many pings are received.
468-
options = [("grpc.max_receive_message_length", -1),
469-
("grpc.max_send_message_length", -1),
470-
("grpc.http2.max_pings_without_data", 0),
471-
("grpc.http2.max_ping_strikes", 0)]
468+
options = [
469+
("grpc.max_receive_message_length", -1),
470+
("grpc.max_send_message_length", -1),
471+
("grpc.http2.max_pings_without_data", 0),
472+
("grpc.http2.max_ping_strikes", 0),
473+
# match `grpc.keepalive_time_ms` defined in the client
474+
# (channel_factory.py)
475+
("grpc.http2.min_ping_interval_without_data_ms", 20_000),
476+
]
472477

473478
self.state = state
474479
self.provision_info = provision_info

0 commit comments

Comments
 (0)