实时计算 Flink版

在Flink算子内部 怎么使用异步 io？ 以下为热心网友提供的参考意见 https://nightlies.apache.org/flink/flink-docs-master/…

有什么办法让flink在windows运行？单机都行 以下为热心网友提供的参考意见 要在Windows上运行Flink，首先需要下载Flink的二进制包。推荐选择与Scala结合的…

请教一下 我往远端flink提交cdc模式作业时，前面可以正常提交，后面再提交会报链接超时问题报错信息：正常的任务 以下为热心网友提供的参考意见 当您往远端Flink提交CDC模式…

flink on k8s 这个pod 重启策略只支持 always ， 怎么 修改能让他支持 never 或OnFailure 吗？ 以下为热心网友提供的参考意见 在Kuberne…

flink 处理的速度太慢 但是又没有背压，还会出现 ck 超时失败的情况，有点不知道怎么弄？ 以下为热心网友提供的参考意见 异步IO或者增加并发 ，此回答整理自钉群“【③群】Ap…

flinkcdc读取mysql的启动模式是不是不支持timestamp模式？ 以下为热心网友提供的参考意见 是2.3還是2.4以上已經支持了 ，此回答整理自钉群“【③群】Apach…

把mysql-cdc的jar挂到/opt/flink/lib目录下了。但是启动sql-client时，提示找不到该连接器？ 以下为热心网友提供的参考意见 如果您将mysql-cdc…

请教一下怎么用flinksql 写一个连接带有kerberos 认证的 hive 的catalog？ 以下为热心网友提供的参考意见 flink必须写到配置文件里，kerberos配…

Flink1.18.0 拿rancher k8s部署 taskmanager报连不上taskmanager 然后一直重启，大家有见过这种情况吗？ 以下为热心网友提供的参考意见 你看…

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

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

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