解決百度BMR的spark集群開啟slaves結點的問題

来源:http://www.cnblogs.com/kwongtai/archive/2017/08/13/7353964.html
-Advertisement-
Play Games

前言 最近一直忙於和小伙伴倒騰著關於人工智慧的比賽,一直都沒有時間停下來更新更新我的博客。不過在這一個過程中,遇到了一些問題,我還是記錄了下來,等到現在比較空閑了,於是一一整理出來寫成博客。希望對於大家有幫助,如果在此有不對的地方,請大家指正,謝謝! 比賽遇到spark開啟的問題 疑惑之處 在使用百 ...


前言

最近一直忙於和小伙伴倒騰著關於人工智慧的比賽,一直都沒有時間停下來更新更新我的博客。不過在這一個過程中,遇到了一些問題,我還是記錄了下來,等到現在比較空閑了,於是一一整理出來寫成博客。希望對於大家有幫助,如果在此有不對的地方,請大家指正,謝謝!


比賽遇到spark開啟的問題

疑惑之處

在使用百度BMR的時候,出現了這樣子一個比較困惑的地方。但百度那邊幫我們初始化了集群之後,我們預設以為開啟了spark集群了,於是就想也不想就開始跑我們的代碼。可認真你就錯了,發現它只是開啟了local(即Master結點),其他的slaves結點並沒有開啟。於是我們不得不每一次都進入到Master的/opt/bmr/spark/conf/中去修改slaves文件,去把它裡面最後的那個localhost刪除,添加上slaves結點的hostname或者是IP。

原來的localhost:

改變成如下:

麻煩之處

最是麻煩的地方是,這個slaves文件,每次使用spark集群的時候都要去修改,非常不方便。在此吐槽一下百度BMR的不智能的地方。於是想,有木有好的辦法可以讓我們省去這樣的麻煩呢?


使用腳本開啟百度BMR的spark集群

觀察Hadoop文件夾下的情況

在開啟集群的時候,百度提供我們選擇Hadoop的鏡像版本,而這個Hadoop是必選的。前幾篇博文里見到配置Hadoop的時候其實需要配置其他slaves的結點的。知道這個,就有點驚喜了,因為Hadoop下的slaves文件是長這樣子的

觀察spark文件夾下的情況

spark下的conf文件夾,一開始並沒有slaves,我們需要從它的slaves.template拷貝過來

cp /opt/bmr/spark/conf/slaves.template /opt/bmr/spark/conf/slaves

使用腳本,拷貝slaves的hostname到spark下的slaves

我們需要做的是,獲取Hadoop下slaves的slaves結點的hostname,進而拷貝到spark下的slaves文件的最後兩行,拷貝之前,需要把spark的slaves的最後一行localhost給刪除掉。那麼有哪個shell指令可以幫我解決這個難題了?經過詢問後臺的大佬,以及晚上查閱,發現了sed這個指令可以幫助我們解決這個問題。

sed的介紹

取自http://www.cnblogs.com/ggjucheng/archive/2013/01/13/2856901.html

[root@www ~]# sed [-nefr] [動作]
選項與參數:
-n :使用安靜(silent)模式。在一般 sed 的用法中,所有來自 STDIN 的數據一般都會被列出到終端上。但如果加上 -n 參數後,則只有經過sed 特殊處理的那一行(或者動作)才會被列出來。
-e :直接在命令列模式上進行 sed 的動作編輯;
-f :直接將 sed 的動作寫在一個文件內, -f filename 則可以運行 filename 內的 sed 動作;
-r :sed 的動作支持的是延伸型正規表示法的語法。(預設是基礎正規表示法語法)
-i :直接修改讀取的文件內容,而不是輸出到終端。

動作說明: [n1[,n2]]function
n1, n2 :不見得會存在,一般代表『選擇進行動作的行數』,舉例來說,如果我的動作是需要在 10 到 20 行之間進行的,則『 10,20[動作行為] 』

function:
a :新增, a 的後面可以接字串,而這些字串會在新的一行出現(目前的下一行)~
c :取代, c 的後面可以接字串,這些字串可以取代 n1,n2 之間的行!
d :刪除,因為是刪除啊,所以 d 後面通常不接任何咚咚;
i :插入, i 的後面可以接字串,而這些字串會在新的一行出現(目前的上一行);
p :列印,亦即將某個選擇的數據印出。通常 p 會與參數 sed -n 一起運行~
s :取代,可以直接進行取代的工作哩!通常這個 s 的動作可以搭配正規表示法!例如 1,20s/old/new/g 就是啦!

使用sed寫腳本

具體用到的有:

-i #因為信息我覺得不用輸出到終端上
d  #需要刪除localhost

這是刪除localhost的:

sed -i '/localhost/d' /opt/bmr/spark/conf/slaves

追加slaves的hostname到spark的slaves最後

for slaves_home in `cat /opt/bmr/hadoop/etc/hadoop/slaves`
do
echo $slaves_home >> /opt/bmr/spark/conf/slaves
done

最後spark下的slaves文件是這樣子的

完整的代碼如下

echo "Starting dfs!"
/opt/bmr/hadoop/sbin/start-dfs.sh
echo "*******************************************************************"

echo "Starting copy!"
cp /opt/bmr/spark/conf/slaves.template /opt/bmr/spark/conf/slaves
echo "Copy finished!"
echo "Writing!"
sed -i '/localhost/d' /opt/bmr/spark/conf/slaves
for slaves_home in `cat /opt/bmr/hadoop/etc/hadoop/slaves`
do
echo $slaves_home >> /opt/bmr/spark/conf/slaves
done
echo "*******************************************************************"

echo "Starting spark!"
/opt/bmr/spark/sbin/start-all.sh
echo "*******************************************************************"

echo "Watching the threads"
jps

查看到Master進程已經開啟了,就大功告成了!


結言

只要把上面的代碼保存到一個.shell文件下。給它加上可運行的許可權,然後就大功告成了。理論上,百度BMR的spark的路徑都是一致的,因而都能通用,希望能減輕大家每次配置的煩惱。

文章出自kwongtai'blog,轉載請標明出處!


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • HBase常用命令 進入shell 表結構 1\. 創建表 語法: 創建一個User表,並且有一個info列族 3\. 查看所有表 4\. 查看表詳情 5\. 表修改 刪除指定的列族 表數據 1\. 插入數據 語法: 2\. 根據rowKey查詢某個記錄 語法: 3\. 查詢所有記錄 語法: 掃描所 ...
  • 一、vivi虛擬攝像頭驅動 基於V4L2(video for linux 2)攝像頭驅動程式,我們減去不需要的ioctl_fops的函數,只增加ioctl函數增加的必要的攝像頭流查詢等函數; 二、虛擬攝像頭驅動應用程式調用過程流程圖: 虛擬攝像頭一般不用自己寫的程式,而是採用網路上提供的應用程式直接 ...
  • Microsoft Visual C++ 2005 Redistributable Package (x86):Microsoft Visual C++ 2005 可再發行組件包 (x86):https://www.microsoft.com/zh-CN/download/details.aspx? ...
  • Ubuntu16.04修改源 1.備份 2.修改 3.更新 ...
  • Nginx 出現 403 Forbidden 最終解決 步驟一: 檢查目錄許可權。許可權不足的就加個許可權吧。 例子:chmod -R 755 / var/www 步驟二: 打開nginx.conf 例子:vim /etc/nginx/nginx.conf 把 user 用戶名 改為 user root ...
  • 創建兩個 shell 腳本文件。 test1.sh 代碼如下: #!/bin/bash url="http://www.cnblogs.com/freescience" test2.sh 代碼如下: #!/bin/bash #使用 . 號來引用test1.sh 文件 . ./test1.sh # 或 ...
  • RHEL7.x(CentOS7.x)系統相對之前的6.x系統變化較大,雖然安裝時選擇了中文環境,但是進入系統後,在控制台及編輯器中仍無法切換輸入法進行中文輸入。 原來還要這麼配置,,才能愉快的使用“拼音”輸入法。 ...
  • 使用LD_LIBRARY_PATH變數 如:當運行scp時出現以下提示: scp: error while loading shared libraries: libz.so.1: cannot open shared object file: No such file or directory那麼 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...