107 Commits

Author SHA1 Message Date
5ca1c28b33 fix(helm): wrong savepoint path config when storage-type is filesystem v1.2.3 2025-07-18 18:12:21 +03:30
d73292ac54 fix: resolve missing task manager statefulset savepoint pvc mount v1.2.2 2025-05-17 14:35:22 +03:30
f0df5ff937 fix: wrong fieldPath in task-manager statefulset spec.hostname v1.2.1 2025-05-17 14:02:01 +03:30
83c4b5ded2 feat(helm): add filesystem savepoint storage mode v1.2.0 2025-05-17 13:02:24 +03:30
89647f3b5b fix(helm): add flink taskmanager host env to task manager v1.1.2 2025-04-15 12:08:17 +03:30
dedbe00fba fix(helm): wrong checkpoint path flink properties v1.1.1 2025-04-13 10:38:15 +03:30
62c340bc64 feat(helm): add filesystem checkpoint storage mode 2025-04-13 10:00:32 +03:30
44ff3627fc feat(helm): add flink properties variable to values 2025-04-12 23:14:52 +03:30
392004d99a ci(docker): add zstd dependency jar to flink docker file 2025-04-12 23:07:53 +03:30
22c7d712f4 feat: update flink http client library 2025-04-07 13:20:39 +03:30
2dd625ec7c feat: update flink http client library 2025-04-07 11:28:33 +03:30
c991215a9d Merge branch 'main' of https://git.logicamp.tech/Logicamp/flink-kube-operator 2025-04-06 08:48:54 +03:30
1c32bfbbe0 chore: create index and chart package 2025-04-06 01:53:33 +03:30
f210090dff Merge branch 'feature/new-helm-structure' into HEAD 2025-04-06 01:49:21 +03:30
54008669cb fix(helm): wrong savepoint and checkpoint s3 configs 2025-04-06 01:49:00 +03:30
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
7f78faeed7 fix(helm): missing task-manager and job-manager configs in values 2025-04-04 13:51:57 +03:30
f2b627cee2 feat: add LOG_LEVEL to envs 2025-03-12 23:33:09 +03:30
4d6b06efe7 fix: restore watcher if channel is closed 2025-03-12 23:27:40 +03:30
6f91ad607f perf: remove go-nanoid and rxgo 2025-03-12 21:20:57 +03:30
b33dc0ba1d fix: resolve finalize is not working in some cases 2025-03-09 02:17:59 +03:30
556d9ff6af fix: wong update status in some situations 2025-03-05 11:40:22 +03:30
346f69100c fix: resolve missing restrict resources namespace 2025-03-04 23:55:28 +03:30
75d0557286 fix(helm): missing namespace env for operator container 2025-03-04 23:14:41 +03:30
012c525915 feat(helm): add clusterId to values 2025-03-04 18:05:01 +03:30
550b6882e1 fix(helm): missing kubernetes.cluster-id option in flink cluster 2025-03-04 17:46:32 +03:30
55dbe9f8c2 feat: add debug logs 2025-02-18 23:08:19 +03:30
1ff69e086f fix(log): add log 2025-01-25 01:05:17 +03:30
e60b96cac7 feat(docker): add jnanoid and jdbc connector jar files 2025-01-24 18:13:32 +03:30
222d70125c fix(helm): missing checkpoint interval configuration 2025-01-18 01:32:56 +03:30
9629e70ed7 fix(savepoint): wrong savepoint path in download savepoint route 2025-01-18 01:32:24 +03:30
e32addcea5 fix(helm): missing checkpoint interval configuration 2025-01-18 01:31:53 +03:30
625d5056e6 feat: merge operator to flink deployment 2025-01-18 01:14:40 +03:30
6591748d16 fix: resolve savepoint trigger no SavepointTriggerId problem 2025-01-18 00:31:05 +03:30
8f3c32ed95 fix: resolve missing handle job not found 2025-01-17 22:48:29 +03:30
4bbb027c41 fix: resolve job start after pause bug 2025-01-17 21:16:38 +03:30
896d45e15a fix: resolve crash operator in some cases 2025-01-17 21:11:17 +03:30
322877ad8e fix: resolve job start after pause bug 2025-01-17 21:09:53 +03:30
5066dc650f feat: add start and trigger savepoint routes 2025-01-17 20:27:32 +03:30
c977c8a15d feat: add download savepoint route 2025-01-17 18:34:06 +03:30
ef7b16af68 feet: add finalizer 2025-01-11 00:25:57 +03:30
14aba80181 feat: separate job-manager and task-manager containers 2025-01-10 12:39:54 +03:30
4cd00f25f0 feat: limit control to single current only namespace 2025-01-10 12:30:15 +03:30
0df874b222 feat: add rest routes to take the control of flink jobs 2025-01-09 00:22:53 +03:30
4dd82c6380 ci(docker): flink docker > add jdbc and postgress cdc and postgres sink jars 2024-12-26 22:20:57 +03:30
e4f756666d fix: missing savepoint path env in operator deployment 2024-12-25 01:46:20 +03:30
0bc45845dc fix(flink): wrong upload dir prop 2024-12-20 18:09:55 +03:30
b8e051911e fix(flink): wrong upload dir prop 2024-12-20 18:05:38 +03:30
b6e2838756 feat(flink): add readiness and liveness probe 2024-12-20 17:57:55 +03:30
8fa99f4ea8 fix(flink): wrong ha path 2024-12-20 17:56:13 +03:30