首页
学习
活动
专区
工具
TVP
发布

Catorory

专栏成员
14
文章
21384
阅读量
15
订阅数
Flink实时写入StarRocks NullPointerException问题解决
最近出现很多任务经常跑着跑着就failed了,也不怎么重启,翻了下异常信息如下,大概意思就是进行stream load的时候失败了,然后回滚了下,然后就空指针了
用户6404053
2023-05-22
8370
DataX导入ES报错Limit of total fields [1000] in index
公司有一个场景是每天需要批量导入大量数据到es中(我们用的是datax),并且字段是动态mapping的,字段越来越多之后终于遇到了这个报错。
用户6404053
2023-05-20
1.3K0
通过Github Actions自动化Docker镜像打包和上传
可以了解到docker构建多架构镜像相关的信息和Github Actions的使用
用户6404053
2023-05-17
2.7K0
HBase JAVA API的scan使用小记
HBase是一个很流行kv数据库,特点是集群化,可水平扩容,基于lsm tree,写入非常快,集群化之后查询性能也不错,成本低,非常适合QPS要求不是特别高,但写入量很大的场景。
用户6404053
2023-05-10
9000
某云平台Flink日志按Job名称收集到ES
使用ES来查询业务日志在开发中是非常常见的一种方式,典型的解决方案是ELK,已经非常成熟了。Flink是一个比较年轻的开源项目,已经发展了好几年,但是周边的生态还是不是很完善,比如日志收集其实不太友好,比如session模式想要按job收集日志就做不到,另外比较流行的是yarn和k8s模式,k8s理论上应该是比较容易收日志的,越来越多的公司大量java应用都跑在k8s里。日志收集这块也限制只能用商业产品,不好用。我们希望接到es里
用户6404053
2023-05-08
3770
使用FileBeat收集StarRocks日志
生产环境中使用StarRocks一般都是多节点,3个fe3个be已经是很小的规模了,出现问题需要查日志的话,6个节点上找日志是比较费劲的,我们希望能够将日志都收集到es,查找方便而且支持搜索,提升排查问题的效率。
用户6404053
2023-04-29
9630
Github fork的项目如何和原项目同步更新
使用过github的小伙伴都知道fork的功能,但是fork是一个一次性的事情,相当于做了一个快照,如果fork后原项目有更新的话,我们fork后的项目是不会同步更新的,想要保持同步可以按下面的步骤操作
用户6404053
2023-04-26
3.6K0
冒泡排序
原理:比较两个相邻元素,值大的交换到右边, 时间复杂度O(n2),空间复杂度O(1) public class BubbleSort{ public static void main(String[] args){ int[] arr = {6,4,2,5,7,9,1}; for(int i = 0; i < arr.length - 1; i++){ for(int j = 0; j < arr.length - 1 - i;j++){
用户6404053
2019-11-05
7470
Java8中的接口和抽象类的区别
今天跑了好远去面试,面试官问了上面这个问题,我是一脸懵比,抽象类我自己没写过,JAVA8对接口有什么修改完全没印象,现在来总结一下,至少下次再遇到这个问题要答上来。
用户6404053
2019-11-05
8690
spark 多表 join
1.Broadcast Hash Join(小表广播,小表Join大表)(分布式改造)
用户6404053
2019-11-03
3.3K0
spark Pi && word count计算
2.随机向正方形内随机找n个点,计算每一个点到圆心的距离,小于1的就是圆内的点,假设数量是count
用户6404053
2019-11-03
7690
Kafka Exactly Once实现原理
  上面3种EOS语义有着不同的应用范围,幂等producr只能保证单分区上无重复消息;事务可以保证多分区写入消息的完整性;而流处理EOS保证的是端到端(E2E)消息处理的EOS。用户在使用过程中需要根据自己的需求选择不同的EOS。以下是启用方法:
用户6404053
2019-10-30
4.1K0
快速排序
核心是partition,然后递归 image.png import java.util.*; public class QuickSort { // 我们的算法类不允许产生任何实例 private QuickSort(){} // 对arr[l...r]部分进行partition操作 // 返回p, 使得arr[l...p-1] < arr[p] ; arr[p+1...r] > arr[p] private static int partition(Comp
用户6404053
2019-10-06
2780
归并排序
复制一个同样的数组aux,3个索引,蓝色剪头为最终的数组中需要跟踪的索引位置,两个红色剪头是已经分别排序好的两个数组当前要考虑的元素
用户6404053
2019-10-06
6550
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档