这是我的代码import org.apache.flink.streaming.api.scala._import org.apache.flink.api.java.utils.ParameterT

Could not execute SQL statement. Reason:java.lang.NoSuchMethodError: com.google.common.base.Precondi

应用主要是分析kafka中的日志数据，统计各个接口的tps/qps。实现方式是根据日志中记载的时间戳已接口名为key统计1s中日志中该key（接口）的日志条数，现在由于某些key的日志数据较多，导致

package com.xu.studyApp.watermarkTest import org.apache.flink.api.common.eventtime.{SerializableTim

如何使用flink并基于scala语言，实现数据泛化解决各种数据源格式，并最终入库elasticsearch？大致的框架为通过flinkx从关系型数据库、非关系型数据库、消息队列采集数据到kafka，

Flink架构项目改造成spring boot项目，或者改造后的flink项目的jar包能放在tomcat中运行，代替flink软件。

flink保证sink 端exactly-once有幂等写入和事务写入两种方式。事务写入的实现方式又有预写日志和两阶段提交。请问预写日志和两阶段提交的差别在哪里？两个好像都是先写入缓存，等checkp

3年工作经验，没接触过FlinkSql，这是什么，求一个文档看看，能知道他是什么，干什么用的。

Flink版本 1.13.1JDK 1.8集群部署 情况: 提交一个job之后JVM metaspace会变大,直到job执行完成.metasapce也不会变小.这样会导致运行了多个job之后met

现在是在服务器端集群部署了flink，每个集群可能有多个task在跑，在不去生产环境的条件下，有没有办法远程通过脚本来操作单个task的启停呢？因为在命令行重启task都是先cancel再run的，需

错误提示： Caused by: java.io.InvalidClassException: org.apache.flink.streaming.api.scala.DataStream$$ano

1单独运行两个流报错数据到es 没问题2为了确保数据没收到2.1kafka生产者我循环每30毫秒发一条 2.2 另外开一个消费者 看到了数据 3代码如下 3.1 sink的sql 3.2 创建

DataStream<ItemViewCount> windowAggStream = dataStream .filter(data -> "p

flink运行任务报错，Failed to construct kafka consumer，下面提示 Too many open files ，请问这个是什么原因，具体怎么排查或者解决，麻烦大佬指点

flink-1.13.2 ，每分钟1个分区，已经生成part文件，但似乎没有提交hive元数据，查不到？ / user/ hive/ warehouse/ event_track2/ dt=2021-

select * from person where age="23",age是Intger类型，报错，能不能做全局的统一处理，不要每次都是cast处理呢

flink基于k8s安装，hadoop原生安装集群，将任务放到flink上执行的时候，报错不能使用checkpoint，环境：k8s的flink1.13.0 原生安装的hadoop3.2.2 我能

初学spark，使用spark structred stream进行计算统计，2小时窗口时长，10秒钟触发一次计算，kafka里发送几条测试数据，内存就报OOM了，按理说不应该啊，请问问题是出在哪儿？

我通过kafka命令查询消费组brokers下有哪些消费者时，是没有的 然后，我通过命令行启动一个消费组 再次查询，消费组下有一个消费者 但是，有个前提，就是我flink一直连接了kafka的，并

按照flink的例子改了一下，从rabbitmq读取流数据，通过RichSinkFunction写入到clickhouse中。第一次运行是正常的，多次写入也没问题。但是cancel job之后，重新s

因本人要学习大数据，需要学习Linux、虚拟机，不清楚R7 5800H是否支持虚拟化操作，询问客服后，还是不清楚能否支持虚拟化，知乎，CSDN里对AMD是否支持虚拟化不认可，想了解下R7 5800H是

求尚硅谷Flink实时数仓2.0 的课件、视频、资料，注意是2.0！

最近在改造项目,全部切换到微服务,组件比较多,需要做熔断机制,在做熔断机制的时候,服务端做好,还是客户端做好?

阿里云全托管的flink怎么读oss桶表数据，还有maxcomputer之类的，用Datastream

你好，为什么我这边把你的代码复制过来报错呢？麻烦帮忙看看，包和依赖都导入了

关于flink接收kafka消息的代码能不能用python写

您好，我跟您遇到了一样的问题，flink写orc文件，用hive加载orc文件的时候报错，请问您解决了么？

SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/hadoop/yarn/l

刀侠，我按照这篇文章搭建还是报错，咋办？ Bytecode: 0x0000000: 2a2b b700 c59a 0016 bb01 2c59 1301 2e04 0x0000010