去返回你要的类型，可以用return()函数来解决 报错的代码如下： 修改：使用ret ...

最近遇到一个很奇怪的问题，Flink任务正常启动正常运行一段时间后就会报错，,错误详情如下 初步判断应该是触发了akka的超时机制，那就先调整集群的akka超时间配置，在conf/flink-conf.yaml最后增加下面参数 观察Job Manager ...

1、输出错误日志信息 编辑tomcat/bin/startup.bat，尾部加上PAUSE，保存后重新运行startup.bat，可至tomcat/logs查看到错误日志信息。 2、如上 ...

简介 记录一些使用Flink SQL时遇到的报错日志信息。 一：Caused by: java.lang.Exception: Pod terminated, container termination statuses: [flink-task-manager(exitCode=239 ...

程序批量插入数据时报错，将sql在navicat执行又不报错。报错信息：Caused by: java.io.IOException: Tried to send an out-of-range integer as a 2-byte value: 43800 查询资料参考资料发现 ...

最近2周开始接手apache flink全链路监控数据的作业，包括指标统计，业务规则匹配等逻辑，计算结果实时写入elasticsearch. 昨天遇到生产环境有作业无法正常重启的问题，我负责对这个问题进行排查跟进。 第一步，基础排查 首先拿到jobmanager和taskmanager的日志 ...

遇到异常 发现异常： hostname 在shell中解析不完整 调整hostname后 增加hosts配置 屏蔽错误ho ...

当存储和计算分离之后，给容器挂载的硬盘一般是块设备，但这个块设备可能是在其他主机上，使用iscsi协议来读写。 最近遇到一个问题，当iscsi的对应target出问题之后，容器中写盘出现io err ...