Realtime Compute for Apache Flink：空間管理與操作

• 工作空間與專案空間管理

  • 工作空間名稱能否修改？

  • VPC和虛擬交換器能否更換？

  • 如何查看工作空間ID等資訊？

  • 專案空間縮容時顯示資源分派失敗

  • Flink計算資源升配後沒生效

  • 如何查看AccessKey ID和AccessKey Secret資訊？

  • 如何在OSS上傳檔案讓Flink作業使用？

  • Realtime Compute控制台未顯示已開通的Flink工作空間？

  • 報錯：Has not enough ip address: abnormal event detected from kubernetes

  • 報錯：Unknown Error: Http failure response for xxxxx

• 作業管理

  • 如何查看當前作業的Flink版本？

  • 如何修改Realtime ComputeFlink版的引擎版本？

  • 如何配置自訂的作業運行參數？

  • 如何持久化Flink常用配置，提升配置效率？

  • 如何避免AK或帳號密碼等資訊泄露？

  • 如何讓Flink作業更合理地利用計算資源？

工作空間名稱能否修改？

目前暫不支援修改工作空間名稱。

VPC和虛擬交換器能否更換？

目前暫不支援更換VPC，但支援修改虛擬交換器。

如何查看工作空間ID等資訊？

在Realtime Compute管理主控台，單擊目標工作空間操作列下的更多 > 工作空間詳情，查看工作空間ID等資訊。

專案空間縮容時顯示資源分派失敗

• 問題詳情

  專案空間縮容時顯示資源分派失敗。

  

• 問題原因

  當前所有資源已被分配或使用。

• 解決方案

  需要先降低資源隊列已指派資源，詳情參見修改資源量，然後再縮容專案空間。

  

Flink計算資源升配後沒生效

• 訂用帳戶

  Flink擴容需要自上而下，工作空間的資源分派給多重專案空間，專案空間資源分派給資源隊列。詳情請參見資源調整。

• 隨用隨付

  隨用隨付是後付費的計費模式，系統會根據您工作空間實際的資源使用量進行結算，不存在資源變更配置。您可以單擊目標工作空間操作列下的更多 > 配額上限，然後在專案空間下配置資源隊列，以更好地滿足有資源隔離和管理需求的批作業情境，詳情請參見管理資源隊列。

如何查看AccessKey ID和AccessKey Secret資訊？

• AccessKey ID

  • 主帳號：使用阿里雲帳號（主帳號）登入阿里雲控制台後，將滑鼠懸浮在右上方的帳號表徵圖上，單擊AccessKey管理進行查看。

  • RAM使用者：查看RAM使用者的AccessKey資訊。

• AccessKey Secret

  為降低AccessKey泄露的風險，阿里雲帳號（主帳號）和RAM使用者的AccessKey Secret只在建立時顯示，後續不支援查看，您需要在建立時妥善保管。

如果您沒有或忘記AccessKey資訊，具體操作請參見建立AccessKey。

如何在OSS上傳檔案讓Flink作業使用？

如果您在開通Flink工作空間時選擇OSS Bucket儲存類型，您可以通過在與工作空間綁定的OSS Bucket上傳檔案，並在Flink作業中使用。您也可以直接在Realtime Compute開發控制台檔案管理頁面上傳檔案供Flink使用，詳情請參見檔案管理。

1. 在Realtime Compute管理主控台，單擊目標工作空間操作列的更多 > 工作空間詳情，查看當前工作空間綁定的OSS Bucket資訊。

   

2. 將資源檔上傳至目標OSS Bucket。

   • 登入OSS管理主控台，上傳資源檔至目標Bucket的/artifacts/namespaces目錄下。

     

   • 通過API上傳資源檔，詳情請參見PutObject。

3. 在Realtime Compute開發控制台左側導覽列，單擊檔案管理，可以查看到通過OSS控制台上傳的資源檔。

   

Realtime Compute控制台未顯示已開通的Flink工作空間？

您可以從以下幾個方面排查問題，若仍無法解決，可以提交工單反饋。

• 確認Flink工作空間是否已完成初始化（通常需要5~10分鐘）。

• 請確保Realtime Compute控制台頁面頂部選擇了正確的地區，工作空間僅會在您開通時所選的地區中顯示。

  

• 如果您是以RAM使用者身份登入，請確保該使用者具有Realtime Compute管理主控台的相關許可權。具體許可權配置請參見許可權管理。

報錯：Has not enough ip address: abnormal event detected from kubernetes

• 報錯詳情

  Has not enough ip address:abnormal event detected from kubernetes (type:[Warning], reason:[CniError_CodeUnKnownErr], message:[CniAllocateError: allocateIP failed: ipamCreate failed: failed to create ENI: all vSwitches ([*****]) cannot be used: CreateNetworkInterface: RequestId: 67959AE5-EA20-5CB4-8560-5BD6752472FD, ErrorCode: InvalidVSwitchId.IpNotEnough, Message: The specified VSwitch "*****" has not enough IpAddress., elapsedTime: 245.03232ms])

• 報錯原因

  虛擬交換器沒有可用IP。

• 解決方案

  建立可用IP，詳情請參見修改虛擬交換器。

報錯：Unknown Error: Http failure response for xxxxx

• 報錯詳情

  上傳檔案失敗，且提示如下報錯資訊。

  

• 報錯原因

  在阿里雲控制台國際站網域名稱改造後，使用alibabacloud.com新網域名稱進行檔案上傳時，如果未提前在Object Storage Service上配置跨域規則（CORS），請求將會因跨域限制而失敗。

• 解決方案

  在OSS控制台上，對Flink工作空間綁定的OSS Bucket設定跨域規則，具體的設定方法請參見檔案管理。

如何查看當前作業的Flink版本？

您可以通過以下方式查看：

• 在ETL或資料攝入頁面右側，單擊更多配置，在引擎版本項中查看版本資訊。

  

• 在營運中心 > 作業營運頁面，單擊目標作業名稱，在部署詳情頁簽基礎配置地區，查看版本資訊。

  

如何修改Realtime ComputeFlink版的引擎版本？

• SQL或YAML作業

  在ETL或資料攝入頁面右側，單擊更多配置，在引擎版本項中選擇目標版本。如果為已部署作業，您需要重新部署並啟動作業，以使線上作業更換版本。

• JAR或Python作業

  在作業營運頁面單擊目標作業名稱，在部署詳情頁簽，單擊基本配置地區右上方的編輯，在引擎版本項中選擇目標版本，單擊儲存後單擊啟動。

如何配置自訂的作業運行參數？

1. 登入Realtime Compute管理主控台。

2. 單擊目標工作空間操作列下的控制台。

3. 在作業營運頁面，單擊目標作業名稱。

4. 在部署詳情頁簽，單擊運行參數配置地區右側編輯。

5. 在其他配置項中，配置代碼資訊。

   請確保索引值對之間冒號後存在一個空格。程式碼範例如下。

   task.cancellation.timeout: 180s

6. 單擊儲存。

如何持久化Flink常用配置，提升配置效率？

Realtime ComputeFlink版提供工作範本功能，您可以將常用的參數設定為預設的，這樣再次建立新的作業就無需手動設定了。

如何避免AK或帳號密碼等資訊泄露？

使用變數可以避免明文AccessKey、密碼等資訊帶來的安全風險，通過複用可以避免重複編寫相同的代碼或值，易於組態管理。支援在SQL作業、JAR或Python作業、日誌配置和UI介面等情境中使用。詳情請參見變數管理。

如何讓Flink作業更合理地利用計算資源？

您可以通過以下方式進行調整：

• 手動調整：在智能診斷頁簽，單擊開始診斷，查看資源分析結論，並根據提示手動進行調整。

  

• 自動調整：開啟自動調優（包含智能調優和定時調優兩種模式）功能讓Flink系統自動完成資源調節，具體的適用情境和配置操作，詳情請參見配置自動調優。