文章 2024-10-14 来自:开发者社区

大数据-129 - Flink CEP 详解 Complex Event Processing - 复杂事件处理

点一下关注吧!!!非常感谢!!持续更新!!!目前已经更新到了:Hadoop(已更完)HDFS(已更完)MapReduce(已更完)Hive(已更完)Flume&...

大数据-129 - Flink CEP 详解 Complex Event Processing - 复杂事件处理
文章 2024-08-25 来自:开发者社区

【Azure 事件中心】使用Apache Flink 连接 Event Hubs 出错 Kafka error: No resolvable bootstrap urls

问题描述 参考Github上 Event Hub的示例代码(Using Apache Flink with Event Hubs for Apache Kafka Ecosystems : https://github.com/Azure/azure-event-hubs-for-kafka/tree/master/tutorials/flink),使用Apache Flink kafk...

【Azure 事件中心】使用Apache Flink 连接 Event Hubs 出错 Kafka error: No resolvable bootstrap urls
文章 2024-08-25 来自:开发者社区

【Azure 事件中心】Flink消费Event Hub中事件, 使用Azure默认示例代码,始终获取新产生的事件,如何消费旧事件呢?

问题描述 根据Azure Event Hub示例文档,[将 Apache Flink 与适用于 Apache Kafka 的 Azure 事件中心配合使用],配置好 consumer.config 文件后,为什么不能自动消费Event Hub中存储的旧数据呢? 如果发送端(生产者)没有任何消息输出,这消费端的信息也是一片空白,如: ...

【Azure 事件中心】Flink消费Event Hub中事件, 使用Azure默认示例代码,始终获取新产生的事件,如何消费旧事件呢?
文章 2024-08-25 来自:开发者社区

【Azure 事件中心】开启 Apache Flink 制造者 Producer 示例代码中的日志输出 (连接 Azure Event Hub Kafka 终结点)

问题描述 Azure Event Hub 在标准版以上就默认启用的Kafka终结点,所以可以通过Apache Kafka协议连接到Event Hub进行消息的生产和消费。通过示例代码下载到本地运行后,发现没有 Kafka Producer 的详细日志输出。当查看SDK源码中,发现使用的是 org.slf4j.Logger 输出日志,如: ...

【Azure 事件中心】开启 Apache Flink 制造者 Producer 示例代码中的日志输出 (连接 Azure Event Hub Kafka 终结点)
问答 2024-07-10 来自:开发者社区

Flink CDC怎么能直接生成 DataStreamSource<Event>?

Flink CDC怎么能直接生成 DataStreamSource?

问答 2024-06-10 来自:开发者社区

flink报错The binlog event doesn't contain expecte...

flink报错The binlog event doesn't contain expected number of columns

问答 2024-06-10 来自:开发者社区

Flink报错Encountered change event for table yhtpl...

Flink报错Encountered change event for table yhtplus.organization whose schema isn't known to this connector

文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的

问题一:flink1.16.0,sql-client客户端,报这个错,请问这个是什么问题啊? flink1.16.0,sql-client客户端,yarn-session下运行,报这个错,请问大佬这个是什么问题啊?怎么解决? ...

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
文章 2024-05-19 来自:开发者社区

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的

问题一:请问一下Flink:我将docker镜像推到k8s上报错(如下图)。请问是什么原因呀? 请问一下Flink:我将docker镜像推到k8s上报错(如下图)。请问是什么原因呀? 参考回答: -...

实时计算 Flink版操作报错合集之使用 Event Time Temporal Join 关联多个 HBase 后,Kafka 数据的某个字段变为 null 是什么原因导致的
问答 2024-03-19 来自:开发者社区

Flink CDC 里有没有方法只通过flink sql 获取到 row 的方式不?

有没有方法只通过flink sql 获取到 row 的changlog event type么?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问