Hologres：計算群組管理

注意事項

• 僅支援使用阿里雲帳號或者RAM使用者建立計算群組，需要具備執行個體的Superuser許可權。

• 由於建立計算群組的過程是非同步，執行建立計算群組SQL後，並不代表計算群組建立完成，需要您使用hg_get_warehouse_status函數查詢計算群組的狀態。

操作方式

注意事項

• 僅支援使用阿里雲帳號或者RAM使用者刪除計算群組，需要具備執行個體的Superuser許可權。

• 執行個體的預設計算群組不支援刪除。

• Table Group的主計算群組不支援使用SQL命令刪除。

• 由於刪除計算群組的過程是非同步，執行SQL後，並不代表計算群組刪除完成，需要您使用hg_get_warehouse_status函數查詢計算群組的狀態。

操作方式

許可權說明

• V3.0.28版本前，僅支援使用阿里雲帳號或者RAM使用者執行計算群組變更配置操作。V3.0.28版本起，支援RamRole（即STS帳號）執行計算群組變更配置操作。

• 執行計算群組變更配置操作需要具備以下許可權：

  • RAM角色許可權：AliyunHologresWarehouseFullAccess或AliyunHologresFullAccess許可權。

  • 執行個體內部的Superuser許可權。

計算群組彈性變更配置原理請參見資源彈性概述。

計算群組縱向擴容（Scale up）

-- 增加計算群組的資源
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');

計算群組縱向縮容（Scale down）

計算群組橫向增加Cluster（Scale out）

計算群組橫向減少Cluster（Scale in）

查看計算群組

• 命令格式

  • 系統資料表hologres.hg_warehouses存放了當前執行個體所有計算群組的資訊，您可以使用如下SQL查看當前執行個體下所有的計算群組的資訊。

    SELECT * FROM hologres.hg_warehouses;

  • 使用如下SQL查看當前使用的計算群組，系統將會返回當前使用的計算群組名稱。

    SELECT current_warehouse();

• 參數說明

  系統資料表hologres.hg_warehouses中包含的欄位資訊如下：

  欄位	欄位類型	說明	樣本值
  warehouse_id	INTEGER	計算群組ID，是計算群組的唯一ID。	1
  warehouse_name	TEXT	計算群組名稱。	init_warehouse
  cpu	INTEGER	計算群組的CPU（單位Core）。	32
  mem	INTEGER	計算群組的記憶體（單位GB）。	128
  cluster_min_count	INTEGER	計算群組的最小分區數量。	1
  cluster_max_count	INTEGER	計算群組的最大分區數量。	1
  target_status	INTEGER	計算群組的目標狀態，由於變更計算群組狀態是非同步，例如執行建立計算群組的SQL，系統會立即返回SQL執行結果，但返回SQL結果時，並非計算群組已經建立成功，系統會在後台非同步建立計算群組，這裡的狀態記錄了計算群組最終需要達到的狀態，有如下狀態： 1：運行中。 2：手動停機。	1
  status	INTEGER	計算群組目前狀態，有如下狀態： 0：初始化。 1：運行中。 2：手動停機。 3：處理失敗，如果狀態為處理失敗，status_detail欄位會顯示具體的原因。 4：處理中。	1
  status_detail	TEXT	計算群組狀態詳情。	無
  is_default	BOOLEAN	是否是預設計算群組，有如下取值： t：是預設計算群組。 f：不是預設計算群組。	t
  config	TEXT	計算群組配置。	無
  comment	TEXT	計算群組備忘。	無

停止計算群組

恢複計算群組

重啟計算群組

擷取計算群組狀態

• 命令格式

  • 使用如下SQL擷取計算群組的目前狀態：

    select hg_get_warehouse_status('<warehouse_name>');

  • 由於Warehouse 的建立、擴縮容等都是非同步執行的，有時候需要變更計算群組狀態後再進行一些操作。此時可以使用wait_until_warehouse_running函數，該函數可以直到指定計算群組處於Running狀態時，再返回結果，命令如下：

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

• 參數說明

  參數	類型	說明
  warehouse_name	TEXT	需要擷取狀態的計算群組名稱。
  timeout_seconds	INTEGER	返回逾時時間，單位秒。非必填。

• 使用樣本

  使用如下SQL實現每次從表org_data向表res_data匯入資料時，先擴容計算群組，再匯入資料，然後縮容計算群組：

  -- warehouse_1擴容至64CU
  CALL hg_alter_warehouse ('warehouse_1',64);
  
  -- 等待warehouse_1擴容完成
  SELECT wait_until_warehouse_running('warehouse_1');
  
  -- 寫入資料
  INSERT INTO res_data SELECT * FROM org_data；
  
  -- warehouse_1縮回32CU
  CALL hg_alter_warehouse ('warehouse_1',32);

修改計算群組名稱

操作方式

計算群組均衡分區（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"}}}');