Johnson Lin

在使用 Elasticsearch 的过程中，经常会有删除某个索引历史数据的需求。比如存储飞机票信息的索引，通常只需要保留今日及今日之后的机票信息。为提升索引的效率和防止索引过大，同时尽量避免删除过程中影响线上环境稳定性，一般会选在业务低峰期的时候删除历史数据。 如以下 DSL 通过调用 _delete_by_query 方法删除 flight_v20220107 索引中日期（dt）在 20220729 ~ 20220802 之间的机票信息数据： 123456789101112131415POST /flight_v20220107/_delete_by_query?size=1000000&conflicts=proceed{ "query": { "bool": { "filter": { "range": { "dt": { ...

概述当在 Java 项目中使用 Gson 库处理 JSON 时，我们可以将原始 JSON 字符串转换成更容易使用的类对象或数据结构。如将 JSON 字符串转换为 **Map<String, Object>** 对象，或者其他自定义类型的对象。但有些时候将 JSON 字符串转换为通用对象会更方便使用。 本文将演示如何使用 Gson 将 JSON 字符串转为 **JsonObject** 对象。 配置Maven依赖首先，在 pom.xml 文件中配置 gson 依赖项： 12345<dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.9.1</version></dependency> gson 版本根据实际情况进行选择，建议使用最新版本（见 Maven Central ）。 本文使用的是 2.9.1 版本（当前最新版本）。...

如何查看 Ambari 版本？ 打开 Ambari web 界面（默认端口：8080，如 http://ambari:8080/#/login ），成功登录之后，点击右上角用户名，在下拉框中点击 About，即可查看当前 Ambari 的版本。 具体如下图所示：

本文根据实际项目经验，详细描述 MySQL 慢查询问题的发现及排查解决过程。在不影响读者阅读理解的前提下，对部分原始数据进行脱敏处理。 背景生产环境 MySQL 硬件配置：32C/64G/2T ESSD MySQL 版本：5.7.28 存储数据主要来源：主要是 Flink 实时计算的指标，少部分 Presto 准实时计算的指标，同时还有部分离线数仓模型也会每天同步一份至该 MySQL，用于加速客户端查询和提升并发查询能力。 发现问题之前收到运维的反馈，生产环境上用于存放 Flink 实时计算指标的 MySQL 有告警——每分钟慢查询数超过告警阈值，需及时跟进。当时通过 MySQL 监控面板查看到部分关键指标如下： 慢查询数 QPS TPS 网络流量（流入、流出） 表锁 慢日志明细部分 SQL（当时只拉取一小部分的慢 SQL，以下这些语句是 Flink SQL 写入 MySQL 的） 12345678910111213141516# Time: 2022-07-28T01:16:52.760142Z# User@Host: bigdata[bigdata] @ ...

密封类(Sealed Classes)通过在类定义前面放置关键字 sealed，可以将类声明为密封类。同时使用关键字 permits 来限制哪些类可以继承或实现该密封类。在下面的示例中，声明了密封类 BasePosition，并且只允许类 PointGuard 和类 ShootingGuard 可以继承该密封类。 123public sealed class BasePosition permits PointGuard, ShootingGuard { // Class members here.} 关键字 sealed 除了可以修饰类外，还可以用来修饰接口，只允许哪些类可以实现该接口。例如： 123public sealed interface UserService permits UserServiceImpl { // Some methods here.} 如果定义的密封类继承了父类，或实现了其他接口，那么关键字 permits 需要放在关键字 extends、implements 的后面。在下面的示例中，密封类...