38c40424d439

Connection unexpectedly closed by remote task manager 想问下这个问题是什么原因那？

flink 启动问题记录

flink 并行度设置 优先级从低到高排序，排序为api>env>p>file，parallelism不能多与slot个数，设置合适的并行度，能提高运算效率 flink 并行...

邵红晓

8556 2 0

38c40424d439

想问下您，我on yarn的时候，log级别一直是debug， 但是没有配置过debug级别的。这个问题您遇到过没

Flink日志配置（基于flink1.11.1）

滚动日志的配置 flink日志的配置主要是将配置放在flink/conf下面才起作用下面是我的滚动日志的配置，能够实现将过期的日志清掉，只保存最新7份50M的日志。 实现滚动...

FishMAN__

3397 2 1

38c40424d439

您好，我现在 1,2都配置了，但是依旧是这个错。 任务如果是跑在yarn的session上是没有问题的，但是per-job就会报这个错。想请教下您，这是那个方面的问题吗?

Flink 连接 hive 解决 java.net.UnknownHostException

错误 今天在实验 Flink 连接 hive 的操作，由于 CDH 的 hadoop 是 HA，连接过程中报错如下： 解决方式 1.配置 HADOOP_CONF_DIR 环境...

shengjk1

3491 6 0