私はネットワーク上にApacheのflinkクラスタをインストールしました。私は以下のように設定を行った。このMaster(JobManager)が起動し、sshを介してすべてのスレーブにstartコマンドを送信します。タスクマネージャは、マスターノードによって起動された後に実行されていることがわかります。Flink Jobmanagerがタスクマネージャーを見ることができません
すべてのノード上の設定ファイル:
jobmanager.rpc.address: flmaster
jobmanager.rpc.port: 6123
jobmanager.heap.mb: 1024
taskmanager.heap.mb: 2048
taskmanager.numberOfTaskSlots: 1
taskmanager.memory.preallocate: false
parallelism.default: 1
jobmanager.web.port: 8081
taskmanager.tmp.dirs: /apps/storage/runtime/flink/workspace
recovery.mode: zookeeper
recovery.zookeeper.quorum:zk1:2181, zk2:2181, zk3:2181
recovery.zookeeper.storageDir: /apps/runtime/flink/recovery
env.java.home: /apps/java/
それから私は、スレーブノードのリストとのconfigフォルダにある奴隷と呼ばれるファイルを持っています。
flSlave1
flSlave2
flSlave3
私はその後
../bin/start-cluster.sh
これは、すべてのスレーブノードへのSSHセッションを開き、タスクマネージャを起動し、それを起動します。私はps axでこれを見ることができます| grep java
flMasterでWeb-Uiを開くことができます:8081 WebUIでは、スレーブノードの数が0であることがわかります。タスクマネージャはありません。 テストとして、私はwordcount.jarジョブを開始しました。スロットが開いていないので、ジョブを実行できないことがわかります。
/apps/flink/bin/flink run /apps/flink/examples/batch/WordCount.jar
応答:
07/20/2016 13:19:01 Job execution switched to status FAILING.
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Not enough free slots available to run the job.*
さて私はタスクマネージャ/スレーブノードが存在しない場合は、スロットがないであろうと思います。
これまでに見たことがある人はいますか?