Updating Configs

Overview

Fluss allows you to update cluster or table configurations dynamically without requiring a cluster restart or table recreation. This section demonstrates how to modify and apply such configurations.

Updating Cluster Configs

From Fluss version 0.8 onwards, some of the server configs can be updated without restarting the server.

Currently, the supported dynamically updatable server configurations include:

• datalake.format: Enable lakehouse storage by specifying the lakehouse format, e.g., paimon, iceberg.
• Options with prefix datalake.${datalake.format}

You can update the configuration of a cluster with Java client. Here is a code snippet to demonstrate how to update the cluster configurations using the Java Client:

// Enable lakehouse storage with Paimon format
admin.alterClusterConfigs(
        Collections.singletonList(
                new AlterConfig(DATALAKE_FORMAT.key(), "paimon", AlterConfigOpType.SET)));

// Disable lakehouse storage
admin.alterClusterConfigs(
        Collections.singletonList(
                new AlterConfig(DATALAKE_FORMAT.key(), "paimon", AlterConfigOpType.DELETE)));

The AlterConfig class contains three properties:

• key: The configuration key to be modified (e.g., datalake.format)
• value: The configuration value to be set (e.g., paimon)
• opType: The operation type, either AlterConfigOpType.SET or AlterConfigOpType.DELETE

Updating Table Configs

The connector options on a table including Storage Options can be updated dynamically by ALTER TABLE ... SET statement. See the example below:

-- Enable lakehouse storage for the given table
ALTER TABLE my_table SET ('table.datalake.enabled' = 'true');