- 博客(24)
- 收藏
- 关注
RSS订阅原创 springboot post 请求参数过长请求接口报错 An HTTP line is larger than 4096 bytes
springboot项目，post请求参数过长到时后代套错
2022-09-15 14:13:58
1872
原创 java SimpleDateFormat类线程安全的问题
1、在程序中当我们把SimpleDateFormat作为全局变量，并且使用他的format方法时存在线程安全的问题。SimpleDateFormat 类中的calendar变量是全局变量，而且在format方法中调用了calendar.setTime(date);当两个线程同时来到此代码处就会存在后面的线程的赋值覆盖之前的线程赋值。如下图：calendar 是全局变量SimpleDateFormat类继承了DateFormat类，calendar变量是在DateForma..
2021-12-15 15:06:41
2331
原创 redis客户端Jedis实现redis连接池
1、引入jar包 <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>版本号</version> </dependency>2、代码实现 JedisPool
2021-12-15 10:25:02
593
原创 java ：给Java实体对象或泛型类属性赋值
1、需要依赖commons-beanutils包 <dependency> <groupId>commons-beanutils</groupId> <artifactId>commons-beanutils</artifactId> <version>1.9.3</version> </dependency&g
2021-12-14 09:42:50
2586
原创 flink taskmanager 挂掉 报错No pooled slot available and request to ResourceManager for new slot failed
1、解决办法：调大taskmanager.memory.process.size 参数的数值。2、导致此问题的原因： taskmanager.memory.process.size 数值太小 task任务内存溢出导致 taskManager 挂掉， taskmanager 挂掉导致提交的任务没有可用的slot，所以报No pooled slot available and request to ResourceManager ...
2021-11-19 16:38:56
3330
原创 flink1.12接受Kafka数据写入hive中，hive客户端不能查询数据
1、代码如下StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setRuntimeMode(RuntimeExecutionMode.STREAMING); env.getConfig().registerKryoType(BusEventKafka.class); //env.enableCheckpointing(10.
2021-11-18 12:01:48
1941
原创 docker命令大全（基本命令）
1、查看docker版本docker -v2、查看所以镜像列表docker imagesTAG：镜像的标签，镜像版本IMAGEID：镜像IDCREATED：镜像创建时间REPOSITORY：表示镜像的仓库3、搜索镜像docker search 镜像名称NAME: 镜像名称DESCRIPTION：镜像描述STARS: 用户的一些点赞、关注评价等，反应一个软件的受欢迎程度OFFICIAL：是否官方发布AUTOMATED：自动构建4、拉取镜像docker pull 镜像
2021-05-24 11:27:17
62
原创 二进制转换是十进制负数处理
二进制转换成十进制，最高位是符号位， 0表示正 1负数负数求值：反码 在加1如1111 1111 1001 0100的十进制实际值反码 0000 0000 0110 1011在加1实际值是108如图：
2021-04-29 16:50:12
1234
原创 jdk序列化和反序列化Java对象
1. jdk序列化Java对象User user = new User();ByteArrayOutputStream byteArr = new ByteArrayOutputStream();ObjectOutputStream objectOut = new ObjectOutputStream(byteArr);objectOut.writeObject(user);byte[] bytes = byteArr.toByteArray();2. jdk发序列化Java对象//byte
2021-04-28 14:26:15
106
原创 springboot项目中动态调用webservice接口
第一步：引入jar包 <!-- webservice远程调用 --> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxws</artifactId> <version>3.2.7</version> </dependency>
2021-03-10 09:06:26
892
原创 Mac 安装Navicat Premium 遇到的问题
下载Navicat Premium安装包，运行提示“以损毁或者无法打开”， 运行一下命令：sudo xattr -r -d com.apple.quarantine Navicat\ Premium.app/如何运行安装包提示“来自不受信用的开发者”， 请点击左上角苹果logo，选择系统偏好设置—安全性与隐私—通用—允许从以下位置下载的应用”选择“任何来源”即可...
2021-02-05 16:04:49
636
原创 git 提交分支报错（不能提交分支）
git 提交新分支报错，报错信息如下：Compressing objects: 100% (100/100), done.Writing objects: 100% (229/229), 25.18 KiB | 3.15 MiB/s, done.Total 229 (delta 108), reused 147 (delta 61)remote: Resolving deltas: 100% (108/108)error: remote unpack failed: error Missing
2021-02-05 15:42:15
1329
原创 influxdb 批量插入数据只成功一条的问题
代码功能：新增五条student数据到influxdb数据库中问题：每次运行代码都是新增一条记录代码如下：public static void main(String[] args) { BatchPoints batchPoints = BatchPoints .database("cjj_test") .consistency(InfluxDB.ConsistencyLevel.ALL) .build(); fo.
2020-07-24 16:39:06
1859
原创 flink table转换DataStream报错 (toAppendStream和toRetractStream区别)
代码实现功能： 统计单词个数代码如下： public static void main(String[] args) throws Exception { String path = "D:\\cjj\\cjj.txt"; StreamExecutionEnvironment fbEnv = StreamExecutionEnvironment.getExecutionEnvironment(); StreamTableEnvironment fbTa.
2020-07-21 13:35:12
2826
原创 kafka java客户端获取topic列表
需要加入的依赖jar包<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.11</artifactId></dependency>代码如下：public static void main(String[] args) throws InterruptedException, ExecutionException { Propertie
2020-07-16 17:39:34
4613
原创 flink1.10: this type (GenericType「pojo) cannot be used as key.异常处理
flink1.10 异常 this type (GenericType<pojo) cannot be used as key.实现功能： 统计单词个数代码如下：public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setP
2020-07-03 15:59:05
2121
2
原创 maven 命令(打包、安装、发布)
1、清理项目清理项目，清楚target目录下编译的内容mvn clean 2、安装项目将项目安装到本地仓库mvn install3、项目打包安装将项目打包并且将打包好的项目放到target目录下mvn package4、将项目发布到远程仓库nexus注意：需要在maven中配置远程仓库的路径和账号和密码mvn deploy5、将本地jar包发布到远程仓库mvn deploy:deploy-file -DgroupId=jar包groupId -DartifactId=jar
2020-07-02 17:31:25
918
原创 linux 防火墙设置
linux有两种防火墙iptables和firewall,centos 7以上版本用firewall, 7以下用iptablesfirewall 防火墙1.启动防火墙systemctl start firewalld2.临时关闭防火强（重启后失效）systemctl stop firewalld3.查看防火墙状态systenctl status firewalld4.永久关闭防火墙（开机后不能自动启动）systemctl disable firewalld5.添加80端口（–
2020-07-02 15:29:49
171
原创 flink transformation聚合算子（reduce，max和maxby等）
1、Reduce 通过reduce可以实现average, sum, min, max, count 等功能 ,reduce第一个参数以reduce操作结果， 第二个参数是当前元素。reduce每传入一个元素生成一个新的元素下面例子的功能：统计相同名称昌平价格总和StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setParallelism(1);
2020-07-02 13:51:38
1067
原创 kafka常用命令
1.后台启动kafka服务nohup kafka-server-start.sh ${kafkahome}/config/server.properties >${kafkahome}/log/log.log &2.查看topic名kafka-topics.sh --list --zookeeper zkip1:zkport1,zkip2:zkport2,zkip3:zkport33.创建topic名kafka-topics.sh --create --zookeeper
2020-06-17 15:35:32
105
空空如也
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人