前沿技术知识_前沿技术学习笔记

前言 我们知道，DataStream 是flink流式数据处理中一个非常重要的数据结构，可以将DataStream转换成许多其他的数据类型，进....

一、ProcessFunction的使用 1、没有进行keyBy package cn._51doit.flink.day07;import org.apache.flink.api.java.tuple.Tup....

上期回顾 kafka producer同异步发送信息 我们的任务是:先上传在线图片到oss,然后获取图片路径推送到kafka中，上期我们分享了....

基于Spring Cloud Alibaba 分布式微服务高并发数据平台化(中台)思想+多租户saas设计的企业开发架构，支持源码二次开发、支持....

文|螳螂观察 作者| 青月 1月25日，Amazon也宣布收购Exactly Right Media播客网络旗下所有播客节目的独家广告销售权和分销权....

skywalking是一个开源的应用性能管理系统和可观测性分析平台 在被监视应用中插入探针，以无侵入式自动收集所需指标，并自动....

前言 在上一篇我们演示了如何使用Flink 的Table Api 读取文件数据，并过滤特定字段的数据，本篇在上一篇的基础上，将从CSV文....

采购管理软件SRM，重构企业采购流程，提供采购计划、供应商、招投标、比价、询价、合同管理、对账等一站式采购信息化解决方....

一、安装与配置 方法1：可以使用在线下载命令，下载安装包： 下载命令：​wget https://artifacts.elastic.co/downloads/e....

上期回顾 win10安装kafka kafka_2.13-2.8.1 实现想法 这一期我们实现kafka 生产数据 分别用同步和异步的方式将数据推送到kaf....

目录 主题及指标开发 一、主题开发业务流程 二、离线模块初始化 1、创建包结构 2、​​​​​​​创建时间处理工具 3、​​....

写在前面：        本文章作为一次实践的记录，可作为经验参考，只记录了大的步骤，及一些问题的解决方案。涉及到的容器....

rd_kafka_consume(m_rkt, iPartition, 100);这个函数，小概率触发超时不起作用 rdkafka_queue.c   函数rd_kafka_q_pop_s....

问题：虚拟集群搭建，hadoop别名无法打开网页hdfs界面 1，已确认防火墙关闭，输入虚拟机IP地址可以打开hdfs页面 2，查看虚....

一、安装kafka 下载kafka两种方式 （1）、手动下载 下载地址：Apache Kafka （2）、也可以用命令下载（直接下载到服务器哦！....

1、环境信息：CentOS版本 （1）CentOS-7-x86_64-Minimal-1810 下载地址：https://pan.baidu.com/s/1Hu6dMOTXQYK8ULEBcATZzw ....

Caused by: org.apache.flink.yarn.YarnClusterDescriptor$YarnDeploymentException: The YARN application unexpectedly switch

最近刚学Spark，碰见个小问题，在运行start-all.sh和start-history-server.sh后，jps里没有出现master和worker 配置文件如下....

随着云计算，大数据以及以太网的快速发展，运营商将数据中心升级到更高的数据速率，这也进一步增加了对100G 的需求，格局也....

elasticsearch 8.1 的分词器 elasticsearch-analysis-ik-8.1.0 发布   下载地址：https://github.com/medcl/elasticsearc....