logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink- AsyncDataStream 异步处理

1、AsyncDataStream有2个方法:unorderedWait表示数据不需要关注顺序,处理完立即发送,orderedWait表示数据需要关注顺序,为了实现该目标,操作算子会在该结果记录之前的记录为发送之前缓存该记录。这往往会引入额外的延迟和一些Checkpoint负载,因为相比于无序模式结果记录会保存在Checkpoint状态内部较长的时间。...

#flink#大数据#big data
linux_直接在linux里面替换jar包里的某个文件

以jar包中的RunZCS.class为例原代码:修改后的代码:linux相应目录下:zcsfastDFSTest-0.0.1-SNAPSHOT.jar步骤如下:如果要替换的文件在jar包的二级及以下目录下,则需要以下步骤:(1)使用jar tvf jar名称 | grep 目标文件名 查询出目标文件在war包中的目录(2)使用jar xvf jar名...

#linux
docker—— 报错Cannot connect to the Docker daemon at unix:///var/run/docker.sock. Is the docker daemon

解决:执行如下命令将当前用户加入docker用户组:sudo gpasswd -a ${USER} docker然后重启dockersystemctl restart docker

#docker
fastDFS中的storage服务端口启动不起来

storage 服务不正常关闭就会出现如下错误:重启后,端口23000没有开启。1、解决问题的突破口查看tracker 服务上的运行日志trackerd.log ,发现:tail -f -n 100 trackerd.log查看后发现其他的storage的23000端口是可以连接的,XXXXXX.13没有出现 使用 lsof -i:23000查看状态,发现23000端口...

Word2003ToHtml——Your file appears not to be a valid OLE2 document

错误提示:org.apache.poi.poifs.filesystem.NotOLE2FileException: Invalid header signature; read 0x7265762D454D494D, expected 0xE11AB1A1E011CFD0 - Your file appears not to be a valid OLE2 document问题原因:(此错误提示

#java
kafka生产报错couldn‘t resolve server 9092 from bootstrap.servers as DNS

报错:couldn't resolve server 9092 from bootstrap.servers as DNS我的环境:kafka配置的是ip连接的配置:ymlkafkaduceconfig:servers: node11:9092修改后:kafkaduceconfig:servers: IP:9092分析:因为hosts配置没有问题,可能是配置kafka的时候写的是ip地址,在代码访

#kafka#bootstrap#分布式
flink on yarn ——报错:Deployment took more than 60 seconds. Please check if the requested resources are

报错描述,看着似乎是资源不够使用。Deployment took more than 60 seconds. Please check if the requested resources are available in the YARN cluster解决方案:配置yarn-site.xml<property><name>yarn.scheduler.minimum-a

#flink#大数据#big data
到底了