匿名

请教一个flink-stream 的问题，在作业中我定义了一个 广播流，将该广播流将一些配置信息动态广播到下游算子中，也实现了BroadcastProcessFunction 类，…

coordinate字段 是point类型 flink不支持怎么办 ？ 我在flinksql改成string的话 写入时报错 以下为热心网友提供的参考意见 如果Flink不支持co…

Flink凌晨的时候有些tm重启是什么原因？ 以下为热心网友提供的参考意见 Apache Flink 提供了一种机制允许 TaskManager 自动检测故障情况并在必要时重新启动…

怎么查看flink任务cpu的使用率？ 以下为热心网友提供的参考意见 拿不到的，只能拿到机器的接了prometheus也拿不到cpu使用率，所以你只能拿机器的cpu使用率 ，此回答…

Flink如果有两条流join，两条流的可变化时间周期跨度很大，这种场景应该怎么解决？ 以下为热心网友提供的参考意见 云上有双流不同ttl可以解一下state太大的问题 ，此回答整…

有没部署过flink sql gateway的呀？一直报错 org.apache.thrift.protocol.TProtocolException: Missing versi…

为什么我用Flink docker-compose up -d 这个配置文件就会变成root 了 是怎么回事啊？ 以下为热心网友提供的参考意见 当你使用docker-compose…

如果Flink能知道配置一个slot的cpu使用率，比如20%。那么配置2个slot可能就是40% 可以这么想吗？ 以下为热心网友提供的参考意见 是的，你的理解是正确的。在Flin…

Flink 这个是什么资源不够哇？我看到slot 都还有 以下为热心网友提供的参考意见 你任务要求的并发slot数量不够 ，此回答整理自钉群“【③群】Apache Flink Ch…

对于一个Flink任务，怎么知道一个tm配置多少slot最合适呢？ 以下为热心网友提供的参考意见 机器的核心数和内存，这个需要看算子效率高低，而且需要压测，没有固定的参考值 ，此回…

这是我们以前的文字识别OCR模型 也是一行数据标注一次，识别出来是合并的，这块你们改了吗？ 以下为热心网友提供的参考意见 嗯，增加了多实体的支持，需要按照实体粒度标；如果多行是多实…

flinkcdc能接kafka开了权限认证吗？kafka开了sasl权限认证 以下为热心网友提供的参考意见 可以的，Flink CDC能够接入开启了SASL权限认证的Kafka。在…