一、環(huán)境準備 IDEA Community Editionjdk8maven 二、下載SpringBoot項目 https://start.spring.io/[https:...
IP屬地：海南
-
最簡單IDEA社區(qū)版構(gòu)建SpringBoot項目 -
Hadoop on Yarn 提交job失?。簀ava.net.ConnectException：Connection refused
報錯： 解決： 配置yarn-site.xml，配置nodemanager的地址。 <name>yarn.nodemanager.hostname</name> <value...
-
Flink On Yarn 模式部署提交Flink On Yarn 模式部署提交 一、環(huá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任務JobName問題
前言： Flink最近剛發(fā)布了1.11.0版本，由于加了很多新的功能，對sql的支持更加全面，我就迫不及待的在本地運行了個demo，但是運行的時候報錯了： 雖然報錯，但任務卻...
-
使用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)在的任務是找出一個單一股票價格不斷下降的時期。 一、Maven項目pom.xml 二、測試數(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)部存儲器（內(nèi)存）中進行排序。 2.外部排序法 數(shù)據(jù)量過大，無法全部加載到內(nèi)存...
-
Flink中的事件語義和watermark機制Flink中的事件語義和watermark機制 【[白話解析] Flink的Watermark機制】：https://www.cnblogs.com/rossiXYZ/p/1...
-
數(shù)據(jù)結(jié)構(gòu)算法基礎(chǔ)
算法基礎(chǔ) 一、基礎(chǔ)算法 字符串處理 LeetCode38 外觀數(shù)列 LeetCode49 字母異位詞分組 對字母排序 LeetCode151 翻轉(zhuǎn)字符串里的單詞 LeetC...
-
Tensorflow安裝及實現(xiàn)第一個程序hello world
Tensorflow安裝及實現(xiàn)第一個程序hello world 1、安裝Anaconda 2、安裝Tensorflow-CPU 3、Pycharm使用Tensorflow 4...
-
Flink-CEP 惡意登錄demo
一、Maven項目的pom.xml 二、測試數(shù)據(jù) LonginLog.csv 5402,83.149.11.115,success,155843081523064,66.24...
-
樸素貝葉斯分類器（Python實現(xiàn)+詳細源碼原理）
一、貝葉斯公式 1、貝葉斯公式的本質(zhì)： 由因到果，由果推因 2、貝葉斯公式： [圖片上傳中...(wps6.png-5fd624-1618488341725-0)] 二、樸素...
-
Flink入門案例-WordCount流處理
一、maven項目的pom.xml中的依賴 二、測試數(shù)據(jù) input file path:./hello.txt hello worldhello flinkhello sp...
-
Flink入門案例-WordCount批處理
一、maven項目pom.xml依賴 二、測試數(shù)據(jù) input file path:./hello.txt hello worldhello flinkhello spark...
-
Docker錯誤記錄: Failed to get D-Bus connection: Operation not permitted
錯誤描述 在創(chuàng)建好Docker的CentOS7容器以后，安裝了服務，使用systemctl啟動關(guān)閉服務的時候報錯。 解決方案 運行容器的時候使用--privileged參數(shù) ...
-
安全領(lǐng)域中的機器學習
安全領(lǐng)域中的機器學習 【網(wǎng)絡安全自學篇（二十二）| 基于機器學習的惡意請求識別及安全領(lǐng)域中的機器學習 轉(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...
