diff --git a/docs/docs/flink/procedures/compaction.md b/docs/docs/flink/procedures/compaction.md index bec655633302..d2a3b889f955 100644 --- a/docs/docs/flink/procedures/compaction.md +++ b/docs/docs/flink/procedures/compaction.md @@ -130,9 +130,9 @@ To compact databases. Arguments: - `mode`: compact mode. "divided" (default): start a sink for each table, detecting the new table requires restarting the job; "combined": start a single combined sink for all tables, the new table will be automatically detected. -- `includingTables`: to specify tables. You can use regular expression. +- `includingTables`: to specify tables. The format is `databaseName.tableName`, and the whole name must match. You can use regular expression, for example `.*\.table_.*`. -- `excludingTables`: to specify tables that are not compacted. You can use regular expression. +- `excludingTables`: to specify tables that are not compacted. The usage is same as `includingTables`. - `tableOptions`: additional dynamic options of the table. @@ -198,8 +198,8 @@ CALL [catalog.]sys.compact_database( CALL sys.compact_database( including_databases => 'db1|db2', mode => 'combined', - including_tables => 'table_.*', - excluding_tables => 'ignore', + including_tables => '.*\.table_.*', + excluding_tables => '.*\.ignore', table_options => 'sink.parallelism=4', compact_strategy => 'full'); ``` diff --git a/docs/docs/maintenance/dedicated-compaction.mdx b/docs/docs/maintenance/dedicated-compaction.mdx index 7b190a771014..6632b630502b 100644 --- a/docs/docs/maintenance/dedicated-compaction.mdx +++ b/docs/docs/maintenance/dedicated-compaction.mdx @@ -221,8 +221,8 @@ CALL sys.compact_database( CALL sys.compact_database( including_databases => 'db1|db2', mode => 'combined', - including_tables => 'table_.*', - excluding_tables => 'ignore', + including_tables => '.*\.table_.*', + excluding_tables => '.*\.ignore', table_options => 'sink.parallelism=4' ) ``` @@ -444,7 +444,7 @@ Example: compact historical partitions for tables in database ```sql -- history partition compact table CALL sys.compact_database( - includingDatabases => 'test_db', + including_databases => 'test_db', mode => 'combined', partition_idle_time => '1 d' );