Commit Graph

249 Commits

Author SHA1 Message Date
43a1bcdb4b feat(exexutor-task): 增加日志输出 2024-03-05 15:16:50 +08:00
390a2dd550 chore(test): 杂项 2024-03-05 15:16:50 +08:00
eb70986d19 refactor(web): 移除调度时间点展示 2024-03-05 15:16:50 +08:00
2b829519d1 feat(web): 增加调度时间点展示 2024-03-05 15:16:50 +08:00
26e65f2a81 feat(cli): 清理旧脚本 2024-03-05 15:16:50 +08:00
616eb1e514 feat(queue): 迁移queue到hudi service项目中 2024-03-05 15:16:50 +08:00
f5b1845d97 feat(gateway): 迁移gateway到hudi service项目中 2024-03-05 15:16:50 +08:00
783c05f6da fix(web): 修复running_status接口由于多线程导致数组越界 2024-03-05 15:16:50 +08:00
c6e0a681bc refactor(pulsar-query): 更新pulsar部署信息 2024-03-05 15:16:50 +08:00
5ac76062c4 feat(web): 给没有在运行的flink任务查询任务名称 2024-03-05 15:16:50 +08:00
820c8438b1 feat(web): overview增加同步任务状态展示 2024-03-05 15:16:50 +08:00
59dd3b29f4 refactor(web): 优化查询条件输入框,有的地方不需要联动查询 2024-03-05 15:16:50 +08:00
d04bf22f8a feat(web): 拆分页面功能,区分基础和高级 2024-03-05 15:16:50 +08:00
f58b803cd0 fix(web): 移除yarn任务进度显示 2024-03-05 15:16:50 +08:00
7841296b0c refactor(executor-task): 优化日志文件和数据文件读取模式 2024-03-05 15:16:50 +08:00
8d6c637b37 feat(web): 增加离线检索页面和任务查看 2024-03-05 15:16:50 +08:00
be64de7fe8 feat(executor): 完成文件检索扫描功能
使用flink分布式扫描日志文件和数据文件,检索关键词
2024-03-05 15:16:50 +08:00
b69512f728 refactor(cli): 调整executor manager部署副本数 2024-03-05 15:16:50 +08:00
86ad6df899 feat(loki-query): 拆分服务和hudi使用的loki,查询服务分开部署 2024-03-05 15:16:50 +08:00
557aa22343 refactor(web): 优化概览页面显示 2024-03-05 15:16:50 +08:00
fe0d779afb feat(executor): 完成任务提交执行的验证 2024-03-05 15:16:50 +08:00
a95aa5fc53 refactor(web): 优化字段显示 2024-03-05 15:16:49 +08:00
efcb40b31e fix(web): 修复mapping字段无法显示的问题 2024-03-05 15:16:49 +08:00
df36657d0c feat(web): 修复单表压缩任务提交 2024-03-05 15:16:49 +08:00
770336f0ae refactor(web): 页面随web服务发布 2024-03-05 15:16:49 +08:00
6f3e3eccff feat(web): UI兼容新版本amis 2024-03-05 15:16:49 +08:00
4e8203daec feat(web): 升级amis依赖到6.0 2024-03-05 15:16:49 +08:00
64fbd9153d refactor(web): 优化b12集群相关内容 2024-03-05 15:16:49 +08:00
1a271d84f2 fix(info-query): 修复跨天查询字段匹配错误 2024-03-05 15:16:49 +08:00
59c3ac4c8a fix(web): 修复url拼写错误 2024-03-05 15:16:49 +08:00
9aec08c43a feat(info-query): 切换旧数据库操作到新服务 2024-03-05 15:16:49 +08:00
829813df38 refactor(info-query): 移除无用参数 2024-03-05 15:16:49 +08:00
143b2fcb99 style(info-query): 移除一个IDE警告 2024-03-05 15:16:49 +08:00
6318e77442 refactor(info-query): 移除database包依赖 2024-03-05 15:16:49 +08:00
5b00b5faaf refactor(info-query): 调整代码分类
将大的service类拆分到小的类中,方便后期维护和功能调整
2024-03-05 15:16:49 +08:00
df5061f77e refactor(cli): 使用新的app jar包路径 2024-03-05 15:16:49 +08:00
0b61eebf41 feat(all): 增加统一的异常处理 2024-03-05 15:16:49 +08:00
fc93d741f2 refactor(web): 增加b12的相关监控 2024-03-05 15:16:49 +08:00
9555a147a9 fix(hudi-query): 修复集群指向 2024-03-05 15:16:49 +08:00
026f33e4d0 fix(hudi-query): 修复依赖缺失
NoClassDefFoundError: com/ctc/wstx/io/InputBootstrapper
2024-03-05 15:16:48 +08:00
b63263d360 refactor(web): 关闭debug 2024-03-05 15:16:48 +08:00
8a5e6f69ac fix(web): 移除eureka跳转 2024-03-05 15:16:48 +08:00
de4b85cad6 fix(info-query): 修复flink job没有one in one配置时候查询不到
使用左连接来取一些可能不存在的关联值
2024-03-05 15:16:48 +08:00
d4e39bdaf1 feat(cli): 副本数变化时重新生成部署主机列表 2024-03-05 15:16:48 +08:00
232645f2fc refactor(cli): 调整api的副本数 2024-03-05 15:16:48 +08:00
ad41ab9683 fix(forest): 修复启动同步没有传参数 2024-03-05 15:16:48 +08:00
7aedde5086 refactor(info-query): 转换flink job查询旧逻辑到新逻辑 2024-03-05 15:16:48 +08:00
c2cdfac269 refactor(info-query): 转换旧逻辑到新逻辑 2024-03-05 15:16:48 +08:00
75e01891c3 feat(info-query): 增加简单table meta信息查询 2024-03-05 15:16:48 +08:00
6b564bb7ea refactor(info-query): 优化参数 2024-03-05 15:16:48 +08:00