2017-11-05 12 views
0

私は、データストリーミングのためにapache flink(1.3.1)で作業しています.Windows Server 2012 R2でセットアップする必要があります。Flink HAセットアップに問題があります。どんな助けでも大歓迎です。ありがとう。Flink Windows HA

ここでは、5つのサーバー、2つのジョブマネージャーHA、2つのタスクマネージャーHA、および最後の1つ(リソースサーバー)ですべての回復、セーブポイントまたはチェックポイントファイルを保存します。

  1. リソースサーバーを「Y」ネットワークドライブとしてマップしました。他のすべてでは サーバーです。 FLINK-conf.yaml 高availability.storageDirで
  2. :ファイル:/// cygdriveの/ Y/FLINK-回復
  3. それはパスとCygwinの端末からリソースサーバーにアクセスすることができます「cygdriveの/ Y/FLINK回復」

問題:私はCygwinの下start-cluster.shコマンドを実行すると、FLINK HAは、フォルダを作成します ':代わりに、すべてのFLINKサーバで/ cygdriveの/ Y/FLINK回復C' をリソースサーバーにリカバリファイルを作成する方法について説明します。

ストレージディレクトリ設定の代わりに 'hdfs://'プロトコルを使用していますが、 'file://'プロトコルをFlink HAで使用できますか?

+0

チェックポイントディレクトリへのパスは、クラスタ内のすべてのマシンからアクセス可能である必要があります。そこにマウントされた分散ファイルシステムを使用している場合は、file:// URIになります。 –

答えて

0

"bin/statrt-cluster.sh"を使用してCygwinでクラスタを起動すると、常にローカルファイルが作成されることがわかりました。 "bin/jobmanager.sh start cluster IP"を使用し、他のノードが "bin/taskmanager.sh start"を使用すると、ネットワークドライブにアクセスできます。

"bin/start-cluster.sh"コマンドが管理者として実行されると思います。 私は管理者として実行しようとしましたが、ネットワークドライブを一覧表示できませんでしたが、ユーザーとして実行するとCygwinのネットワークドライブを一覧表示できます。

ありがとう

関連する問題