springboot整合flink后打包到Flink集群环境上运行报错
我是通过在SpringBoot启动类实现CommandLineRunner类，实现run方法来整合SpringBoot与Flink的，在本地运行没有任何问题。打包到flink集群环境上运行…
IDEA 创建第一个 Flink 项目 出现JNI错误
问题描述 跑flink源码无任何问题，但是自己创建一个新的flink项目就会出现错误 Error: A JNI error has occurred, please check your installation a…
Flink的TTL是否会对数据一致性造成影响？
Time-To-Live 是否会对 Flink 的 数据一致性 造成影响吗？比如：程序因为某个原因 回放 到上个 checkpoint 的状态了，然后它的执行结果与没有 回放 …
flink1.8启动时报错找不到resoucemanager
问题描述 我下载了flink1.8版本后，按说明解压，执行start-cluster.sh后，访问 localhost:8081 页面，taskmanager个数一直为0,查看日志发现是taskman…
依赖于kafka的Flink任务是否可以通过复制job来强行达到动态增加资源的目的？
由于目前版本似乎flink不支持dynamic scaling，需要增加资源分配的话必须先停止正在运行的job。目前我有一个flink job是用于消费kafka topic中的数据…
flink 如何初始化 spring
刚刚使用flink，有几个疑问，求各位了解的大大们，帮帮忙 flink如何初始化spring上下文 flink如何使用定时任务 @codecraft @阿里云云栖社区 @范闲 叩…
