Commit Graph

420 Commits

Author SHA1 Message Date
6ff19c1ebe feat(checker): 增加pulsar topic检查 2024-03-05 15:16:53 +08:00
6a0bbf3344 fix(sync): 修复decimal字段为空时抛出异常 使用返回null替代 2024-03-05 15:16:53 +08:00
396bc01f94 feat(sync): 字段类型不存在不抛出异常 默认使用String 2024-03-05 15:16:53 +08:00
299d8d5e23 fix(sync): 修复decimal类型名称重复导致schema解析报错
Schema中的类型名称不能重复,比如有一个decimal_15如果后面的字段再出现同样的类型名称,就会报错
2024-03-05 15:16:52 +08:00
c1d423bc32 fix(uploader): 修复hdfs默认构造导致问题 2024-03-05 15:16:52 +08:00
4a0db374fe fix(executor): 修复flink依赖版本 2024-03-05 15:16:52 +08:00
2669eed1ae feat(configuration): 输出http异常 2024-03-05 15:16:52 +08:00
61601e3e80 fix(sync): 优化依赖 2024-03-05 15:16:52 +08:00
d0729b6471 fix(cli): 修复download路径错误 2024-03-05 15:16:52 +08:00
a24080a543 fix(cli): 修复脚本名称错误 2024-03-05 15:16:52 +08:00
8b30207cbe fix(cli): 更新配置适配 2024-03-05 15:16:52 +08:00
7dc38383c5 refactor(executor-manager): 使用sync同款jar更新方式 2024-03-05 15:16:52 +08:00
36c31df2c1 fix(launcher): 修复sync包路径引用 2024-03-05 15:16:52 +08:00
9a6eb1e0a4 feat(cli): 适配使用uploader上传jar包 2024-03-05 15:16:52 +08:00
826f7bc780 fix(cli): uploader改为后台运行 2024-03-05 15:16:52 +08:00
c81efce3de fix(uploader): 避免路径不存在导致错误 2024-03-05 15:16:52 +08:00
c56e05dea4 feat(uploader): 固定端口方便使用 2024-03-05 15:16:52 +08:00
cc7a2239cc fix(uploader): 修复uploader安全配置未配置 2024-03-05 15:16:52 +08:00
8ae522bfcd fix(uploader): 修复uploader依赖未导入 2024-03-05 15:16:52 +08:00
adc9c95ddc fix(uploader): 修复依赖冲突 2024-03-05 15:16:52 +08:00
f3c1d12c60 feat(uploader): 增加文件上传下载模块 2024-03-05 15:16:52 +08:00
c8126684a1 feat(executor): 增加juice-fs依赖 2024-03-05 15:16:52 +08:00
c6c6919f11 refactor(all): b9配置从主分支移除 2024-03-05 15:16:52 +08:00
7d0511bd4c fix(web): 修复集群简写名称类型错误 2024-03-05 15:16:52 +08:00
479e7a58f2 feat(web): 集群信息改为统一配置 2024-03-05 15:16:52 +08:00
677fd1d246 feat(common): 主分支修改为数据库b12使用 2024-03-05 15:16:52 +08:00
adc480e43c fix(cli): 修复b9访问地址 2024-03-05 15:16:52 +08:00
f63f4466a7 fix(cli): 修复command启动脚本参数错误 2024-03-05 15:16:52 +08:00
18b2071b37 fix(cli): 修复b9对应数据库引用错误 2024-03-05 15:16:52 +08:00
708c29cf2e fix(cli): 修复b9应用名称错误 2024-03-05 15:16:52 +08:00
9c6615c33c fix(cli): 修复argument和environment为空时报错 2024-03-05 15:16:52 +08:00
e9aa11a15d feat(all): 补充b9集群配置 2024-03-05 15:16:52 +08:00
54f2738b2e feat(command): 移除多余的配置 2024-03-05 15:16:52 +08:00
b655295f33 feat(scheduler): 允许集群判断规则为空 2024-03-05 15:16:52 +08:00
70d2d31540 fix(cli): 适配master改动 2024-03-05 15:16:52 +08:00
d0bbdff61d feat(all): 增加b9集群相关配置 2024-03-05 15:16:52 +08:00
0338a0d579 feat(all): 优化依赖
移除旧common包
2024-03-05 15:16:52 +08:00
5a2e9fdfb8 feat(all): 迁移common、sync、executor项目 2024-03-05 15:16:52 +08:00
0683068a02 feat(command): 迁移service-command项目 2024-03-05 15:16:52 +08:00
474ee6173d feat(scheduler): 迁移service-launcher项目 2024-03-05 15:16:52 +08:00
f258bfe5b0 feat(scheduler): 迁移service-scheduler项目 2024-03-05 15:16:52 +08:00
14409ae798 feat(api): 迁移hudi-api项目到这里 2024-03-05 15:16:52 +08:00
b9247fa4f0 refactor(cli): 优化配置项 2024-03-05 15:16:52 +08:00
55c4be2479 fix(cli): 修复没有转义配置文件中的$符号 2024-03-05 15:16:52 +08:00
de78898a60 refactor(cli): 优化配置
移除flink多余配置
2024-03-05 15:16:52 +08:00
2c36a826a5 fix(cli): 修复deploy.plan路径错误导致无法保留上一次部署计划 2024-03-05 15:16:52 +08:00
3e3dd09d52 feat(cli): 移除关于配置分发的内容
PipelineOptions.CLASSPATHS 这个参数并不能方便地分发 hadoop 配置
2024-03-05 15:16:52 +08:00
871b01522a feat(cli): 增加配置发布
将hadoop配置分发到各个主机上
2024-03-05 15:16:52 +08:00
73f0c4c82c refactor(cli): 优化脚本 增加command脚本的生成 2024-03-05 15:16:51 +08:00
5ecc3daac0 refactor(cli): 优化脚本 2024-03-05 15:16:51 +08:00