问答 2024-05-28 来自:开发者社区

flinkcdc3 cli如何提交任务到远程flink 集群环境呢?

flinkcdc3 cli如何提交任务到远程flink 集群环境呢?

问答 2023-10-18 来自:开发者社区

Flink CDC主函数的日志可以在集群环境中打印, udf函数的日志不打印, 知道怎么解决吗?

Flink CDC主函数的日志可以在集群环境中打印, udf函数的日志不打印, 有大佬知道怎么解决吗?

文章 2022-11-12 来自:开发者社区

【采坑-Flink消费kafka中的数据】阿里云ECS/VMware之zookeeper和kafka单机/集群环境

一、环境1.centos7.62.zookeeper-3.4.53.kafka_2.11-0.10.2.14.jdk1.8_261二、单机-ECS-zookeepertar -zxvf zookeeper-3.4.5 -C /root/apps/cp zoo_simple.cfg zoo.cfg提前创建好数据和目录日志文件夹dataDir=/root/data/zookeeperdataLogD....

【采坑-Flink消费kafka中的数据】阿里云ECS/VMware之zookeeper和kafka单机/集群环境
文章 2022-04-30 来自:开发者社区

使用Flink集群环境进行数据处理(下)

各种算子简介以单词计数为例先要将字符串数据解析成单词和次数 使用tuple2表示 第一个字段是单词 第二个字段是次数 次数初始值设置成1flatmapflatmap来做解析的工作 一行数据可能有多个单词keyBy将数据流按照单词字段即0号索引字段做分组 keyBy(int index) 得到一个以单词为key的tuple2数据流timeWindow在流上指定想要的窗口 并根据窗口中的数据计算结果....

使用Flink集群环境进行数据处理(下)
文章 2022-04-30 来自:开发者社区

使用Flink集群环境进行数据处理(上)

前言上篇文章记录了搭建分布式Flink集群环境的过程搭建Flink集群环境这篇文章咱们聊一聊Flink客户端如何对接Flink集群环境的过程示例:Flink读取Hadoop中的文件 然后通过集群环境进行数据处理的过程HadoopHadoop集群环境搭建搭建大数据运行环境之一搭建大数据运行环境之二Hadoop集群端口说明Hadoop集群搭建过程异常情况不能格式化存储目录详细异常信息org.apac....

使用Flink集群环境进行数据处理(上)
文章 2022-04-30 来自:开发者社区

搭建Flink集群环境

下载最新的Flink安装包https://www.apache.org/dyn/closer.lua/flink/flink-1.12.1/flink-1.12.1-bin-scala_2.11.tgz好用的下载工具速度快的没得说 你可以对付费的迅雷说拜拜了motrix下载地址https://motrix.app/Free Download Manager下载地址https://dn3.free....

搭建Flink集群环境
问答 2021-01-24 来自:开发者社区

flink on k8s 集群环境 checkpoint 保存位置怎么做?#Flink

flink on k8s 集群环境 checkpoint 保存位置怎么做?#Flink

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

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