logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink 异常记录

1:java.lang.NoSuchMethodError: scala.Product.initinitinit(Lscala/Product;)V设置对应的scala版本解答:jar包引用和运行时的scala版本不同,如果在开发过程遇到修改了环境配置还有这个问题,应该关闭所有idea窗口再打开才能生效。...

#flink
flink基础知识之window的灵活计算--aggregate

flink基础知识之window的灵活计算–aggregate在前面的博客里,我讲过window的Trigger,它是窗口的触发器可以灵活的控制窗口的关闭,今天我要介绍window的灵活计算,windos的aggregate方法。AggregateFunction内置有四个方法:createAccumulator()我的理解是定义一个用于累加的容器add()add()是一个很重要的方法,有两个参数

关于我在Hadoop3.2.1集群安装hive3.1.2的过程记录

背景前提已经安装好了hadoop3.2.1集群,但是没有安装hive,hadoop3.2.1是比较新的版本,在网上有不少hadoop3.2.x版本安装hive3.1.2所以我认为,这两个版本应该是兼容的,整体安装是比较简单的,但还是遇到一些问题,所以记录一下安装hive下载地址:http://archive.apache.org/dist/hive/hive-3.1.2/[root@slave1

#大数据#hadoop#hive
解决linux配置ssh免密登录遇到的异常:-bash: cd: /root/.ssh: Not a directory

解决异常:-bash: cd: /root/.ssh: Not a directory事件场景:搭建了一个kafka集群,现在做脚本启动集群,发现需要做免密登录,在正常的免密设置中一台机遇到了该问题,花了不少时间解决所以记录一下一:免密登录的设置步骤原理:执行ssh-keygen生成秘钥 id_rsa.pub,将产生的id_rsa.pub放到authorized_keys文件,authorized

#linux#ssh#kafka
重启虚拟机异常:Unmount and run xfs_repair

重启虚拟机异常:Unmount and run xfs_repair解决办法:原因:看出来应该是sda3分区损坏,修复就可以了1:启动虚拟机E进入单用户模式2:在linux16开头的哪一行后面添加rd.break,ctrl+x进入救援模式3:执行umount /dev/sda3执行xfs_repair-L /dev/sda3如果没有成功尝试 xfs_repair-L /dev/sda2再执行3步骤

#linux
到底了