在原来的jenkins基础之上，已打补丁的方式进行升级，升级有可能涉及jdk版本的变更。升级以后的jenkins，所有配置与原来一样，只是在版本上做了更新。

在做ETL开发的时候，如果针对每一个字段的处理逻辑基本相同，需要处理的字段和模型又特别多。在这种情况下我们可以通过此ETL生成器，批量生成标准的ETL。

根据以上可能性逐一排查，通常问题出在规则生效前文件已被追踪或规则书写不正确。调整后记得重新提交更改以确保忽略规则生效。

文章目录概述kafka时间戳的作用kafka 参数关于从ConsumerRecord获取时间戳为-1的说明概述Kafka从0.10.0.0版本起，在消息内新增加了个timestamp字段，在Kafka 0.10.1.0以前(不包含0.10.1.0)，对于一个Topic而言，其Log Segment是由一个.log文档和一个.index文档组合而成，分别用来存储具体的消息数据和对应的偏移量从Kafk

即席查询调研报告什么是即席查询即席查询（Ad Hoc）是用户根据自己的需求，灵活的选择查询条件，系统能够根据用户的选择生成相应的统计报表。即席查询与普通应用查询最大的不同是普通的应用查询是定制开发的，而即席查询是指那些用户在使用系统时，根据自己当时的需求自定义的查询。测试组件介绍Apache Doris是一个现代化的MPP分析型数据库产品。仅需亚秒级响应时间即可获得查询结果，有效地支持实时数据分析

文章目录测试&思考：java多线程同时写一个文件第一种情况是：一个线程A有对文件加锁，另一个线程B没对文件加锁在windows7环境下：(持有锁的可以写文件成功)。在linux centos 6.3环境下:(都可以写文件成功)第二种情况两个线程都有加锁在windows7环境和linux centos 6.3环境下表现一样：（持有锁的可以写文件成功）多进程同时写一个文件如果同为java进程，

文章目录特别说明listenersadvertised.listeners介绍区别什么场景用到只有内网内外网客户端连接kafka集群流程特别说明kafka 0.9.x以后的版本新增了advertised.listeners配置kafka 0.9.x以后的版本不要使用 advertised.host.name 和 advertised.host.port 已经deprecatedhost.n...

superset简单易用，可以对接 mysql、presto、doris、postgresql、ClickHouse、sparkSQL、hive、oracle、sqlserver、Elasticsearch等多种数据源，官网安装部署：docker run -d -p "8088:8088" --name superset amancevice/superset初始化superset并设置管理员账号

Dockerfile构建镜像NOTE： 需要镜像上传到docker镜像私服（或者在每个node节点都构建相同的镜像），并保证所有k8s node节点都有权限链接到此私服。登录本地镜像仓库重新打标签推送镜像测试镜像可用性创建configmap创建jobmanager创建taskmanager创建jobmanager service创建namespace设置命名空间首选项创建 Flink 集群查看服务

flink版本flink1.15.0。k8s部署（minkube简单快速部署k8s）：https://minikube.sigs.k8s.io/docs/start/如果使用 MiniKube，请确保在部署 Flink 集群之前先执行 minikube ssh ‘sudo ip link set docker0 promisc on’，否则 Flink 组件不能自动地将自己映射到 Kubernet