Hologres：計算群組管理

許可權說明

• 僅支援使用阿里雲帳號或者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"}}}');