This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 59fd4ec774 [dcos] Supplementary document description (#9404)
59fd4ec774 is described below
commit 59fd4ec77497552af8b1d1b5cfc399e6e7d6895a
Author: sanshi <[email protected]>
AuthorDate: Wed Aug 26 16:27:09 2026 +0800
[dcos] Supplementary document description (#9404)
---
docs/docs/append-table/bucketed.mdx | 2 +-
docs/docs/maintenance/dedicated-compaction.mdx | 20 ++++++++++++++++++++
docs/docs/primary-key-table/query-performance.md | 2 +-
3 files changed, 22 insertions(+), 2 deletions(-)
diff --git a/docs/docs/append-table/bucketed.mdx
b/docs/docs/append-table/bucketed.mdx
index 59493ea5ae..66b78ad57c 100644
--- a/docs/docs/append-table/bucketed.mdx
+++ b/docs/docs/append-table/bucketed.mdx
@@ -83,7 +83,7 @@ CREATE TABLE FACT_TABLE (order_id INT, f1 STRING)
TBLPROPERTIES ('bucket'='10',
CREATE TABLE DIM_TABLE (order_id INT, f2 STRING) TBLPROPERTIES ('bucket'='10',
'primary-key' = 'order_id');
-SELECT * FROM FACT_TABLE JOIN DIM_TABLE on t1.order_id = t4.order_id;
+SELECT * FROM FACT_TABLE AS fact JOIN DIM_TABLE AS dim ON fact.order_id =
dim.order_id;
```
The `spark.sql.sources.v2.bucketing.enabled` config is used to enable
bucketing for V2 data sources. When turned on,
diff --git a/docs/docs/maintenance/dedicated-compaction.mdx
b/docs/docs/maintenance/dedicated-compaction.mdx
index c2f6dc4fb1..153118053f 100644
--- a/docs/docs/maintenance/dedicated-compaction.mdx
+++ b/docs/docs/maintenance/dedicated-compaction.mdx
@@ -113,6 +113,7 @@ Run the following command to submit a compaction job for
the table.
--database <database-name> \
--table <table-name> \
[--partition <partition-name>] \
+ [--buckets <bucket-ids-or-ranges>] \
[--compact_strategy <minor / full>] \
[--table_conf <table_conf>] \
[--catalog_conf <paimon-catalog-conf> [--catalog_conf
<paimon-catalog-conf> ...]]
@@ -155,6 +156,25 @@ For more usage of the compact action, see
</Tabs>
+### Compact Specified Buckets
+
+For fixed-bucket tables, a dedicated compaction can target selected buckets.
The `sys.compact` procedure is available in Flink SQL and Spark SQL. The
expression supports a single ID, comma-separated IDs, closed ranges, or
combinations such as `0`, `0,2,5`, `0-9`, and `0-9,20`.
+
+```sql
+CALL sys.compact(`table` => 'default.T', partitions => 'dt=20221126',
compact_strategy => 'full', buckets => '0-1,3');
+```
+
+The equivalent Flink Action command is:
+
+```bash
+<FLINK_HOME>/bin/flink run -Dexecution.runtime-mode=batch \
+ /path/to/paimon-flink-action-@@VERSION@@.jar compact \
+ --warehouse s3:///path/to/warehouse --database test_db --table test_table \
+ --partition dt=20221126 --compact_strategy full --buckets 0-1,3
+```
+
+`buckets` is supported only for fixed-bucket tables (`bucket > 0`). Each ID
must be in the range `0` (inclusive) to the configured bucket number
(exclusive). Partition filters can be combined with the bucket filter. Bucket
selection is not supported for [Sort Compact](#sort-compact), dynamic-bucket
tables, unaware-bucket tables, or postpone-bucket tables.
+
:::info
Similarly, the default is synchronous compaction, which may cause checkpoint
timeouts.
diff --git a/docs/docs/primary-key-table/query-performance.md
b/docs/docs/primary-key-table/query-performance.md
index e54f28b00e..7d0bc2931b 100644
--- a/docs/docs/primary-key-table/query-performance.md
+++ b/docs/docs/primary-key-table/query-performance.md
@@ -92,7 +92,7 @@ CREATE TABLE FACT_TABLE (order_id INT, f1 STRING)
TBLPROPERTIES ('bucket'='10',
CREATE TABLE DIM_TABLE (order_id INT, f2 STRING) TBLPROPERTIES ('bucket'='10',
'primary-key' = 'order_id');
-SELECT * FROM FACT_TABLE JOIN DIM_TABLE on t1.order_id = t4.order_id;
+SELECT * FROM FACT_TABLE AS fact JOIN DIM_TABLE AS dim ON fact.order_id =
dim.order_id;
```
The `spark.sql.sources.v2.bucketing.enabled` config is used to enable
bucketing for V2 data sources. When turned on,
