Apache Flink：flink UI的根本原因异常在日志中不可见
我有一个flink作业运行，并配置为与记录back配置进行登录，奇怪的问题是，当发生异常时，在文件日志或控制台日志中找不到flink web UI中的根本原因例…
无法在Apache Flink中使用PULSAR共享订阅
Flink Data Pipeline从Apache Pulsar分区主题中读取。我已经将 pulsarsource 订阅设置为 sisscriptionType.exclusive 。将其更改为 sisscriptionType.…
在apache flink中使用水槽以阅读目的？
我是Apache Flink（和Stackoverflow）的新手，我想知道处理以下方案的最佳实践： 我目前正在使用其他人的应用程序使用Kafkasource消费实时消息。如果…
Flink Oracle JDBC水槽连接器不加载驱动程序
我正在尝试将FLINK JBDC接收器创建到Oracle数据库。当本地运行（从Junit测试和微型驱动器中）时，它可以正常运行，但是当在K8中部署时，它会引发一个…
Flink AndientTimestampSandwatermark
我想通过request_time来计算健康检查数据的状态代码，从当前时间开始使用1分钟的窗口。 众所周知，健康检查每分钟发送约60条请求。因此，结果应该像 {…
cocece.go：220：警告：不能用非表格覆盖桌
我如何找到哪个YAML文件创建此错误。 我正在使用本机Kubernetes flink部署，但是当我运行Helm模板时，我会遇到此错误。 coalesce.go:220: warning: ca…
Flink Kafkasource阅读了该主题的所有消息
我的目标是使用Flink Kafkasource阅读Kafka主题的所有消息。我尝试使用批处理和流模式执行。问题是以下： 当我设置env.setParallelism高于2时，我必须…
是否有flink指标显示具有哈希图状态后端状态的键数？
我将Apache Flink 1.14与RockSDB一起作为状态后端，我考虑将状态后端迁移到Hashmap以改善延迟。 这种方法的主要缺点是rocksdb公开了一个指标指标 - 遗…
Flink聚集功能与keyedProcesfunction and valuestate
我们有一个应用程序，可以消耗来自Kafka源的事件。处理每个元素的逻辑需要考虑以前收到的事件（具有相同的分区密钥），而无需花费时间进行窗口。第一…
为什么我的水印不在我的Apache Flink Keyed Stream中前进？
我目前正在将Apache Flink 1.13.2与Java一起用于流媒体应用程序。我正在使用没有窗口功能的键功能。尽管我的水印没有前进，但我已经实施了水印策略和 …
RegisterEventTimetimer未使用水印发射
我正在使用kafkasource读取事件类型的KAFKA消息，根据文档， KafkaSource source = KafkaSource.builder() .setProperties(kafkaProperties) .setBoot…
即使状态存在密钥，ProcessElement发出记录
我有一个保存数据2分钟的状态，即使该密钥有一个州，有时仍然会发出记录。 @Override public void processElement(EngagerEvents value, KeyedProcess…
