flink1.10 Linux 闆嗙兢瀹夎

Posted 2020-12-16

鏍囩锛?a href='http://www.mamicode.com/so/1/%e9%9b%86%e7%be%a4' title='闆嗙兢'>闆嗙兢   闆嗙兢瀹夎   nbsp   bin   heap   dir   cal   rsync   for   

1.瀹樼綉涓嬭浇jar鍖咃細

https://www.apache.org/dyn/closer.lua/flink/flink-1.10.1/flink-1.10.1-bin-scala_2.11.tgz

2.涓婁紶jar鍖呭苟涓旇В鍘嬶細

 

3.杩涘叆/flink-1.10.1/conf/flink-conf.yaml

閰嶇疆淇敼浠ヤ笅鍙傛暟锛?/p>

銆€銆€1锛塲obmanager.rpc.address: 姝ゅ娣诲姞master鑺傜偣鐨刲ocalhost

      鍏朵綑鍙傛暟鏍规嵁鑷繁鏈哄櫒鑷閰嶇疆锛屾垜绮樿创涓€涓嬮粯璁ゅ€煎拰璇存槑

銆€銆€2锛塲obmanager.heap.size:1024m  --姣忎竴涓猨obmanage鍙敤鐨勫唴瀛?/p>

銆€銆€3)  taskmanager.memory.process.size: 1728m --姣忎竴涓猼askmanager鍙敤鐨勫唴瀛?/p>

銆€銆€4锛塼askmanager.numberOfTaskSlots:4 --姣忎釜鏈哄櫒鎵€鑳界敤鐨凜PUs

銆€銆€5锛塱o.tmp.dirs:/tmp --鐢ㄤ簬瀛樻斁杩愮畻杩囩▼涓殑涓存椂鐩綍

4.杩涘叆/flink-1.10.1/conf/slaves

銆€銆€1锛夋坊鍔犺嚜宸遍泦缇ょ殑slaves 渚嬪锛?/p>

銆€銆€銆€192.168.1.102

銆€銆€銆€192.168.1.103

         192.168.1.104

5.鍐欎竴涓垎鍙戣剼鏈皢flink鍒嗗彂鍒板悇涓妭鐐广€?/p>

======================================================================================

鑴氭湰锛?/p>

#!/bin/bash

if[ $# -lt 1 ] 

then

      echo Not Enough Arguement!

      exit;

fi

#2.閬嶅巻闆嗙兢鎵€鏈夋満鍣?/p>

for host in 姝ょ矖鍐欎綘鐨勮妭鐐逛緥濡傦紙hadoop102 Hadoop103 Hadoop104锛?/p>

do

銆€銆€echo ========================= 銆€$host    ================================

銆€銆€#3.閬嶅巻鎵€鏈夌洰褰曪紝鎸ㄤ釜鍙戦€?/p>

      for file in $@

      do

          #4 鍒ゆ柇鏂囦欢鏄惁瀛樺湪

銆€銆€    if [ -e $file ]

          then

                #5.鑾峰彇鐖剁洰褰?/p>

                pdir=$(cd -P ${dirname $file}; pwd)

                fname=${basename $file}

                ssh $host "mkdir -p $pdir"

                rsync -av $spdir/$fname $host:$pdir

           else

銆€銆€銆€銆€銆€echo $file does not exists!

          fi

     done

done

======================================================================================

6.鍦╩aster涓婇潰杈撳叆鍚姩鍛戒护寮€鍚泦缇わ細

銆€銆€bin/start-cluster.sh

7.璁块棶ui鐣岄潰锛歭ocalhost:8081

8.鍏抽棴闆嗙兢锛?/p>

銆€銆€stop-cluster.sh