From a2fc735d9afa9b8bd78635a4741cb1c85c7245cb Mon Sep 17 00:00:00 2001 From: charlesdong1991 Date: Sat, 28 Feb 2026 22:48:08 +0100 Subject: [PATCH 1/4] Add missing property stubs in config --- bindings/python/fluss/__init__.pyi | 29 +++++++++++++++++++++++++---- 1 file changed, 25 insertions(+), 4 deletions(-) diff --git a/bindings/python/fluss/__init__.pyi b/bindings/python/fluss/__init__.pyi index 4c2142d7..c387d734 100644 --- a/bindings/python/fluss/__init__.pyi +++ b/bindings/python/fluss/__init__.pyi @@ -169,6 +169,30 @@ class Config: def scanner_log_max_poll_records(self) -> int: ... @scanner_log_max_poll_records.setter def scanner_log_max_poll_records(self, num: int) -> None: ... + @property + def writer_batch_timeout_ms(self) -> int: ... + @writer_batch_timeout_ms.setter + def writer_batch_timeout_ms(self, timeout: int) -> None: ... + @property + def connect_timeout_ms(self) -> int: ... + @connect_timeout_ms.setter + def connect_timeout_ms(self, timeout: int) -> None: ... + @property + def security_protocol(self) -> str: ... + @security_protocol.setter + def security_protocol(self, protocol: str) -> None: ... + @property + def security_sasl_mechanism(self) -> str: ... + @security_sasl_mechanism.setter + def security_sasl_mechanism(self, mechanism: str) -> None: ... + @property + def security_sasl_username(self) -> str: ... + @security_sasl_username.setter + def security_sasl_username(self, username: str) -> None: ... + @property + def security_sasl_password(self) -> str: ... + @security_sasl_password.setter + def security_sasl_password(self, password: str) -> None: ... class FlussConnection: @staticmethod @@ -837,10 +861,6 @@ class TableBucket: def __str__(self) -> str: ... def __repr__(self) -> str: ... -class TableDistribution: - def bucket_keys(self) -> List[str]: ... - def bucket_count(self) -> Optional[int]: ... - class PartitionInfo: """Information about a partition.""" @@ -864,6 +884,7 @@ class ErrorCode: """ CLIENT_ERROR: int + NONE: int UNKNOWN_SERVER_ERROR: int NETWORK_EXCEPTION: int UNSUPPORTED_VERSION: int From 97a4c7f5cc3241916a68f398457956d264af7d7a Mon Sep 17 00:00:00 2001 From: charlesdong1991 Date: Sat, 28 Feb 2026 22:49:07 +0100 Subject: [PATCH 2/4] code update --- bindings/python/fluss/__init__.pyi | 1 - 1 file changed, 1 deletion(-) diff --git a/bindings/python/fluss/__init__.pyi b/bindings/python/fluss/__init__.pyi index c387d734..df8885bd 100644 --- a/bindings/python/fluss/__init__.pyi +++ b/bindings/python/fluss/__init__.pyi @@ -884,7 +884,6 @@ class ErrorCode: """ CLIENT_ERROR: int - NONE: int UNKNOWN_SERVER_ERROR: int NETWORK_EXCEPTION: int UNSUPPORTED_VERSION: int From 6df98adde757d2973e9e52990e5664a2369a1578 Mon Sep 17 00:00:00 2001 From: charlesdong1991 Date: Sat, 28 Feb 2026 22:49:54 +0100 Subject: [PATCH 3/4] revert unrelated change --- bindings/python/fluss/__init__.pyi | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/bindings/python/fluss/__init__.pyi b/bindings/python/fluss/__init__.pyi index df8885bd..04de6876 100644 --- a/bindings/python/fluss/__init__.pyi +++ b/bindings/python/fluss/__init__.pyi @@ -861,6 +861,10 @@ class TableBucket: def __str__(self) -> str: ... def __repr__(self) -> str: ... +class TableDistribution: + def bucket_keys(self) -> List[str]: ... + def bucket_count(self) -> Optional[int]: ... + class PartitionInfo: """Information about a partition.""" From 5b5799944b026686b86d45976149e71dbc0cad7c Mon Sep 17 00:00:00 2001 From: charlesdong1991 Date: Sun, 1 Mar 2026 11:01:50 +0100 Subject: [PATCH 4/4] add error code non and remove unregistered table distribution --- bindings/python/fluss/__init__.pyi | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/bindings/python/fluss/__init__.pyi b/bindings/python/fluss/__init__.pyi index 04de6876..c387d734 100644 --- a/bindings/python/fluss/__init__.pyi +++ b/bindings/python/fluss/__init__.pyi @@ -861,10 +861,6 @@ class TableBucket: def __str__(self) -> str: ... def __repr__(self) -> str: ... -class TableDistribution: - def bucket_keys(self) -> List[str]: ... - def bucket_count(self) -> Optional[int]: ... - class PartitionInfo: """Information about a partition.""" @@ -888,6 +884,7 @@ class ErrorCode: """ CLIENT_ERROR: int + NONE: int UNKNOWN_SERVER_ERROR: int NETWORK_EXCEPTION: int UNSUPPORTED_VERSION: int