解決flink的后續(xù)問題

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

# 接上周

- 問題 資源不夠

? - 嘗試上調(diào)minikube的資源

? - 需要minikube stop 意味著minikube的docker私有倉庫需要重新配

? - `minikube stop`

? - 在hyper-v中設(shè)置minikube虛擬機(jī) 設(shè)置cpu為4 內(nèi)存為12000M

? - `minikube start`

? - 檢查kubectl describe node

? - 資源已分配

? - 檢查pods情況 發(fā)現(xiàn)elastic search掛了

- 先恢復(fù)私有倉庫配置

? - 登錄minikube

? ? - `ssh docker@192.168.2.15`

? ? - 發(fā)現(xiàn)證書不匹配

? ? - 刪除現(xiàn)有ssh證書 windows用戶目錄 .ssh/known_host

? - 登錄后 添加私倉 hosts

? ? - sudo vi /etc/hosts

? ? - 192.168.2.15 k8s-master

? - 給minikube的docker客戶端授權(quán)私有倉庫的證書

? ? - sudo mkdir -p /etc/docker/certs.d/k8s-master:31320

? ? - sudo vi /etc/docker/certs.d/k8s-master:31320/ca.crt

? ? - 證書內(nèi)容和之前一樣(因?yàn)橹耙呀?jīng)把證書存入pvc了 minikube restart不會(huì)丟pvc)

- elastic search pod失敗

? - 刪除pod 讓k8s重新創(chuàng)建

? - 成功

? - kibana 也成功了

? - 感覺eck還是挺穩(wěn)的

- 測(cè)試springbootdemo

? - http://192.168.2.15:31000/

? - 搜索測(cè)試 成功

- 再試flink

? - 之前想減少worker數(shù)量 但沒找到相關(guān)參數(shù)

? ? - 也考慮過減少flink worker的內(nèi)存使用

? ? - 但是現(xiàn)在minikube的cpu和內(nèi)存都快用完了 還是擴(kuò)一下

- 問題 flink相關(guān)的pods都消失了

? - 運(yùn)行一段時(shí)間后消失的

? - kubectl get deployment

? - deployment也沒了

? - 重新布flink 看看日志

? - 日志報(bào)錯(cuò)

? ? ```

? ? io.debezium.DebeziumException: Misconfigured master - master server_id is 0 Error code: 1236; SQLSTATE: HY000.

? ? ```

? - 看來application模式下 如果拋異常 整個(gè)集群都沒了?

? - 有效的server_id是多少? 試下從1開始

? - $((${HOSTNAME##*-}+1))

? - 如果hostname 是 xxx-xxx-0 上述表達(dá)式取值是1

? - 解釋 `##*` 表示 刪除長前綴

? - https://devhints.io/bash

? - `##*-` 表示 基于最后一個(gè)-號(hào)刪除前綴 該-號(hào)也被刪除

? - $(()) 表示執(zhí)行數(shù)字運(yùn)算 里面 +1?

? - 重新apply -f 數(shù)據(jù)庫的描述文件

? - 檢查web端 http://192.168.2.15:31000/doc/_list

? - 正常

? - 重新部署blink

? - 這次問題解決了 job一直在運(yùn)行 沒有中斷了

- 確認(rèn)結(jié)果

? - 見下節(jié)

# 前端測(cè)試 新增 刪除

- 前端創(chuàng)建 create 和 delete 功能

? - java端的create功能是現(xiàn)成的

? - java端增加delete by id 功能

? - 前端調(diào)用create功能

? - 前端調(diào)用delete功能

- 測(cè)試

? - 采用create功能創(chuàng)建文檔

? - 搜索剛創(chuàng)建的文檔的關(guān)鍵詞

? ? - 結(jié)果 能搜到

? ? - 表示flink正確處理了 create的事件

? - 采用delete功能刪除某個(gè)文檔

? - 搜索本來能搜到原文檔的關(guān)鍵詞

? ? - 結(jié)果 搜不到了

? ? - 表示flink正確處理了 delete的事件