流计算

有人接过influxDB吗？Flink这里为什么没有提供setHost()？ 以下为热心网友提供的参考意见 在Flink中使用InfluxDB时，需要先配置InfluxDB的连接信…

请教一下，flink on yarn模式下，怎么对job作业进行指标监控？job整理时延，吞吐量等性能指标想拿jmx看 以下为热心网友提供的参考意见 在Flink on Yarn模…

Flink有人遇到这个问题不？ 以下为热心网友提供的参考意见 这个问题可能是由于Kafka Connect在处理字段名时出现了问题。请检查您的Kafka Connect配置文件中的…

我在使用flink kafka连接器的时候，遇到报错问题，没有分析思路，请各位大佬指教一下报错如下图：kafka集成了kerberos，flink是 on yarn模式，与kafk…

大家有遇到Flink这问题吗?在1.15.4里报错。Caused by: java.util.concurrent.CompletionException: org.apache.…

有什么办法让flink在windows运行，单机都行? 以下为热心网友提供的参考意见 首先，您需要从Flink官网或者Apache的存档站点下载Flink安装包。以Flink 1.…

想问下Flink sql作业支持写判断语句吗，根据标志执行删除，或是更新或是插入? 以下为热心网友提供的参考意见 是的，Flink SQL支持写判断语句。您可以使用CASE WHE…

请问一下，flink sql udf 通过字符串这样传进来，然后用groovy编译成Class，然后通过tableEnv去注册，这样会报错。大家有没有一个好的实现办法呀？外面传个字…

有Flink 的SqlServer 2000版本的驱动包吗？ 以下为热心网友提供的参考意见 Flink支持与多种数据库的连接，但对于SqlServer 2000版本的驱动包，目前公…

想问下我这边Flink在keyby之后数据还是有的，但是到后面的流程里数据就没有了，这是什么原因？ 以下为热心网友提供的参考意见 楼主你好，看了你的描述，需要你检查keyBy操作是…

有没部署过flink sql gateway的呀？一直报错 org.apache.thrift.protocol.TProtocolException: Missing versi…

有没有 大佬用 springboot 启动flink 处理 ，发现springboot 加 schedule调度处理会内存占满情况？ 以下为热心网友提供的参考意见 在Spring …