Flink 作為一套分布式執(zhí)行框架，計算資源可以不斷的擴展。不同的任務(wù)類型，可以控制需要的計算資源。在flink整個runtime的模型中并行度是一個很重要的概念，通過設(shè)置并...
發(fā)簡信
IP屬地：江蘇
-
flink 并行度
-
Apache Kafka 是什么
Kafka 是基于發(fā)布與訂閱的消息系統(tǒng)。Kafka 是一個分布式的，可分區(qū)的，冗余備份的持久性的日志服務(wù)。它主要用于處理活躍的流式數(shù)據(jù)。 Kafka 的主要特點 1、同時為發(fā)...
-
git rebase -i 合并多次提交在實際開發(fā)中，經(jīng)常會需要使用到git合并功能，git rebase可以將多個commit合并成為一個。這里主要介紹一下git rebase -i命令的使用： 一、使用git ...
-
從零開始理解IEC104協(xié)議之三——主要過程中的一些技術(shù)細節(jié)⑴、遙信 遙信數(shù)據(jù)格式一般為——當總召喚時，使用不帶時標的全遙信報文，而其它情況下一律只使用帶時標的遙信報文。 當主站收到SOE信息后應(yīng)能自動產(chǎn)生COS信息。 遙信報文常見問...
-
二進制的運算轉(zhuǎn)成二進制主要有以下幾種：正整數(shù)轉(zhuǎn)二進制，負整數(shù)轉(zhuǎn)二進制，小數(shù)轉(zhuǎn)二進制 在說明換算之前，先介紹一下次方和負次方的概念(面向新手): 一，值轉(zhuǎn)化為二進制 1，正整數(shù)轉(zhuǎn)二進制 在...
-
-
從零開始理解IEC104協(xié)議之一——104規(guī)約幀格式前言 本文根據(jù)相關(guān)標準、本司實際情況及個人調(diào)試經(jīng)驗編寫，主要目的是針對104協(xié)議進行掃盲，共分為五大塊。根據(jù)個人需求可選擇相應(yīng)段落進行閱讀。 這里做一個小推薦： 1、僅...
-
brew 升級
mac 12.2.1下執(zhí)行brew報 initialize': Version value must be a string; got a NilClass () (Typ...
-
項目中使用ECharts，echarts-liquidfill 水球圖安裝npm install echarts-liquidfillnpm install --save echarts-for-reactnpm install --save ...
-
基于Jmeter的壓力測試一 . 基于Jmeter的壓力測試 使用說明 1. jmeter簡介 Apache JMeter是Apache組織開發(fā)的基于Java的壓力測試工具。用于對軟件做壓力測試，它最...
-
Kerberos主從搭建
cdh集群需要開啟Kerberos認證，但是 KDC存在單點故障的問題，這就需要搭建主備，這方面的問題網(wǎng)上的文檔很多，但是照著坐下來基本都是失敗，大多說只是介紹了搭建的具體過...
-
行式存儲VS列式存儲引言 很多人剛開始學習數(shù)據(jù)庫的時候可能接觸到的都是關(guān)系型數(shù)據(jù)庫RDS，它是基于行式存儲的思想來進行數(shù)據(jù)存儲的；但是數(shù)據(jù)庫存儲領(lǐng)域還有一個不容小覷的力量，非關(guān)系型數(shù)據(jù)庫NoSQ...
-
Flink如何實現(xiàn)一個某種數(shù)據(jù)缺失半小時觸發(fā)報警的監(jiān)控問題定義：半小時監(jiān)控可以定義為整間隔時間（如9:00-9:30），也可以定義為某條數(shù)據(jù)之后的半小時 提示：若采用processingtime，我們可以在env中設(shè)置自動定時產(chǎn)...
-
umi中找不打connect
提交的issues中作者給出了答案，參考如下參考資料:解決方案[https://github.com/umijs/umi/issues/6006]官網(wǎng)解決方案[https:/...
-
NodeJS項目基礎(chǔ)結(jié)構(gòu)簡單介紹按照常規(guī)，去執(zhí)行npm start 或者在Terminal中手動輸入命令，結(jié)果如下： 可以看到是執(zhí)行了test/package.json文件中的start命令，初始packa...
-
npm安裝vue.js一、npm 版本查看及升級 注：若npm install 報錯 permission denied，使用sudo npm install -g npm 二、安裝vue相關(guān)工具...
-
Kafka基礎(chǔ)運維
在軟件項目的生命周期中，開發(fā)只占開始的一小部分，大部分時間我們要對項目進行運行維護，Kafka相關(guān)的項目也不例外。所以這里介紹了一些Kafka服務(wù)器基礎(chǔ)的運維方法。 關(guān)于Ka...
-
(填坑)（Hadoop）HADOOP_HOME and hadoop.home.dir are unset.一.問題描述：windows本地調(diào)試Hadoop程序時報錯錯誤信息： 其原因是需要在windows本地搭建Hadoop環(huán)境，下載winutils文件，并將hadoop-2.8...
-
flink on yarn之per-job方式部署超時的一種解決方法
網(wǎng)上很多寫的很亂，看不明白，故此記錄。 前提：flink版本：1.10.0zk集群hadoop集群 一、flink-session方式 在yarn中啟動一個長久運行的flin...
-
Flink系列 - 實時數(shù)倉之數(shù)據(jù)入HBase實戰(zhàn)（八）??這個案例是建立在上一篇的基礎(chǔ)之上，之所以做總結(jié)是因為網(wǎng)上很多都只是簡單的調(diào)用API而已，根本找不到優(yōu)化過后的 sink 自定義方法，顯示的生產(chǎn)中我們不可能僅僅是像教程那樣...
