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

flink读取source data 数据的来源是flink程序从中读取输入的地方。我们可以使用StreamExecutionEnvironment.addSource（sourceFunction）将源添加到程序中。 flink附带大量预先实现好的各种读取数据源的函数，也可以通过为非并行源 ...

　　在我之前的博文中，已经介绍过要慎用Actor的ask。这里我们要分析一下ask的源码，看看它究竟是怎么实现的。 　　开发时，如果要使用ask方法，必须要引入akka.pattern._，这样才能使用ask（或者？）方法，那么想必ask是在akka.pattern._对应的包里面实现 ...

今天打算把selenium降级重新安装，发现安装时总是失败，报如下错误： 原因是超时了，解决方法：安装时指定超时时间 参考博客：http://www.cnblog ...

最近整理配置Eureka时, 注册服务后, Eureka服务一直报出如下错误: 如下是我的单台eureka的 application.yml 配置: 启动完Eureka后, 启 ...

最近上了个Flink任务，运行一段时间后就自动停止了，很是郁闷，查看最后一个chekpoint时间点，翻看时间日志 根据Heartbeat of TaskManager with id和The heartbeat of ResourceManager with id ...

Flink Heartbeat of TaskManager和Heartbeat of ResourceManager timed out问题 引起心跳超时有可能是yarn压力比较大引起的，先暂时在conf/flink-conf.yaml将这个值调大一点，再观察。 ...

一、nginx 作PHP的web接口服务器，在线上发现时不时经常崩溃。504，导致接口访问无响应回复。 查看日志： [error] 11618#0: *324911 upstream timed out (110: Connection timed out) while reading ...