一般的なワークフローの問題

これがあなたの週のように聞こえますか?

これはエッジケースではありません。これは、複数のツールでHadoop HDFSパイプラインを実行しているチームの通常の運用条件です。Control-Mがそれぞれをどのように処理するかを見てみましょう。

ファイル到着

HDFSファイルは午前2時に到着しましたが、まだ不完全です。

Control-M HDFSファイルウォッチャーは、指定されたHDFSパスを監視し、ファイルが定義された最小サイズに達するまで待機します。ファイルが到着したがサイズ基準が満たされていない場合、ジョブは監視を続け、部分的なデータが次のパイプラインステージに入るのを防ぎます。

HDFSコマンド失敗

HDFSの取得に失敗しました。下流の処理はすでに開始される予定です。

Control-MはHDFSコマンドを管理されたジョブとして実行し、その完了状態をキャプチャします。依存関係により、失敗したコマンドの後に下流のジョブが進行することを防ぎ、HDFSのアクセスや転送の問題がワークフロー全体に波及するのを防ぎます。

クロスクラスターコピー

昨日のDistCp転送は長引きました。今日の分析ウィンドウは閉じつつあります。

Control-MはDistCpを同じ生産ワークフローの一部としてスケジュールし、依存する処理が始まる前にその完了を追跡し、ジョブ周辺にControl-MのスケジューリングおよびSLA制御を適用します。これにより、大規模なクラスタ間のコピーが長時間実行される際の手動調整が削減されます。

HIVE · HDFS

あなたのHiveジョブは完了しました。HDFSの配信ステップは開始されませんでした。

Control-MはHive処理とHDFS操作を一つの依存関係チェーン内でモデル化します。Hiveジョブが必要な完了状態に達すると、Control-Mは別のcronスケジュールや手動の引き渡しなしに、依存するHDFSステップを解放できます。

SLAリスク

HDFS処理が遅れています。ビジネスの締切は動いていません。

Control-MはHadoopジョブをそのエンタープライズスケジューリング環境に取り込み、周囲にSLAジョブを有効にします。チームは孤立したファイルシステムタスクをトラブルシューティングするのではなく、エンドツーエンドのワークフローの文脈でHDFSステージを管理できます。

統合の事実

Control-M + Hadoop HDFS

workload.types

HDFSコマンド · HDFSファイルウォッチャー · DistCp · Sparkの前後のHDFSコマンド · MapReduceの前後のHDFSコマンド

trigger.type

HDFSファイルの到着(最小ファイルサイズと最大待機時間の基準付き) · 時間スケジュール · 上流ジョブの完了。

cross_tool.deps

Hiveジョブ · Sparkジョブ · Sqoopジョブ · MapReduceジョブ · Oozieワークフロー · DistCp転送 · 下流の分析

cloud.platforms

オンプレミスのHadoop · Cloudera / Hortonworksディストリビューション · Linuxエッジノード · Kerberosで保護されたHadoop

error_handling

前コマンド失敗処理(FailJobOnCommandFailure) · 後コマンド失敗処理 · 依存関係ゲーティング · SLA監視 · リソース制御

throughput

分散HDFSストレージ · 大規模データセット · 並列DistCp転送 · Hadoopバッチ処理 · クラスター規模のワークロード

observability

Control-Mジョブモニタリング · ジョブ完了ステータス · エンドツーエンドの依存関係の可視性 · SLA追跡 · 中央集権的なスケジュールビュー

エンドツーエンドのオーケストレーション

1つの生産ワークフロー。スタック内のすべてのツール。

Control-Mは、Hadoop HDFS、Hive、Spark、Sqoop、Oozie、およびファイル転送を単一のジョブフローでオーケストレーションします - すべての依存関係追跡、SLAの可視性、自動復旧を備えています。

  • クロスツール依存関係: Sqoop → HDFS → Hive → Spark
  • データ対応トリガー: HDFSファイルの到着、最小ファイルサイズ、ジョブの完了、時間スケジュール

Hadoop HDFS

HDFSコマンド · ファイル到着の監視 · 最小サイズ基準 · 管理された依存関係

DistCp

分散コピー · ソースパス · ターゲットパス · DistCpオプション

Hive

Hiveスクリプト実行 · 依存関係の調整 · 前後のHDFS操作

Spark

分散コピー(インター/イントラクラスタ) · ソースパス · ターゲットパス · DistCpオプション。

Sqoop

データ移動ジョブ · ワークフロー依存関係 · スケジュールされた実行

Oozie

ワークフロー実行 · ワークフロー抽出 · アクションの可視性

MapReduce

MapReduceジョブ · ストリーミングジョブ · HDFS前後のコマンド

パイプラインを監視

完全なデータパイプラインでのHDFS実行を監視する

HDFSはファイルシステム内で何が起こっているかを示しますが、ビジネスワークフロー全体が進行しているかどうかは示しません。Control-MはHDFS操作をHadoop処理および依存するエンタープライズジョブと一つの運用ビューにまとめます:

  • HDFSジョブ実行ステータス

  • 上流および下流の依存関係

  • クロスツールワークフローの可視性

  • 集中型ジョブ監視

SLA保証

HDFS依存のパイプラインをビジネスの締切に合わせて維持する

成功したHDFS操作でも、それに依存するプロセスには遅すぎる場合があります。Control-MはHadoopワークロードの周りにエンタープライズスケジューリング、依存関係、リソース管理、SLA管理を適用し、チームがビジネスコンテキストでのデリバリーを管理できるようにします:

  • エンドツーエンドのSLA追跡

  • 高度なスケジューリング基準

  • 複雑な依存関係管理

  • リソースプールの調整

  • リソース制御のロック

複雑なワークフローに秩序をもたらす

Control-Mがチームにどのように複雑なプロセスをより良く可視化、調整、制御するかを学ぶ。