一.引言 使用 Flink - Kafka 接数据 Source 时程序报错： org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy 任务每次启动后持续10min左右，然后 RUNNING -> FAILED，如此重启失败了多次。 二.问题现象 1.任务 …

一.引言: Spark Streaming 支持通过 Receiver 自定义数据流，实现之后由于接受客户端的不稳定时常造成streaming程序的崩溃，最早的想法是在Receiver实现中加入try catch，通过异常处理使得数据不会中断，但是Receiver整体的中断还是会…

环境 docker安装在Centos7上，机器重启后，发现docker里服务都没启动。 查看了一下： % docker ps -a Cannot connect to the Docker daemon at unix:///var/run/docker.sock. Is the docker daemon running?原来是docker服务没有启动。需要把…