我试图从flink kafkaconsumer使用的数据流:
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html
这里我的KAFKA是Kerberos安全和启用SSL的。
我是r...
我想写一个Flink streaming operator，它维护每个键1500-2000个地图，每个地图包含大约100个 ~ 100B的元素。大多数记录将触发插入和读取，.
请帮助我，我有两个问题:
我从Apache Kafka json-messages中读取，(然后我有步骤: 反序列化到POJO，filter，keyBy.)
哪个更好使用: KeyedProcessFunction (with state，
我试图在遇到各种问题的windows上安装flink。请帮忙。
从网上下载tar文件，不给我windows bat文件选项。使用了h.处的下载链接
我试图设置一个flink-yarn会话来运行 ~ 100 个批处理作业。在连接到大约 40 个任务管理器和大约 10 个正在运行的作业 (每个任务管理器有 2 个插槽和 1gb内存) 后，它看起来l.