Connection unexpectedly closed by remote task manager 想問下這個問題是什么原因那？
flink 啟動問題記錄flink 并行度設(shè)置 優(yōu)先級從低到高排序，排序?yàn)閍pi>env>p>file，parallelism不能多與slot個數(shù)，設(shè)置合適的并行度，能提高運(yùn)算效率 flink 并行...
發(fā)簡信
IP屬地：北京
-
-
想問下您，我on yarn的時候，log級別一直是debug， 但是沒有配置過debug級別的。這個問題您遇到過沒
Flink日志配置（基于flink1.11.1）
滾動日志的配置 flink日志的配置主要是將配置放在flink/conf下面才起作用下面是我的滾動日志的配置，能夠?qū)崿F(xiàn)將過期的日志清掉，只保存最新7份50M的日志。 實(shí)現(xiàn)滾動...
-
您好，我現(xiàn)在 1,2都配置了，但是依舊是這個錯。 任務(wù)如果是跑在yarn的session上是沒有問題的，但是per-job就會報這個錯。想請教下您，這是那個方面的問題嗎?
Flink 連接 hive 解決 java.net.UnknownHostException
錯誤 今天在實(shí)驗(yàn) Flink 連接 hive 的操作，由于 CDH 的 hadoop 是 HA，連接過程中報錯如下： 解決方式 1.配置 HADOOP_CONF_DIR 環(huán)境...
-
