すべてのプロダクト
Search

このプロダクト

    Realtime Compute for Apache Flink:ジョブの開始

    ドキュメントセンター

    Realtime Compute for Apache Flink:ジョブの開始

    最終更新日:Mar 10, 2026

    ジョブを開発およびデプロイメントした後、[ジョブ O&M] ページで開始できます。停止したジョブを回復する場合や、動的に適用されない更新済みのパラメーター設定を反映する場合にも、ジョブの開始が必要です。このトピックでは、ジョブの開始方法について説明します。

    前提条件

    ジョブがデプロイされました。詳細については、「ジョブをデプロイする」をご参照ください。

    制限事項

    ストリームジョブのみが開始オプションをサポートします。

    注意事項

    • Resource Access Management (RAM) ユーザー、RAM ロール、または他の Alibaba Cloud アカウントを使用してジョブを開始する場合は、そのアカウントが対象プロジェクトへのアクセス権限を持っていることを確認してください。詳細については、「開発コンソールでの権限付与」および「権限管理」をご参照ください。

    • 最新の状態または指定された状態からジョブを開始する場合、システムは状態の互換性チェックを実行します。状態に互換性の問題があるジョブは、開始に失敗するか、予期しない結果をもたらす可能性があります。詳細については、「Flink 状態互換性リファレンス」をご参照ください。

    操作手順

    1. ジョブ開始インターフェイスに移動します。

      1. オーナーロールを持つメンバーとして Flink 開発コンソールにログインします。

      2. ページ上部で、対象プロジェクトの名前を選択します。

        image.png

      3. オペレーションセンター > ジョブ O&M ページで、ドロップダウンリストから ストリームジョブ または バッチジョブ を選択します。

        image.png

    2. 対象ジョブの 操作 列で、開始 をクリックします。

    3. （任意）ストリームジョブの場合、開始オプションを設定します。

      • ステートレス開始

        新規ジョブの場合、または状態を再利用できない場合にこのオプションを選択します。必要に応じて自動チューニングを有効にすることもできます。

        ポリシー

        説明

        ソーステーブルの開始時刻を指定

        ソーステーブルの開始時刻を指定 を選択し、時刻を指定します。

        現在、ジョブ開始インターフェイスでソーステーブルの開始時刻を設定できるコネクタは、以下の 7 種類です：Kafka、Simple Log Service (SLS)、DataHub、ApsaraMQ for RocketMQ、Hologres、Paimon データレイクハウス for ストリーミング、MySQL。

        ジョブ開始インターフェイスで指定した読み取り時刻は、ジョブの Data Definition Language (DDL) コード内で設定された startTime よりも優先されます。

        説明

        • Kafka 0.11 より前のバージョンは、コネクタの Kafka クライアントとの互換性の問題によりサポートされていない可能性があります。Kafka のバージョンをアップグレードしてください。

        • すべてのコネクタが startTime パラメーターをサポートしているわけではありません。startTime が WITH パラメーターに含まれているかどうかを確認してください。例については、「Simple Log Service (SLS) WITH パラメーター」をご参照ください。

        • startTime は、ジョブをゼロから開始し、かつ startTime を指定した場合にのみ有効になります。システムチェックポイントまたはジョブスナップショットからジョブを開始する場合は、startTime は有効になりません。

        自動チューニングの設定

        このスイッチをオンにして、チューニングモードを選択します。

        • インテリジェントチューニング：リソース使用量が低い場合はシステムが自動的にリソース構成を削減し、使用量が特定のしきい値に達すると増加させます。詳細については、「インテリジェントチューニングの有効化と設定」をご参照ください。

        • スケジュールチューニング：ドロップダウンリストからスケジュールを選択します。スケジュールには、複数のリソースと時刻のマッピングを含めることができます。時間帯ごとの使用状況に基づいてリソースを設定できます。詳細については、「スケジュールチューニングプランの設定と適用」をご参照ください。

      • ステートフル開始

        特定の開始ポリシーを選択し、必要に応じて自動チューニングを有効にします。

        ポリシー

        説明

        最新の状態から回復

        スナップショットまたはシステムチェックポイントの最新の状態からジョブを回復します。最新の状態からジョブを開始する場合、Flink システムは SQL ジョブの変更（SQL コード、Flink ランタイムパラメーター設定、データベースエンジンバージョンなど）を検出します。

        変更が検出された場合は、状態互換性チェック の横にある チェック をクリックして互換性を確認します。互換性の結果に基づいて次のステップを決定してください。互換性結果の意味と推奨アクションの詳細については、「互換性」をご参照ください。

        指定された状態から回復

        特定のスナップショットを選択します。スナップショットの作成方法の詳細については、「ジョブ状態セットの管理」をご参照ください。

        別のジョブから回復

        このオプションを選択した後、対象ジョブとその対応するスナップショットを指定してジョブを回復します。スナップショットはジョブ間で共有できますが、ジョブの状態は互換性がある必要があります。詳細については、「ジョブ状態セットの管理」をご参照ください。

        非復元状態を許可

        説明

        JAR ジョブでのみサポートされています。

        デフォルトでは、Flink システムは提出中のジョブとスナップショット全体を一致させようと試みます。ジョブの変更により演算子の状態が変化した場合、タスクが回復不能になる可能性があります。このような場合、このスイッチをオンにできます。これにより、Flink システムは一致しない状態をスキップし、ジョブを開始できるようになります。詳細については、「Allow Non-Restored State」をご参照ください。

        自動チューニングの設定

        このスイッチをオンにして、チューニングモードを選択します。

        • インテリジェントチューニング：リソース使用量が低い場合はシステムが自動的にリソース構成を削減し、使用量が特定のしきい値に達すると増加させます。詳細については、「インテリジェントチューニングの有効化と設定」をご参照ください。

        • スケジュールチューニング：ドロップダウンリストからスケジュールを選択します。スケジュールには、複数のリソースと時刻のマッピングを含めることができます。時間帯ごとの使用状況に基づいてリソースを設定できます。詳細については、「スケジュールチューニングプランの設定と適用」をご参照ください。

    4. 開始 をクリックします。

      ジョブの実行状況は、オペレーションセンター > ジョブ O&M ページで確認できます。詳細については、「ジョブの実行状況の確認」をご参照ください。

    参考資料