问题描述 在机器上执行/usr/sbin/kadmin.local时卡住，通过 systemctl重启kadmin、kdc server也都会因为超时启动失败。 问题处理 使...
发简信
IP属地：湖北
问题描述 在机器上执行/usr/sbin/kadmin.local时卡住，通过 systemctl重启kadmin、kdc server也都会因为超时启动失败。 问题处理 使...
动机 最近需要将流程的耗时接入可观测系统，方便后续优化性能。为了统一技术栈，决定使用prometheus来接入。特别的是，我需要使用自定义的时间戳，由于PushGateway...
版本与环境信息 组件版本hbase2.3.5hadoop3.2.2HADOOP_HOME/usr/local/service/hadoopHBASE_HOME/usr/loc...
背景 一客户反映，通过控制台启动hiveserver2一直卡住，但是在机器上查看进程已经启动 排查过程 在客户的机器上，会启动一个agent，用来从server端获取指令并执...
ISSUE https://issues.apache.org/jira/browse/HIVE-18920[https://issues.apache.org/jira/b...
函数 在go中，既可以在包中定义函数，也可以定义结构体的函数，对于后者，函数接收者(结构体对象)是它的第一个参数。他们都会在运行时被构造成funcval对象，而闭包就是含有捕...
[toc] 1. string的底层结构 图最清楚了，对于一个string类型的变量，在64位系统中，占用内存大小为16个字节，分别是内存起始地址8个字节，长度8个字节 2....
1. 涉及组件 FlinkKafkaConsumer是用户使用Kafka作为Source进行编程的入口，它有一个核心组件KafkaFetcher，用来消费kafka中的数据，...
版本：1.11当是EventTime类的应用时，Watermark才有意义（IngestTime也可以生成WaterMark，很少用），它是一个时间，表示后来的数据的Even...
前置知识： 前置知识1：Actor的创建 Props代表的是一个不可变的配置类，创建Actor时，必须要用到；它由两部分构成 创建的Actor类：akkaRpcActorTy...
用来对原方法进行增强，类结构如下： 例子 InvocationHandler 实现类 target接口 target实现 生成代理 读者可以根据堆栈图自己debug下生成的逻...
根据其实现的接口可知，它有两个特点: Future，表示异步执行的结果CompletionStage，表示整个异步计算的一个阶段，它能被其它的stage触发，也能触发其它的s...
背景 yarn默认使用的是最简单的FIFO调度器，即一个default队列，所有用户共享，分配资源也是先到先得，没有优先级之分。有时一两个任务就把资源全占了，其他任务吃不到资...
前言 1 Flink基础（适合初入职场） 简单介绍一下 Flink Flink相比传统的Spark Streaming区别? Flink的组件栈有哪些？ Flink 的运行必...
本文仅为笔者平日学习记录之用，侵删原文：https://mp.weixin.qq.com/s/GuA9o09EEue66fEpGgoGaQ 本文是 Flink 源码解析系列，...
随着CPU的核数的增加，异步编程模型在并发领域中的得到了越来越多的应用，由于Scala是一门函数式语言，天然的支持异步编程模型，今天主要来看一下Java和Scala中的Fut...
Actor作为Akka中最核心的结构，其在Akka中的中的组织结构也至关重要，今天我们就来讲讲Akka中Actor系统。 Actor系统 Actor作为一种封装状态和行为的对...
