- 博客(55)
- 资源 (3)
- 收藏
- 关注
RSS订阅原创 Flink文章汇总
Flink文章汇总_电光闪烁的博客-CSDN博客Flink文章汇总1、Flink基础知识点博文汇总2、https://blog.csdn.net/yang_shibiao/article/details/122570051
2022-04-08 15:42:52
1326
转载 Flink事件时间处理和水印
Flink事件时间处理和水印_泽米的博客-CSDN博客_flink 水印最近找到这个对事件时间处理和水印说的比较好的文章，所以转载一下，供大家分享，原文连接：Flink Event Time Processing and Watermarks本文用途纯粹是为了分享，如若有侵权，请与我联系~下面是原文：如果您正在构建实时流媒体应用程序，则事件时间处理是您必须迟早使用的功能之一。由于在大多数现实世界的用例中，消息到达无序，应该有一些方法，您建立的系统了解消息可能迟到并且相应地处理的事实。在这篇博文中
2022-03-25 16:21:19
416
原创 canal
1. 查看当前mysql是否开启binlog模式，ON是已开启。SHOW VARIABLES LIKE '%log_bin%';2. 如果log_bin的值为OFF是未开启。修改/etc/my.cnf 需要开启binlog模式。修改完成之后，重启mysqld的服务。#添加#二进制日志存储路径log-bin=/var/lib/mysql/mysql-bin#server_id 不能与canal配置文件中的canal_id冲突server_id=12343. 创建 canal .
2022-03-21 15:23:12
494
原创 kafka设置过期时间
消息的过期时间我们在使用Kafka存储消息时，如果已经消费过了，再永久存储是一种资源的浪费，所有，kafka为我们提供了消息文件的过期策略，可以通过配置server.properies来实现# vi config/server.properies修改下面的代码log.roll.hours=1log.retention.hours=2log.segment.delete.delay.ms=0重启kafka服务即可，上面表示消息存储时间为２小时。设置单个topic的过期时间：clean
2022-03-02 11:09:05
4098
原创 大list拆分多个小的list
两种方式拆分：第一种： 拆分成固定个数的list/** * 将一个list均分成n个list,主要通过偏移量来实现的 * @param source * @return */ public static <T> List<List<T>> averageAssign(List<T> source,int n){ List<List<T>> result=new Arra...
2021-11-02 10:22:58
2559
原创 oracle数据库解锁
异常：ora-00054:resource busy and acquire with nowait specified 是因为有事务正在执行（或者事务已经被锁），所有导致执行不成功。 解决方法如下： 1、用dba权限的用户查看数据库都有哪些锁 SELECT T2.USERNAME,T2.SID,T2.SERIAL#,T2.LOGON_TIME FROM V$LOCKED_OBJECT T1,V$SESSION T2 ...
2021-10-29 09:38:44
120
原创 Flink学习之 - map与flatMap
import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.common.functions.MapFunction;import org.apache.flink.api.common.functions.RichMapFunction..
2021-10-27 20:28:09
905
原创 Postman操作Elasticsearch 7.6 API
1.创建索引{ "settings":{ "index":{ "number_of_shards":5, "number_of_replicas":1 }, "analysis":{ "filter":{ "my_filter":{ "type":"stop", "stopwords":""
2021-09-26 18:41:37
131
转载 Docker安装Elasticsearch7.6.1、elasticsearch-head
安装elasticsearch拉取镜像docker pull elasticsearch:7.6.1运行容器运行命令创建启动容器：docker run -d --name es -p 9200:9200 -p 9300:9300 \-e "discovery.type=single-node" elasticsearch:7.6.1discovery.type=single-node：单机学习直接添加该参数，表示单节点运行，避免启动的时候es的引导检查会报错将配置文件、数
2021-09-26 15:28:26
252
转载 kibana开发工具简单使用
GET opt_log/_mappingGET opt_log/_search{ "query": { "match_all": {} }}GET opt_log/_search{ "query": { "match": { "userCode": "888888" } }}PUT操作向elasticsearch插入引索或文档//插入一个文档，字段自动识别类型PUT /test1/type1/5{ "name...
2021-09-24 10:33:03
744
原创 按分区读取hdfs文件，解析输入字段信息
<properties> <maven.compiler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target></properties><dependencies> <dependency> <groupId>org.apache.ha.
2021-09-16 09:21:51
195
转载 DataStream之Sink简介及RichSinkFunction
来源：https://blog.csdn.net/zhuzuwei/article/details/1071424941. 安装ncyum -y install nmap-ncat2. 启动（8888是端口号）nc -lk 8888import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.java.tuple.Tuple2;import org.apache.fl.
2021-08-05 15:25:57
660
原创 java多线程处理
import com.alibaba.fastjson.JSONObject;import com.yl.platform.api.dto.RequestDTO;import org.springframework.util.DigestUtils;import java.util.*;import java.util.concurrent.CopyOnWriteArrayList;import java.util.concurrent.ExecutorService;import java.
2021-08-04 20:26:35
131
原创 解决连接Doris异常：Unknown System variable ‘performance_schema‘
mysql-connector-java的版本由8.0.22降到8.0.11后成功解决。
2021-07-16 15:30:07
938
转载 spring boot 中配置文件加密
来源：https://blog.csdn.net/leejiliang/article/details/93172070为了避免在配置文件直接明文写敏感信息, 使用加密可以解决尴尬pom文件添加依赖 <dependency> <groupId>com.github.ulisesbocchio</groupId> <artifactId>jasypt-spring-boot-starter&...
2021-07-16 10:52:21
175
转载 【sping-boot】druid 连接池配置多个数据源
读目录背景 目录结构 修改配置 演示效果 代码地址回到顶部背景如何使用druid 连接池配置多个数据源参考文档：https://www.cnblogs.com/qdhxhz/p/10192041.html回到顶部目录结构为了更好的区分，我把不同的数据库，新建在不同的目录下面先看目录结构：回到顶部修改配置pom.xml <dependency> <groupId>org.mybat
2021-06-19 15:09:42
1053
转载 Docker安装ElasticSearch-Head完毕后,创建索引报错406,解决方法
首先,我是根据这篇博客安装的Docker安装ElasticSearch但是安装完毕以后创建索引无响应,F12查看发现406错误,原来是请求头的问题,所以要修改head的 Content-Type 设置.一.进入容器(b93fa4e29ba2为容器ID,请改成自己的)[root@localhost ~]# docker exec -it b93fa4e29ba2 /bin/bash1二.安装vim命令在使用docker容器时，有可能没有安装Vim, 安装Vim:apt-get install.
2021-06-17 19:34:08
662
转载 如何从外网访问本地服务器
如何从外网访问本地服务器原文链接：https://blog.csdn.net/qq_36135231/article/details/804725311.首先到ngrok官网https://ngrok.com/download下载相应软件2.解压缩右键 以管理员身份运行3.输入 ngrok.exe http 80注意：这里的 80 得根据实际你tomcat的端口改写，假设你的tomcat端口用的是81端口，这里就要改成 81 ！！！4.接着我们就可以用 https:.
2021-06-13 12:35:39
405
转载 在本地Windows系统下搭建Apollo配置中心
1.下载网盘下载地址：链接: https://pan.baidu.com/s/1LqmuFUEWeWKkn2aYd-fqnA 提取码:tyuk下载完毕后解压文件，可以看下目录结构这里的sql目录文件里面放入了两个sql执行语句的sql文件，我们可以去本地数据库新建两个数据库取名为：ApolloPortalDB和ApolloConfigDB然后导入sql文件。我们可以打开demo.sh查看配置这里的文件是配置数据库连接地址配置，我们可以按照自己的mysql账号...
2021-06-08 13:58:21
428
转载 Docker 安装 Jenkins （超详细）
来源：https://segon.cn/install-jenkins-using-docker.html详细介绍如何通过 Docker 安装 Jenkins 。安装环境CentOS 7.6Docker 18.09.6拉取镜像我这里安装的版本是2.222.3-centos，可以去这里获取你需要的版本:https://hub.docker.com/_/jenkins?tab=tags 1 # docker pull jenkins/jenkin.
2021-06-06 19:38:24
344
原创 nginx
一、启动 cd usr/local/nginx/sbin ./nginx二、重启 更改配置重启nginx kill -HUP 主进程号或进程号文件路径或者使用cd /usr/local/nginx/sbin./nginx -s reload 判断配置文件是否正确 nginx -t -c /usr/local/nginx/conf/nginx.conf或者cd /usr/local/nginx/sbin./nginx -t关闭nginx：nginx..
2021-06-06 17:34:56
31
原创 minio设置永久访问链接
wget https://dl.min.io/client/mc/release/linux-amd64/mc //下载minio clientchmod a+x mc//添加minio server./mc config host add minio http://139.159.xx.xx:9000/ admin admin123456//设置需要开放下载的bucket, 注意需要带minio./mc policy set download minio/video ...
2021-06-06 12:59:15
3021
转载 Java时间戳与日期格式字符串的互转
import java.text.SimpleDateFormat;import java.util.Date;public class DateUtil { /** * 时间戳转换成日期格式字符串 * @param seconds 精确到秒的字符串 * @param formatStr * @return */ public static String timeStamp2Date(String seconds,Stri...
2021-06-04 15:43:36
245
转载 SpringBoot整合ES
作者：@后青春期的Keats本文为作者原创，转载请注明出处：https://www.cnblogs.com/keatsCoder/p/11341835.htmlSpringBoot整合ES Java API操作ES SpringBoot整合ES创建SpringBoot项目，导入 ES 6.2.1 的 RestClient 依赖和 ES 依赖。在项目中直接引用 es-starter 的话会报容器初始化异常错误，导致项目无法启动。如果有读者解决了这个问题，欢迎留言交流<!--
2021-06-03 11:17:16
394
原创 接口设计token+sign
接口设计：token+sign1. 申请userId,password,secretKey, 由客户端保管2. 获取token{ "userId":"test", "password": MD5("123456"), "reqId": "f322113333", "sign":MD5(userId=test&reqId=v1&secretKey=v2)}服务端生成token,...
2021-05-31 15:26:57
204
转载 API接口设计之token、timestamp、sign具体实现
API接口设计之token、timestamp、sign具体实现内容来源于：https://www.cnblogs.com/red-fox/p/12698599.html一、token 简介Token：访问令牌access token, 用于接口中, 用于标识接口调用者的身份、凭证，减少用户名和密码的传输次数。一般情况下客户端(接口调用方)需要先向服务器端申请一个接口调用的账号，服务器会给出一个appId和一个key, key用于参数签名使用，注意key保存到客户端，需要做一些安全处理，防止泄露
2021-05-31 15:08:08
2012
原创 docker 安装showdoc
docker pull star7th/showdoc#新建存放showdoc数据的目录mkdir -p /showdoc_data/htmlchmod -R 777 /showdoc_data#启动showdoc容器docker run -d --name showdoc --user=root --privileged=true -p 4999:80 \-v /showdoc_data/html:/var/www/html/ star7th/showdochttp://loca...
2021-05-30 15:19:14
179
转载 SpringBoot 整合 Nacos Config 实现配置文件动态更新
原文地址：https://cloud.tencent.com/developer/article/1642798SpringBoot 整合 Nacos Config 实现配置文件动态更新2020-06-11阅读1.5K0前提条件安装好 nacos, 初始化 SpringBoot 项目nacos 官方地址：https://nacos.io/zh-cn/使用版本Springboot 2.2.2.RELEASE Nacos config 0.2.7导入 Nacos 依赖 .
2021-05-25 11:55:42
1211
原创 nacos配置中心无法动态刷新
public static void main(String[] args) throws InterruptedException{ ConfigurableApplicationContext applicationContext = SpringApplication.run(StartApplication.class, args); while(true){ ConfigurableEnvironment environment = applicationConte...
2021-05-25 11:52:20
1283
1
原创 Guava Cache使用
<dependency> <groupId>com.google.guava</groupId> <artifactId>guava</artifactId> <version>29.0-jre</version> </dependency>public static void main(String[] args) { Cache<String, LogDTO&g...
2021-05-20 14:49:38
187
转载 Docker安装Minio存储服务器详解
1、 前言1.1 Minio 简介1、MinIO 是在 Apache License v2.0 下发布的对象存储服务器。 它与 Amazon S3 云存储服务兼容。 它最适合存储非结构化数据，如照片，视频，日志文件，备份和容器/ VM 映像。 对象的大小可以从几 KB 到最大 5TB。 2、MinIO 服务器足够轻，可以与应用程序堆栈捆绑在一起，类似于 NodeJS，Redis 和 MySQL 3 一种高性能的分布式对象存储服务器，用于大型数据基础设施。它是机器学习和其他大数据工作负载下Hado
2021-05-15 11:50:08
359
转载 比Xshel更好用的 FinalShell
FinalShell功能特点：1.多平台支持Windows,Mac OS X,Linux2.多标签,批量服务器管理.3.支持登录Ssh和Windows远程桌面.4.漂亮的平滑字体显示,内置100多个配色方案.5.shell,sftp同屏显示,同步切换目录.6.命令自动提示,智能匹配,输入更快捷,方便.7.sftp支持,通过各种优化技术,加载更快,切换,打开目录无需等待.8.服务器网络,性能实时监控,无需安装服务器插件.9.内置海外服务器加速,加速远程桌面和ssh连接,操作流畅无卡顿.
2021-05-06 20:29:24
103
原创 CentOS7安装k8s
安装:https://www.cnblogs.com/spll/p/10033316.html 原图的博客地址：https://blog.csdn.net/zyc88888/article/details/79281954
2021-05-06 20:25:43
48
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人