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