發(fā)簡(jiǎn)信
IP屬地：北京
-
FlinkSQL的痛點(diǎn)
現(xiàn)在FlinkSQL可以source創(chuàng)建一張表,也可以sink也創(chuàng)建一張表 然后直接aggTable1.insertInto("out"); 但...
-
Scala解析JSON
package com.mlamp.test_json /** * @Author: DaChun777 * @Date: 2021/12/8 ...
-
Spark讀取Hive數(shù)據(jù)
依賴如下: <dependencies> <!-- mysql --> <dependency> <groupId>mys...
-
Maven明明導(dǎo)入了依賴但是運(yùn)行報(bào)錯(cuò)
我在運(yùn)行flink程序時(shí)候,就是一個(gè)table程序,在編譯時(shí)候以及寫(xiě)代碼都不報(bào)錯(cuò),然后運(yùn)行就報(bào)錯(cuò)少依賴, 臥槽,而且這個(gè)依賴這個(gè)類(lèi)我都能夠找到,...
-
MySQL獲取毫秒值
select time_to_sec(now()), now(), current_timestamp(), replace(unix_time...
-
谷歌Octotree插件下載推薦一個(gè)Github上查看源代碼的瀏覽器插件Octotree 網(wǎng)址：https://pictureknow.com/extensions（偶然發(fā)...
-
Cannot request memory (Xms 0 kb, Xmx 0 kb) from system for job HDFSjob, sleep for 60 secs and ret...場(chǎng)景,執(zhí)行azkaban時(shí)候,一個(gè)簡(jiǎn)單的hdfs查詢,看任務(wù)日志卡主 然后找到看azkaban界面找到日志 然后查看報(bào)錯(cuò) github解決辦法 ...
-
模式匹配
def say(name:String) = namematch {case "YuiHatano" =>println("波多野結(jié)衣")cas...
-
hdfs.DFSClient: DataStreamer Exception org.apache.hadoop.ipc.RemoteException(java.io.IOException)...
hdfs.DFSClient: DataStreamer Exception org.apache.hadoop.ipc.RemoteExcep...