flink
-
【flink】Task 故障恢复详解以及各重启策略适用场景说明
文章目录 一. 重启策略种类（Restart Strategies） 1. Fixed Delay Restart Strategy 2. Failure Rate Restart…
-
【大数据】流处理基础概念（一）：Dataflow 编程基础、并行流处理
流处理基础概念（一）：Dataflow 编程基础、并行流处理 流处理基础概念（二）：时间语义（处理时间、事件时间、水位线） 流处理基础概念（三）：状态和一致性模型（任务故障、结果保…
-
Flink1.17.1消费kafka3.5中的数据出现问题Failed to get metadata for topics [flink].
问题呈现 Failed to get metadata for topics [flink]. at org.apache.flink.connector.kafka.source…
-
Flink流数据窗口与时间
1.背景介绍 随着大数据时代的到来，流处理技术变得越来越重要。流处理系统可以实时地处理大量数据，为实时应用提供有价值的信息。Apache Flink是一个流处理框架，它可以处理大规…
-
使用Flink处理Kafka中的数据
目录 使用Flink处理Kafka中的数据 前提： 一， 使用Flink消费Kafka中ProduceRecord主题的数据 具体代码为（scala） 执行结果 …
-
Flink CDC MySQL同步MySQL错误记录
0、相关Jar包 https://repo1.maven.org/maven2/org/apache/flink/flink-connector-jdbc/3.1.1-1.16/ …
-
实时Flink大数据分析平台的流式计算模型
1.背景介绍 在大数据时代，实时分析和处理数据变得越来越重要。Apache Flink是一种流处理框架，它可以处理大量数据并提供实时分析。在本文中，我们将深入了解Flink的流式计…
-
示例代码：使用golang进行flink开发
以下是一个使用 Golang 进行 Flink 开发的简单示例代码： package main import ( “context” “encoding/json” “log” “…
-
Flink 系例 之 Dashboard 安装与界面操作
前期入门讲解了需多常用算子、方法、和连接器的使用与代码示例，本文讲解如何安装 Apache Flink Dashboard 平台与界面基本操作。 Apache Flink Dash…
-
flink sql1.18.0连接SASL
阅读此文默认读者对docker、docker-compose有一定了解。 环境 docker-compose运行了一个jobmanager、一个taskmanager和一个sql-…
-
Caused by: java.lang.ClassNotFoundException:org.apache.flink.connector.base.source.reader.RecordEmit
出现以下错误: Exception in thread “main” java.lang.NoClassDefFoundError: org/apache/…
-
Flink（十四）【Flink SQL（中）查询】
前言 接着上次写剩下的查询继续学习。 Flink SQL 查询 环境准备： # 1. 先启动 hadoop myhadoop start # 2. 不需要启动 fl…
-
StreamPark + PiflowX 打造新一代大数据计算处理平台
🚀 什么是PiflowX PiFlow 是一个基于分布式计算框架 Spark 开发的大数据流水线系统。该系统将数据的采集、清洗、计算、存储等各个环节封装成组件，以所…
-
Flink中的容错机制
一.容错机制 在Flink中，有一套完整的容错机制来保证故障后的恢复，其中最重要的就是检查点。 1.1 检查点（Checkpoint） 在流处理中，我们可以用存档读档的思路，将之…
-
Flink1.17实战教程（第七篇：Flink SQL）
系列文章目录 Flink1.17实战教程（第一篇：概念、部署、架构） Flink1.17实战教程（第二篇：DataStream API） Flink1.17实战教程（第三篇：时间和…
