实时计算 Flink版

Flink rest能不能在main中执行多个串行的job？ 以下为热心网友提供的参考意见 是的，Flink REST API可以在main方法中执行多个串行的job。 首先，你需…

在Flink这个metadata 怎么赋值进去？ 以下为热心网友提供的参考意见 自动生成的，souce采用 meta。此回答整理自钉群“【②群】Apache Flink China…

用FlinkSQL从Datahub中的一个topic读数据没有问题，但是向DataHub中另一个topic写数据写不进去也不报错，知道什么原因吗？ 以下为热心网友提供的参考意见 可…

请问有人遇到过因为某些task重启导致akka rpc压力过大导致心跳没办法正常进行，从而导致其他taskmanager也failover的问题么？Flink这个问题除了增大心跳超…

flink 可以让他自动重启的时候都无状态重启吗？ 以下为热心网友提供的参考意见 是的，Flink 可以在自动重启时以无状态方式重启。为了实现这一点，你需要在 Flink job …

flink中如何能够产生-D的change log的呢？ 实际的业务场景是，我这边有一个滑动窗口，但是我希望根据第二次滑动后窗口产生的数据和第一次滑动后窗口产生的数据做对比，按照主…

Flink日期减去24小时 怎么实现？需要保留时分秒 以下为热心网友提供的参考意见 在Flink中，可以使用DateTime类和TimeUnit枚举来实现日期减去24小时的操作。以…

Flink的faker 时候array类型, 这种怎么表示？ 指的是在平台上直接指定的时候 以下为热心网友提供的参考意见 在Flink的faker中，要表示array类型，可以使用…

Flink调度功能什么时候能上？ 以下为热心网友提供的参考意见 等着发版。阿里云整体变更暂停了。此回答整理自钉群“实时计算Flink产品交流群”

Flink这个错误怎么处理？2023-11-30 11:20:48java.lang.UnsupportedOperationException: Currently it is …

Flink因为session集群无法启动，提示要剔除参数。剔除后session集群能启动了，但是调试的时候又报错，这应该怎么处理啊？ 以下为热心网友提供的参考意见 这个问题可能是由…

Flink写入阿里云的selectdb，导入selectdb连接器报错，怎么处理？用的flinksql从阿里云kafka导入到阿里云selectdb 以下为热心网友提供的参考意见 …