流计算

一个Flink SQL Job 能同时订阅多个MySql表的Binlog吗？ 以下为热心网友提供的参考意见 可以的，但是会起多个binlog dump链接，因为mysql不支持按表…

请问一下Flink，咱们这个平台怎么关闭 动态调整并发度 的功能？ 因为我在测试环境，用的和生产环境相同的Jar包， 测试环境不想调整那么放开调整那么多并发度， 设置了全局并发度，…

有没有大佬帮忙解释一下Flink这两个指标代表啥意思？ 以下为热心网友提供的参考意见 比较简单的理解是第一个是反压程度，第二个是自身繁忙程度，你这个算子可能处理逻辑比较复杂，有外部…

大佬们，我刚接触flink，请教个问题，flinksql不支持这样写吗，数据库函数？ 在数据库是可以执行的，但是在flink校验sql的 时候报错了？ 以下为热心网友提供的参考意见…

Flink这个问题有明确的解决方案吗？https://developer.aliyun.com/ask/491124 以下为热心网友提供的参考意见 根据您提供的链接，问题描述是关于…

在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…

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

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