830e265162
feat: apply new helm structure
...
use minio s3 for savepoint and checkpoint path
separate task-manager, job-manager and operator
use statefulset for task-manager to handle replication
support basic credential for download jar request
update to flink 1.20.1
2025-04-05 01:39:02 +03:30
6f91ad607f
perf: remove go-nanoid and rxgo
2025-03-12 21:20:57 +03:30
0df874b222
feat: add rest routes to take the control of flink jobs
2025-01-09 00:22:53 +03:30
5e3f093f08
feat: handle job run error and change life-cycle status
2024-12-18 10:08:30 +03:30
9b219d967e
feat: handle upgrade job
2024-12-13 15:00:43 +03:30
d909765afc
ci(helm): add helm chart
2024-12-08 22:03:05 +03:30
bc20345fc0
feat: add early update job def into patch
2024-12-08 19:29:05 +03:30
c5b19d3336
feat: remove buntdb dep
2024-12-07 22:12:46 +03:30
2c25323e62
feat(manager): make check status from flink batch
2024-12-07 01:09:25 +03:30
d1a715deea
feat: add drawio
2024-12-06 19:27:05 +03:30
6bd197b812
feat: add manager
2024-11-30 23:36:44 +03:30
412a5292cb
feat(crd): update crd type
2024-11-30 20:52:12 +03:30
19b874cba6
feat(crd): add kube api and crds
2024-11-30 19:04:02 +03:30
3b0aff5688
feat: initialize
2024-11-30 01:22:51 +03:30
