執行 Managed Service for Apache Flink 應用程式 - Managed Service for Apache Flink
識別應用程式和任務狀態執行批次工作負載

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

執行 Managed Service for Apache Flink 應用程式

本主題包含執行 Managed Service for Apache Flink 的相關資訊。

執行 Managed Service for Apache Flink 應用程式時，該服務會建立 Apache Flink 作業。Apache Flink 作業是指 Managed Service for Apache Flink 應用程式的執行生命週期。作業的執行及其使用的資源由作業管理員管理。作業管理員會將應用程式的執行分隔為任務。每個任務由任務管理員管理。監視應用程式的效能時，您可以檢查每個任務管理員的效能或作業管理員的整體效能。

如需有關 Apache Flink 任務的資訊，請參閱 Apache Flink 文件中的任務和排程。

識別應用程式和任務狀態

應用程式及其作業都具有目前的執行狀態：

  • 應用程式狀態：您的應用程式目前的狀態，描述其執行期。應用程式狀態包括下列幾種：

    • 穩定的應用程式狀態：您的應用程式通常會保持下列狀態，直到您變更狀態為止：

      • READY：在您執行之前，新的或已停止的應用程式處於 READY 狀態。

      • RUNNING：已成功啟動的應用程式處於 RUNNING 狀態。

    • 暫時性應用程式狀態：處於這些狀態的應用程式通常處於轉換至其他狀態的過程中。如果應用程式長時間保持短暫狀態，您可以使用 Force 參數設定為 StopApplication的動作來停止應用程式true。這些狀態包括下列項目：

      • STARTING: StartApplication動作後發生。應用程式正在從狀態 READY 轉換為 RUNNING 狀態。

      • STOPPING: StopApplication動作後發生。應用程式正在從狀態 RUNNING 轉換為 READY 狀態。

      • DELETING: DeleteApplication動作後發生。正在刪除應用程式。

      • UPDATING: UpdateApplication動作後發生。應用程式正在更新，並會轉換回 RUNNING 或 READY 狀態。

      • AUTOSCALING: 應用程式具有 ParallelismConfiguration設定為 的 AutoScalingEnabled 屬性true，且服務正在增加應用程式的平行處理。當應用程式處於此狀態時，您可以使用的唯一有效API動作是 Force 參數設定為 StopApplication的動作true。如需自動擴展的相關資訊，請參閱在 Managed Service for Apache Flink 中使用自動擴展。

      • FORCE_STOPPING: 在Force將 參數設定為 並呼叫StopApplication動作後發生true。正在停止應用程式。應用程式正在從 STARTING、UPDATING、STOPPING 或 AUTOSCALING 狀態轉換為 READY 狀態。

      • ROLLING_BACK: 在呼叫RollbackApplication動作後發生。應用程式正在復原至先前的版本。應用程式正在從 UPDATING 或 AUTOSCALING 狀態轉換為 RUNNING 狀態。

      • MAINTENANCE: 在 Managed Service for Apache Flink 將修補程式套用至您的應用程式時發生。如需詳細資訊，請參閱管理 Managed Service for Apache Flink 的維護任務。

    您可以使用主控台或使用 DescribeApplication動作來檢查應用程式的狀態。

  • 作業狀態：當應用程式處於 RUNNING 狀態時，作業的狀態會描述其目前的執行期。作業會以 CREATED 狀態開始，然後在啟動時繼續進行到 RUNNING 狀態。如果發生錯誤情況，應用程式會進入下列狀態：

    • 對於使用 Apache Flink 1.11 及更新版本的應用程式，會進入 RESTARTING 狀態。

    • 對於使用 Apache Flink 1.8 及更新版本的應用程式，會進入 FAILING 狀態。

    然後，應用程式會繼續進入 RESTARTING 或 FAILED 狀態，取決於作業是否可以重新啟動。

    您可以透過檢查應用程式 CloudWatch 日誌的狀態變更來檢查任務的狀態。

執行批次工作負載

Managed Service for Apache Flink 支援執行 Apache Flink 批次工作負載。在批次任務中，當 Apache Flink 任務進入 FINISHED 狀態時，Managed Service for Apache Flink 應用程式狀態會設定為 READY。如需 Flink 作業狀態的詳細資訊，請參閱作業與排程。