This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new d62e63cc6 [server] Checks value of LOG_SEGMENT_FILE_SIZE (#1504)
d62e63cc6 is described below
commit d62e63cc6733f66cbe9b7cd9a433bf42a4bb4ec8
Author: Liebing <[email protected]>
AuthorDate: Sun Aug 10 21:35:17 2025 +0800
[server] Checks value of LOG_SEGMENT_FILE_SIZE (#1504)
Co-authored-by: Liebing <[email protected]>
---
.../main/java/com/alibaba/fluss/server/tablet/TabletServer.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java
b/fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java
index 635a15f11..ce221f8d0 100644
---
a/fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java
+++
b/fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java
@@ -457,6 +457,13 @@ public class TabletServer extends ServerBase {
throw new IllegalConfigurationException(
String.format("Configuration %s must be set.",
ConfigOptions.REMOTE_DATA_DIR));
}
+
+ if (conf.get(ConfigOptions.LOG_SEGMENT_FILE_SIZE).getBytes() >
Integer.MAX_VALUE) {
+ throw new IllegalConfigurationException(
+ String.format(
+ "Invalid configuration for %s, it must be less
than or equal %d bytes.",
+ ConfigOptions.LOG_SEGMENT_FILE_SIZE.key(),
Integer.MAX_VALUE));
+ }
}
@VisibleForTesting
