This is an automated email from the ASF dual-hosted git repository. vterentev pushed a commit to branch fix-postcommit-python in repository https://gitbox.apache.org/repos/asf/beam.git
commit d9cd33668166acb751f108473f1e4299d3f750eb Author: Vitaly Terentyev <[email protected]> AuthorDate: Thu Jul 24 16:33:38 2025 +0400 Fix debezium port type --- sdks/python/apache_beam/io/debezium.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/io/debezium.py b/sdks/python/apache_beam/io/debezium.py index 9e93801852c..26516fa4e4b 100644 --- a/sdks/python/apache_beam/io/debezium.py +++ b/sdks/python/apache_beam/io/debezium.py @@ -155,7 +155,7 @@ class ReadFromDebezium(PTransform): username=username, password=password, host=host, - port=port, + port=str(port), max_number_of_records=max_number_of_records, connection_properties=connection_properties) self.expansion_service = expansion_service or default_io_expansion_service()
