实时计算 Flink版

怎么查看flink任务cpu的使用率？ 以下为热心网友提供的参考意见 Flink任务的CPU使用率可以通过Flink Metrics来查看。Flink Metrics涵盖了Flin…

springboot集成flink有什么好的方式 能够通过接口启动和关闭flink程序？ 以下为热心网友提供的参考意见 有api接口 ，此回答整理自钉群“【③群】Apache Fl…

flinkcdc能接kafka开了权限认证吗？ 以下为热心网友提供的参考意见 Flink CDC 可以接入开启了权限认证的 Kafka。在接入过程中，需要进行以下步骤：首先，如果您…

我Flink 5 个并行度 为什么只有其中 1 个并行度有数据啊？分区策略还需要手动指定吗？ 以下为热心网友提供的参考意见 Flink 的并行度是指将数据分割成多个并行任务进行处理…

Flink集群重启之后job列表都消失了 有没有办法恢复？ 以下为热心网友提供的参考意见 当Flink集群重启后，Job列表消失可能是由于以下原因之一： 未正确配置保存点（Chec…

请教个问题，flink使用sql插入数据，插入过程中有异常数据，通过sql的方式可以处理吗？ 以下为热心网友提供的参考意见 是的，Flink SQL提供了一些内置函数和操作符来处理…

Flink开启changelog配置文件，但是代码设置只是开启即可？state.backend.changelog.enabled: truestate.backend.chang…

Flink用jdbc catalog连接postgresql时，pg的schema里有横线该怎么处理呢？ 以下为热心网友提供的参考意见 在Flink SQL中通过 JDBC Cat…

请教个问题，我在83服务器上部署了一个Flink1.17 ，然后我有两个mysql数据库，分别部署在63服务器和81服务上了，我在往83提交cdc作业时（链接的是81服务器上的数据…

Flink binlog 收到这样一条sql 任务就崩溃了，怎么解决呀？已经稳定运行很久了 最近出现了这样一个错 以下为热心网友提供的参考意见 楼主你好，你的错误信息表明阿里云Fl…

flink自动合并新录入的数据到有sort-order的table，iceberg表底层parquet的排序怎么保证呀？ 以下为热心网友提供的参考意见 Flink 自动合并新录入的…

Flink这个 busy 是啥意思？ 以下为热心网友提供的参考意见 在Flink中，”busy”一词通常被用来描述任务的运行状态。当任务正处于忙碌状态时，这…