- Flink核心特性Flink具有先进的架构理念，拥有诸多的优秀特性以及完善的编程接口，Flink的优势有以下几点：一、批流一体化Flink可以在底层用同样的数据抽象和计算模型来进行批处理和流处理。事实上，Flink在设计理念上没有刻意强调批处理和流处理，而更多的强调数据的有界和无界，这就意味着Flink能够满足企业业务需求，无需用两种甚至多种框架分别实现批处理和流处理，这大大降低了架构设计、... Flink核心特性Flink具有先进的架构理念，拥有诸多的优秀特性以及完善的编程接口，Flink的优势有以下几点：一、批流一体化Flink可以在底层用同样的数据抽象和计算模型来进行批处理和流处理。事实上，Flink在设计理念上没有刻意强调批处理和流处理，而更多的强调数据的有界和无界，这就意味着Flink能够满足企业业务需求，无需用两种甚至多种框架分别实现批处理和流处理，这大大降低了架构设计、...
- Flink应用场景以及其他实时计算框架对比一、Flink应用场景在实际生产的过程中，大量数据在不断地产生，例如金融交易数据、互联网订单数据、GPS定位数 据、传感器信号、移动终端产生的数据、通信信号数据等，以及我们熟悉的网络流量监控、服务器产生的日志数据，这些数据最大的共同点就是实时从不同的数据源中产生，然后再传输到下游的分析系统。针对这些数据类型主要包括实时智能推荐、复杂事件处理、实时欺诈... Flink应用场景以及其他实时计算框架对比一、Flink应用场景在实际生产的过程中，大量数据在不断地产生，例如金融交易数据、互联网订单数据、GPS定位数 据、传感器信号、移动终端产生的数据、通信信号数据等，以及我们熟悉的网络流量监控、服务器产生的日志数据，这些数据最大的共同点就是实时从不同的数据源中产生，然后再传输到下游的分析系统。针对这些数据类型主要包括实时智能推荐、复杂事件处理、实时欺诈...
- Flink是分布式流数据处理引擎。 Flink是分布式流数据处理引擎。
- 本文通过阅读Kafka Connector代码的调用，分析了Kafka partition分配、Commit、线程模型等 本文通过阅读Kafka Connector代码的调用，分析了Kafka partition分配、Commit、线程模型等
- 《数据如何治理呢》 《数据如何治理呢》
- 本文目的是给自己备忘的，在后面的工作和学习中若想快速搭建Flink环境用于开发，可以照此进行 本文目的是给自己备忘的，在后面的工作和学习中若想快速搭建Flink环境用于开发，可以照此进行
- 本文主要介绍pyflink 1.14的一些特性 本文主要介绍pyflink 1.14的一些特性
- 一、准备环境1.根据产品文档安装Flink客户端；2.将sql-client-defaults.yaml放入/opt/client/Flink/flink/conf中3.将jaas.conf放入/opt/client/Flink/flink/conf中Client {com.sun.security.auth.module.Krb5LoginModule requireduseKeyTab=... 一、准备环境1.根据产品文档安装Flink客户端；2.将sql-client-defaults.yaml放入/opt/client/Flink/flink/conf中3.将jaas.conf放入/opt/client/Flink/flink/conf中Client {com.sun.security.auth.module.Krb5LoginModule requireduseKeyTab=...
- 1.1.1 开启checkpoint并且自定义目录后任务运行24小时后checkpoint全部失败问题现象 Flink选择使用对接ES的任务在运行一段时间后checkpoint全部失败，而对接kafka能够正常运行。可能原因ES的认证模式跟其它场景不同，在运行一段时间后，票据信息会超时需要重新认证，此时ES中缓存的票据信息没有更新，导致跟HDFS中指定的目录无法正常认证。解决方案1.需要在... 1.1.1 开启checkpoint并且自定义目录后任务运行24小时后checkpoint全部失败问题现象 Flink选择使用对接ES的任务在运行一段时间后checkpoint全部失败，而对接kafka能够正常运行。可能原因ES的认证模式跟其它场景不同，在运行一段时间后，票据信息会超时需要重新认证，此时ES中缓存的票据信息没有更新，导致跟HDFS中指定的目录无法正常认证。解决方案1.需要在...
- 【问题描述】Flink对接消费Kafka数据时，任务超时失败，Flink的JobManager日志上报“org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition trafficgo_realtime_traffic-0 could ... 【问题描述】Flink对接消费Kafka数据时，任务超时失败，Flink的JobManager日志上报“org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition trafficgo_realtime_traffic-0 could ...
- 以flink1.10开源代码未例子。梳理flink client提交作业的源码流程 1、/bin/flink run xxx用户通过flink client的命令行工具提交作业flink只是个shell脚本，原理就是调用如下类 org.apache.flink.client.cli.CliFrontend “$@” 2、CliFrontend的main()函数内部逻辑getConfigura... 以flink1.10开源代码未例子。梳理flink client提交作业的源码流程 1、/bin/flink run xxx用户通过flink client的命令行工具提交作业flink只是个shell脚本，原理就是调用如下类 org.apache.flink.client.cli.CliFrontend “$@” 2、CliFrontend的main()函数内部逻辑getConfigura...
- 随着大数据时代的深入发展，实时数据处理需求呈爆发式增长。作为实时计算领域的事实标准，Apache Flink在过去十年中不断演进，从最初的流式计算引擎发展为如今的流批一体计算平台。本文将深入探讨Flink未来的技术发展趋势，揭示流处理技术的下一个十年。 一、流处理技术演进历程Flink的发展历程反映了流处理技术的演进轨迹：2010-2015年：Lambda架构时代 - 批流分离架构，代码重复... 随着大数据时代的深入发展，实时数据处理需求呈爆发式增长。作为实时计算领域的事实标准，Apache Flink在过去十年中不断演进，从最初的流式计算引擎发展为如今的流批一体计算平台。本文将深入探讨Flink未来的技术发展趋势，揭示流处理技术的下一个十年。 一、流处理技术演进历程Flink的发展历程反映了流处理技术的演进轨迹：2010-2015年：Lambda架构时代 - 批流分离架构，代码重复...
- Apache Flink作为当前最活跃的开源流处理引擎，其"流批一体"的核心设计理念一直备受业界关注。Flink 1.18版本于2023年发布，不仅在稳定性、性能方面进行了优化，更在流批一体化道路上迈出了重要一步。本文将深入浅出地解析Flink 1.18在流批一体方面的关键演进。 流批一体：从理念到实践Flink的流批一体并非简单地将批处理视为有界流，而是通过统一的运行时架构和API设计，让... Apache Flink作为当前最活跃的开源流处理引擎，其"流批一体"的核心设计理念一直备受业界关注。Flink 1.18版本于2023年发布，不仅在稳定性、性能方面进行了优化，更在流批一体化道路上迈出了重要一步。本文将深入浅出地解析Flink 1.18在流批一体方面的关键演进。 流批一体：从理念到实践Flink的流批一体并非简单地将批处理视为有界流，而是通过统一的运行时架构和API设计，让...
- Apache Flink作为当前最活跃的流处理框架之一，持续迭代更新以满足日益复杂的实时计算需求。Flink 1.17版本在连接器生态和系统性能方面带来了多项重要改进，这些优化不仅提升了开发体验，更为生产环境的稳定性和效率提供了坚实保障。本文将深入浅出地解析Flink 1.17在连接器增强与性能优化方面的核心特性。 一、连接器生态全面增强 1. Kafka连接器重大改进Flink 1.17对... Apache Flink作为当前最活跃的流处理框架之一，持续迭代更新以满足日益复杂的实时计算需求。Flink 1.17版本在连接器生态和系统性能方面带来了多项重要改进，这些优化不仅提升了开发体验，更为生产环境的稳定性和效率提供了坚实保障。本文将深入浅出地解析Flink 1.17在连接器增强与性能优化方面的核心特性。 一、连接器生态全面增强 1. Kafka连接器重大改进Flink 1.17对...
- Apache Flink作为当前最主流的流处理框架之一，其1.16版本带来了众多关键改进，尤其在状态管理与API设计方面取得了显著进步。这些改进不仅提升了Flink的性能和可靠性，还大大简化了开发者的使用体验。本文将深入探讨Flink 1.16中这些关键特性的实际应用价值。 状态管理的显著提升 1. 状态后端配置的简化Flink 1.16对状态后端配置进行了大幅简化，开发者现在可以通过更直观... Apache Flink作为当前最主流的流处理框架之一，其1.16版本带来了众多关键改进，尤其在状态管理与API设计方面取得了显著进步。这些改进不仅提升了Flink的性能和可靠性，还大大简化了开发者的使用体验。本文将深入探讨Flink 1.16中这些关键特性的实际应用价值。 状态管理的显著提升 1. 状态后端配置的简化Flink 1.16对状态后端配置进行了大幅简化，开发者现在可以通过更直观...
上滑加载中
推荐直播
-
HDC深度解读系列 - Serverless与MCP融合创新，构建AI应用全新智能中枢2025/08/20 周三 16:30-18:00
张昆鹏 HCDG北京核心组代表
HDC2025期间，华为云展示了Serverless与MCP融合创新的解决方案，本期访谈直播，由华为云开发者专家(HCDE)兼华为云开发者社区组织HCDG北京核心组代表张鹏先生主持，华为云PaaS服务产品部 Serverless总监Ewen为大家深度解读华为云Serverless与MCP如何融合构建AI应用全新智能中枢
回顾中 -
关于RISC-V生态发展的思考2025/09/02 周二 17:00-18:00
中国科学院计算技术研究所副所长包云岗教授
中科院包云岗老师将在本次直播中，探讨处理器生态的关键要素及其联系，分享过去几年推动RISC-V生态建设实践过程中的经验与教训。
回顾中 -
一键搞定华为云万级资源，3步轻松管理企业成本2025/09/09 周二 15:00-16:00
阿言 华为云交易产品经理
本直播重点介绍如何一键续费万级资源，3步轻松管理成本，帮助提升日常管理效率！
回顾中
热门标签