權限說明

• 僅支持使用阿里云賬號或者RAM用戶擴容計算組，不支持STS賬號。

• 擴容計算組計算資源需要具備以下權限：

  • RAM角色權限：AliyunHologresWarehouseFullAccess或AliyunHologresFullAccess權限。

  • 實例內部的Superuser權限。

使用說明

• 擴容計算組前，需要先在管控臺上擴容實例的資源，確保實例有足夠的未分配資源。當實例資源調整完畢后，系統會拉起新的Pod，但是此時Pod上并未加載任何Shard的元數據，所以擴容出來的Pod不會參與計算，實例擴容的操作不會影響計算組的查詢和寫入。

• 實例擴容完成，且有足夠的未分配資源后，可以繼續使用該部分未分配資源，擴容計算組資源。如果實例未分配資源不足，則無法完成計算組擴容。

  • 自Hologres V2.2版本起，如果計算組有空Pod，系統會自動執行Rebalance操作，使新的Pod加載Shard的元數據。在Rebalance完成后，才能使用新擴容的資源，Rebalance時查詢和寫入會中斷15秒。因此，如果您的實例為V2.2及以上版本，擴容計算組后，無需手動執行Rebalance操作。如果您的實例版本低于V2.2，則需手動執行Rebalance操作。

  • Hologres V3.0版本起，計算組擴容期間，計算組的查詢和寫入不會中斷。

操作步驟

1. 擴容計算組資源，操作語法如下：

   CALL hg_alter_warehouse ('<warehouse_name>',<cu>);

   參數說明：

   參數	類型	說明
   warehouse_name	TEXT	需要調整的計算組名稱。
   cu	INTEGER	計算組的CU數。 最大值：512。 最小值：32。 步長：16。

2. 查詢計算組的狀態。

   由于調整計算組計算資源的過程是異步的，執行SQL后，并不代表計算組計算資源調整完成，需要您使用hg_get_warehouse_status函數查詢計算組的狀態。

   select hg_get_warehouse_status('<warehouse_name>');

   返回結果為Running，即計算組在Running狀態下，繼續下面步驟。

3. Shard重分布。

   使用如下命令讓Shard重新分布到增加擴容的計算組上。

   SELECT hg_rebalance_warehouse ('<warehouse_name>');

4. 查詢計算組的狀態。

   由于rebalance的過程是異步的，執行SQL后，并不代表rebalance調整完成，需要您使用如下命令查詢計算組的狀態。

   • hg_get_rebalance_warehouse_status函數返回當前計算組的狀態：

     SELECT hg_get_rebalance_warehouse_status ('<warehouse_name>');

     返回t即表示成功。

   • hg_wait_until_rebalance_warehouse_done函數可以直到指定計算組處于Running狀態時，再返回結果：

     select hg_wait_until_rebalance_warehouse_done('<warehouse_name>',<timeout_seconds>);

     其中timeout_seconds：非必填。代表返回超時時間，單位為秒，類型為INTEGER。

     返回DONE即表示成功。

使用示例

推薦使用如下SQL為read_warehouse_1計算組擴容至64CU：

-- 增加計算組的資源
CALL hg_alter_warehouse ('read_warehouse_1',64);

-- 等待計算組擴容完畢
SELECT wait_until_warehouse_running ('read_warehouse_1');

-- rebalance
SELECT hg_rebalance_warehouse ('read_warehouse_1');

-- 等待rebalance完畢
SELECT hg_wait_until_rebalance_warehouse_done ('read_warehouse_1');

權限說明

• 僅支持使用阿里云賬號或者RAM用戶縮容計算組，不支持STS賬號。

• 縮容計算組計算資源需要具備以下權限：

  • RAM角色權限：AliyunHologresWarehouseFullAccess或AliyunHologresFullAccess權限

  • 實例內部的Superuser權限。

使用說明

• 縮容時Hologres系統會先做Shard的Rebalance，將準備下線的Pod上的Shard遷移到其他Pod上。Rebalance中查詢和寫入會中斷15秒。Rebalance完成后，直接下線多余的Pods。

• 縮容后，計算資源會歸屬到實例未分配資源中，您可以繼續使用該資源新建計算組或擴容其他計算組，也可以縮容實例以釋放該資源。

操作步驟

1. 縮容計算組資源，操作語法如下：

   CALL hg_alter_warehouse ('<warehouse_name>',<cu>);

   參數說明：

   參數	類型	說明
   warehouse_name	TEXT	需要調整的計算組名稱。
   cu	INTEGER	計算組的CU數。 最大值：512。 最小值：32。 步長：16。

2. 查詢計算組的狀態。

   由于調整計算組計算資源的過程是異步的，執行SQL后，并不代表計算組計算資源調整完成，需要您使用hg_get_warehouse_status函數查詢計算組的狀態。

   select hg_get_warehouse_status('<warehouse_name>');

   返回結果為running，即計算組狀態為running狀態。

計算組均衡分片（Rebalance）

Hologres實例在運行時，每個計算組的Worker節點會均勻地加載數據分片（Shard）的元數據。但是在某些場景下（例如觸發了快速恢復、擴容等），數據分片在Worker節點上分布不均，此時就需要觸發均衡分片操作，使系統主動的重新分配數據分片，最終讓計算組的Worker節點均勻加載Shard的元數據。

• 權限說明

  觸發均衡分片操作需要具備實例的Superuser權限。

• 注意事項

  • Hologres從 V2.1版本開始，如果計算組內發現有空的Worker節點（未加載任何Shard），計算組會自動觸發Rebalance。

  • Hologres從 V2.2版本開始，系統支持對計算組Rebalance期間執行的查詢（SELECT）自動重試，使得查詢能在適當延長執行時間后順利完成，不會出現如ERROR: fail to execute query internal error: Get rundown is not allowed in recovering state.異常報錯。

• 命令格式

  SELECT hg_rebalance_warehouse ('<warehouse_name>');

• 參數說明

  參數	類型	說明
  warehouse_name	TEXT	需要觸發均衡分片的計算組名稱。

• 返回結果

  觸發均衡分片操作后，有如下返回結果：

  • true：表示Rebalance觸發成功，系統開始進行Rebalance操作。

  • false：表示無需Rebalance。

  • 報錯：表示Rebalance觸發失敗。例如存在Pod故障時，觸發Rebalance操作會報錯。

  說明

  • 執行Rebalance過程中，系統會計算是否需要Rebalance，最終達到均衡狀態，即每個Worker加載的Shard數量差異小于等于1。例如：

    • 如果有2個Worker，2個Shard，那么最終每個Worker都會分到1個Shard。

    • 如果有2個Worker，3個Shard，那么最終其中1個Worker會分到1個Shard，另一個Worker會分到2個Shard。

  • Rebalance操作通常需要2~3分鐘，執行時長和計算組中Table Group的數量有關，Table Group越多，Rebalance耗時越長。Rebalance過程中您的寫入大約會中斷15秒。

  • 由于Rebalance是異步執行，您可以使用如下SQL查看執行進度：

    SELECT hg_get_rebalance_warehouse_status('<warehouse_name>');

    返回結果為DOING表示正在執行Rebalance操作；返回結果為DONE表示Rebalance操作已完成。

設置計算組的超時時長

您可以通過設置statement_timeout參數，實現Session級別或數據庫級別的超時時長設置，詳情請參見GUC參數。

針對計算組，可以執行如下命令，為計算組設置超時時長。該配置優先級低于上述Session級別和數據庫級別配置，因此需要先取消數據庫級別的配置。

-- 取消數據庫級別設置
ALTER DATABASE <db_name> RESET statement_timeout;

-- 設置計算組的超時時長為600s
CALL hg_alter_warehouse ('<warehouse_name>', <cu>, '{"configs":{"gucs":{"statement_timeout":"600000"}}}');