一晌块、環(huán)境準(zhǔn)備 IDEA Community Editionjdk8maven 二陆爽、下載SpringBoot項(xiàng)目 https://start.spring.io/[https:...
IP屬地：內(nèi)蒙古
-
最簡(jiǎn)單IDEA社區(qū)版構(gòu)建SpringBoot項(xiàng)目 -
Hadoop on Yarn 提交job失斉：java.net.ConnectException：Connection refused
報(bào)錯(cuò)： 解決： 配置yarn-site.xml，配置nodemanager的地址。 <name>yarn.nodemanager.hostname</name> <value...
-
Flink On Yarn 模式部署提交Flink On Yarn 模式部署提交 一、環(huán)境準(zhǔn)備 Ubuntu hadoop 2.6.0（官網(wǎng)下載） Flink 1.12.2 jdk 8 二、Hadoop 完全分布式...
-
在flink 1.13版本可以使用：
StreamTable Environment tableEnv = StreamTableEnvironment.create(env);
tableEnv.getConfig().getConfiguration().setString("pipeline.name", "Common.jobName");解決Flink1.11.0不能指定SQL任務(wù)JobName問題
前言： Flink最近剛發(fā)布了1.11.0版本抡医，由于加了很多新的功能，對(duì)sql的支持更加全面早敬，我就迫不及待的在本地運(yùn)行了個(gè)demo魂拦，但是運(yùn)行的時(shí)候報(bào)錯(cuò)了： 雖然報(bào)錯(cuò)，但任務(wù)卻...
-
使用maven構(gòu)建Flink jar包并在集群中使用
pom.xml使用maven-shade-plugin構(gòu)建jar包搁嗓。注意：修改<mainclass> Terminal執(zhí)行命令：mvn clean package -Dmav...
-
Flink CEP SQL案例
描述：現(xiàn)在的任務(wù)是找出一個(gè)單一股票價(jià)格不斷下降的時(shí)期芯勘。 一、Maven項(xiàng)目pom.xml 二腺逛、測(cè)試數(shù)據(jù) 輸入： +----+-------------------------...
-
MySql+Navicat環(huán)境搭建
【轉(zhuǎn)載參考】：https://blog.csdn.net/liangllhahaha/article/details/89508826[https://blog.csdn.n...
-
數(shù)據(jù)結(jié)構(gòu)和算法總結(jié)數(shù)據(jù)結(jié)構(gòu)和算法總結(jié) 一、排序算法 1.1棍矛、排序分類 1.內(nèi)部排序 指將需要處理的所有數(shù)據(jù)都加載到內(nèi)部存儲(chǔ)器（內(nèi)存）中進(jìn)行排序安疗。 2.外部排序法 數(shù)據(jù)量過大，無法全部加載到內(nèi)存...
-
Flink中的事件語義和watermark機(jī)制Flink中的事件語義和watermark機(jī)制 【[白話解析] Flink的Watermark機(jī)制】：https://www.cnblogs.com/rossiXYZ/p/1...
-
數(shù)據(jù)結(jié)構(gòu)算法基礎(chǔ)
算法基礎(chǔ) 一够委、基礎(chǔ)算法 字符串處理 LeetCode38 外觀數(shù)列 LeetCode49 字母異位詞分組 對(duì)字母排序 LeetCode151 翻轉(zhuǎn)字符串里的單詞 LeetC...
-
Tensorflow安裝及實(shí)現(xiàn)第一個(gè)程序hello world
Tensorflow安裝及實(shí)現(xiàn)第一個(gè)程序hello world 1荐类、安裝Anaconda 2、安裝Tensorflow-CPU 3茁帽、Pycharm使用Tensorflow 4...
-
Flink-CEP 惡意登錄demo
一玉罐、Maven項(xiàng)目的pom.xml 二、測(cè)試數(shù)據(jù) LonginLog.csv 5402,83.149.11.115,success,155843081523064,66.24...
-
樸素貝葉斯分類器（Python實(shí)現(xiàn)+詳細(xì)源碼原理）
一潘拨、貝葉斯公式 1吊输、貝葉斯公式的本質(zhì)： 由因到果，由果推因 2铁追、貝葉斯公式： [圖片上傳中...(wps6.png-5fd624-1618488341725-0)] 二季蚂、樸素...
-
Flink入門案例-WordCount流處理
一、maven項(xiàng)目的pom.xml中的依賴 二琅束、測(cè)試數(shù)據(jù) input file path:./hello.txt hello worldhello flinkhello sp...
-
Flink入門案例-WordCount批處理
一扭屁、maven項(xiàng)目pom.xml依賴 二、測(cè)試數(shù)據(jù) input file path:./hello.txt hello worldhello flinkhello spark...
-
Docker錯(cuò)誤記錄: Failed to get D-Bus connection: Operation not permitted
錯(cuò)誤描述 在創(chuàng)建好Docker的CentOS7容器以后涩禀，安裝了服務(wù)料滥，使用systemctl啟動(dòng)關(guān)閉服務(wù)的時(shí)候報(bào)錯(cuò)。 解決方案 運(yùn)行容器的時(shí)候使用--privileged參數(shù) ...
-
安全領(lǐng)域中的機(jī)器學(xué)習(xí)
安全領(lǐng)域中的機(jī)器學(xué)習(xí) 【網(wǎng)絡(luò)安全自學(xué)篇（二十二）| 基于機(jī)器學(xué)習(xí)的惡意請(qǐng)求識(shí)別及安全領(lǐng)域中的機(jī)器學(xué)習(xí) 轉(zhuǎn)載】：https://cloud.tencent.com/develo...
-
flink-example分析 batch/WordCount.jar 和streaming/SocketWindowWordCount.jarflink-example分析 batch/WordCount.jar 和streaming/SocketWindowWordCount.jar java版本環(huán)境 openj...
