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 635a15f11c..ce221f8d04 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 @@ private static void validateConfigs(Configuration conf) { 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