2016-07-21 5 views
1

私はネットワーク上に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.* 

さて私はタスクマネージャ/スレーブノードが存在しない場合は、スロットがないであろうと思います。

これまでに見たことがある人はいますか?

答えて

0

ジョブマネージャーマシンのrpcポートでtelnetを実行してみてください。タスクマネージャーは、rpcを通じてジョブマネージャーと話します。したがって、ジョブマネージャとタスクマネージャのrpcポートにアクセスできるかどうかをネットワーク設定で確認してください。

また、blobサーバーのポートも確認してください。 taskmanager blobサーバーに接続できるかどうかをtaskmanagerログで確認します。

関連する問題