流计算

Flink这个问题怎么解决？ The main method caused an error: maxConcurrentCheckpoints can’t be &g…

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

Flink计算产生了大量的pps 包，导致机器网络不稳定有人遇到过这样问题吗？ 以下为热心网友提供的参考意见 Flink计算产生了大量的pps包，这可能导致机器网络不稳定。这种情况…

Flink这个问题怎么处理？

Flink这个问题怎么解决？ 以下为热心网友提供的参考意见 这个问题是由于缺少Kafka Connect的依赖导致的。你需要在项目的pom.xml文件中添加以下依赖： <de…

在Flink 1.16 lookup join 可以join子查询吗？ 以下为热心网友提供的参考意见 Flink 1.16的Lookup Join主要用于将一张表的数据通过查询去丰…

flink sql 怎么获取到oracle 自增ID ？ 以下为热心网友提供的参考意见 在Flink SQL中，获取Oracle自增ID可以通过以下步骤实现： 首先，你需要在你的F…

Flink sql有没有函数支持解析一个json string并转成期望的数据类型呢？JSON_QUERY(‘{“a”:[{“c&#…

Flink的sqlserver的cdc支持抽取sqlserver视图不？ 以下为热心网友提供的参考意见 Flink的SQL Server CDC支持抽取SQL Server视图。

Flink这种一般会是什么情况引起的呢？我 3秒 的窗口计算总和，但是在现场有溢些 group by 的分组无法计算出值。数据也是有在发送的。WATERMARK 也是设置了允许延迟…

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

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