apache-flink有关的问题


来自KAFKA KRB5 Kerberos问题的FLINK流媒体

我试图从flink kafkaconsumer使用的数据流:
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html
这里我的KAFKA是Kerberos安全和启用SSL的。
我是r...


如何实现支持快速插入、查找和迭代嵌套映射的Flink keyed状态的映射?

我想写一个Flink streaming operator,它维护每个键1500-2000个地图,每个地图包含大约100个 ~ 100B的元素。大多数记录将触发插入和读取,.


如何停止Apache Flink CEP模式?

请帮助我,我有两个问题:
我从Apache Kafka json-messages中读取,(然后我有步骤: 反序列化到POJO,filter,keyBy.)
哪个更好使用: KeyedProcessFunction (with state,


Apache flink windows安装

我试图在遇到各种问题的windows上安装flink。请帮忙。
从网上下载tar文件,不给我windows bat文件选项。使用了h.处的下载链接


Flink yarn-session模式在同时运行 ~ 10 个批处理作业时变得不稳定

我试图设置一个flink-yarn会话来运行 ~ 100 个批处理作业。在连接到大约 40 个任务管理器和大约 10 个正在运行的作业 (每个任务管理器有 2 个插槽和 1gb内存) 后,它看起来l.