このトピックでは、2026 年 7 月 29 日に Realtime Compute for Apache Flink でリリースされた主要な機能変更とバグ修正について説明します。
このリリースは、ネットワーク全体で段階的にロールアウトされています。アップグレードの進行状況については、Realtime Compute コンソールの右ペインで最新のお知らせをご確認ください。説明されている機能がまだご利用いただけない場合は、グレースケールアップグレードがお客様のアカウントにまだ適用されていません。アップグレードを早めるには、ビジネス要件を記載してチケットを送信してください。ご要望に応じてスケジュールを調整いたします。
概要
このリリースは、エンタープライズグレードのセキュリティの充実、AI 機能のサードパーティへの公開、および運用エクスペリエンスの向上という 3 つの領域に焦点を当てています。プラットフォーム側では、Connector の認証情報不要アクセスと高可用性災害復旧訓練が追加され、セキュリティとコンプライアンスのベースラインが向上しました。OpenAPI 側では、AI Assistant、Autopilot ポリシー管理、およびデータクエリのエンドポイントが公開され、大規模なお客様が Flink の AI およびデータ機能を独自のプラットフォームに統合できるようになりました。エクスペリエンス面では、ジョブ運用リストに多次元フィルターと再起動回数列が追加され、ヘルススコア診断に再起動回数ルールが追加されたことで、運用が事後対応から事前予防へとシフトしました。
プラットフォーム機能
高可用性災害復旧訓練
高可用性ネームスペースで、AZ レベルの災害復旧訓練を開始できるようになりました。システムは自動的にジョブノードを退避して再起動し、ジョブステータスを復元し、移行をリアルタイムで監視します。訓練が完了すると、RTO やジョブ回復率などのコア指標を含むレポートが生成されます。高可用性をご利用のお客様は、オペレーターの介入なしに訓練を実行して、MLPS や ISO などのコンプライアンス監査に対応できるようになりました。これにより、プロセスが手動操作からコンソール上でのワンクリック、視覚化、監査可能なワークフローへと変わります。
認証情報不要の Connector アクセス (パブリックプレビュー)
RAM ロールの参照、KMS 認証情報管理との統合、および洗練された変数管理エントリのサポートが追加されました。OSS Connector は RAM ロールを介したデータソースへのアクセスをサポートし、PostgreSQL-CDC Connector は RAM ロールを介した KMS 認証情報へのアクセスをサポートします。ジョブ構成で AccessKey/SecretKey やデータベースパスワードを保持する必要がなくなりましたが、既存の明示的なキー構成は引き続きサポートされます。機密認証情報がジョブコードから分離され、平文キーのリスクが排除され、セキュリティ監査の負担が軽減され、キーローテーションでジョブごとの変更が不要になります。
エクスペリエンスの改善
ジョブ運用の強化
ジョブ運用リストで、エンジンバージョンとジョブタイプ (SQL / JAR / Python / YAML) によるフィルタリングがサポートされ、再起動回数列が表示されるようになりました。これらの変更により、ジョブ数が増加した際のフィルタリング機能の不足、内部再起動異常の不可視性、および時間による一括異常の特定の困難さといった課題に対処し、運用を事後対応から事前予防へとシフトします。
ヘルススコア診断の強化
再起動回数のヘルススコアルールが追加されました。累積再起動回数が 0 より大きい場合は Medium、100 より大きい場合は High、300 より大きい場合も High と評価されます。これにより、継続的な指標のスコアリングにおけるギャップが埋められ、「数百回再起動してもスコアが 100」という盲点が解消され、リスクが可視化され、スコアの一貫性が保たれるようになります。
OpenAPI
AI Assistant OpenAPI
AI Assistant のライフサイクル全体のインターフェイスが、非同期ファーストの設計で公開されました。セッションの送信、ステータスのクエリ、および結果の取得を非同期モードでサポートし、エンドユーザーとのリアルタイム会話用の SSE ストリーミングインターフェイスも提供します。新しいオペレーションが 1 つ追加されました。
-
会話の開始 (
ChatAiAgent)
Autopilot OpenAPI
Autopilot ポリシー管理とチューニング履歴クエリのインターフェイスが公開され、お客様が独自のプラットフォームからチューニングポリシーを一括で構成し、結果を追跡できるようになりました。これにより、自動化ループの最後のギャップが埋められ、コンソールに切り替えて手動操作を行う必要がなくなります。新しいオペレーションが 3 つ追加されました。
-
Autopilot ポリシーのクエリ (
GetAutopilotPolicy) -
Autopilot ポリシーの更新 (
UpdateAutopilotPolicy) -
Autopilot チューニング履歴のリスト表示 (
ListAutopilotTuningHistories)
データクエリ OpenAPI
SQL データクエリスクリプトのライフサイクル管理インターフェイス全体が公開され、外部システムが API を介して SQL クエリを実行し、結果を取得し、スクリプトファイルを管理できるようになりました。新しいオペレーションが 6 つ追加されました。既存の StartSqlExecution オペレーションと組み合わせることで、SQL データクエリ API の完全なクローズドループが形成され、コンソールにログインすることなく、独自のプラットフォームから直接 Flink データをクエリできるようになります。
-
クエリ実行の停止 (
StopSqlExecution) -
クエリ実行結果の取得 (
FetchSqlExecutionResult) -
クエリスクリプトの作成 (
CreateSqlFile) -
クエリスクリプトの取得 (
GetSqlFile) -
クエリスクリプトの更新 (
UpdateSqlFile) -
クエリスクリプトの削除 (
DeleteSqlFile)