 mohamad
|
e60b96cac7
|
feat(docker): add jnanoid and jdbc connector jar files
|
2025-01-24 18:13:32 +03:30 |
|
|
mohamad
|
222d70125c
|
fix(helm): missing checkpoint interval configuration
|
2025-01-18 01:32:56 +03:30 |
|
|
mohamad
|
9629e70ed7
|
fix(savepoint): wrong savepoint path in download savepoint route
|
2025-01-18 01:32:24 +03:30 |
|
|
mohamad
|
e32addcea5
|
fix(helm): missing checkpoint interval configuration
|
2025-01-18 01:31:53 +03:30 |
|
|
mohamad
|
625d5056e6
|
feat: merge operator to flink deployment
|
2025-01-18 01:14:40 +03:30 |
|
|
mohamad
|
6591748d16
|
fix: resolve savepoint trigger no SavepointTriggerId problem
|
2025-01-18 00:31:05 +03:30 |
|
|
mohamad
|
8f3c32ed95
|
fix: resolve missing handle job not found
|
2025-01-17 22:48:29 +03:30 |
|
|
mohamad
|
4bbb027c41
|
fix: resolve job start after pause bug
|
2025-01-17 21:16:38 +03:30 |
|
|
mohamad
|
896d45e15a
|
fix: resolve crash operator in some cases
|
2025-01-17 21:11:17 +03:30 |
|
|
mohamad
|
322877ad8e
|
fix: resolve job start after pause bug
|
2025-01-17 21:09:53 +03:30 |
|
|
mohamad
|
5066dc650f
|
feat: add start and trigger savepoint routes
|
2025-01-17 20:27:32 +03:30 |
|
|
mohamad
|
c977c8a15d
|
feat: add download savepoint route
|
2025-01-17 18:34:06 +03:30 |
|
 seraj
|
ef7b16af68
|
feet: add finalizer
|
2025-01-11 00:25:57 +03:30 |
|
|
mohamad
|
14aba80181
|
feat: separate job-manager and task-manager containers
|
2025-01-10 12:39:54 +03:30 |
|
|
mohamad
|
4cd00f25f0
|
feat: limit control to single current only namespace
|
2025-01-10 12:30:15 +03:30 |
|
|
mohamad
|
0df874b222
|
feat: add rest routes to take the control of flink jobs
|
2025-01-09 00:22:53 +03:30 |
|
|
mohamad
|
4dd82c6380
|
ci(docker): flink docker > add jdbc and postgress cdc and postgres sink jars
|
2024-12-26 22:20:57 +03:30 |
|
|
mohamad
|
e4f756666d
|
fix: missing savepoint path env in operator deployment
|
2024-12-25 01:46:20 +03:30 |
|
|
mohamad
|
0bc45845dc
|
fix(flink): wrong upload dir prop
|
2024-12-20 18:09:55 +03:30 |
|
|
mohamad
|
b8e051911e
|
fix(flink): wrong upload dir prop
|
2024-12-20 18:05:38 +03:30 |
|
|
mohamad
|
b6e2838756
|
feat(flink): add readiness and liveness probe
|
2024-12-20 17:57:55 +03:30 |
|
|
mohamad
|
8fa99f4ea8
|
fix(flink): wrong ha path
|
2024-12-20 17:56:13 +03:30 |
|
|
mohamad
|
23a4de92e4
|
fix: missing ha pvc
|
2024-12-20 17:22:32 +03:30 |
|
|
mohamad
|
37936c8c58
|
feat: separate ha and checkpoint pvc
|
2024-12-20 17:12:51 +03:30 |
|
|
mohamad
|
4ed533f284
|
fix(manage-job): missing patch kube resource after run job
|
2024-12-20 14:45:29 +03:30 |
|
|
mohamad
|
00030195c8
|
perf(helm): flink-deployment > remove unneeded mount
|
2024-12-19 00:40:16 +03:30 |
|
|
mohamad
|
7e33fd6cef
|
fix: wrong life-cycle-status after job failed
|
2024-12-18 11:12:08 +03:30 |
|
|
mohamad
|
5bc047dbd1
|
feat(managed-job): add args and parallelism param to run flink job method
|
2024-12-18 11:08:21 +03:30 |
|
|
mohamad
|
07b8a36e63
|
feat: add avro and exp4j jar
|
2024-12-18 10:51:53 +03:30 |
|
|
mohamad
|
5e3f093f08
|
feat: handle job run error and change life-cycle status
|
2024-12-18 10:08:30 +03:30 |
|
|
mohamad
|
03fe9910a3
|
feat: add clickhouse and postgres support
|
2024-12-16 09:28:26 +03:30 |
|
|
mohamad
|
438296ec35
|
docs: update readme for helm repo
|
2024-12-15 10:27:34 +03:30 |
|
|
mohamad
|
6a475c7755
|
feat: add repo for helm chart
|
2024-12-15 10:24:38 +03:30 |
|
|
mohamad
|
a3a806a54f
|
Merge remote-tracking branch 'origin/feature/kube-crd-control'
|
2024-12-15 10:16:46 +03:30 |
|
|
mohamad
|
9086f6664e
|
fix: resolve leftover jar file issue after upload
|
2024-12-13 20:12:52 +03:30 |
|
|
mohamad
|
9f36dca7c9
|
fix: prevent concurrent jobs map writes by adding synchronization
This fix prevents undefined behavior and runtime crashes in multithreaded
use cases.
|
2024-12-13 20:11:58 +03:30 |
|
|
mohamad
|
02d8f0b02e
|
fix: resolve remain jar file after upload
|
2024-12-13 19:51:26 +03:30 |
|
|
mohamad
|
d36b9c30df
|
fix: resolve issue with jar upgrade not uploading new jar
Ensure the new jar is properly uploaded during an upgrade process. Previously, the jar was not replaced as expected.
|
2024-12-13 19:41:59 +03:30 |
|
|
mohamad
|
699cf12f72
|
fix(savepoint): periodically savepoint bug
|
2024-12-13 15:11:36 +03:30 |
|
|
mohamad
|
444cfc7061
|
feat: optimize logs
|
2024-12-13 15:06:02 +03:30 |
|
|
mohamad
|
08407afe1e
|
fix(jar): not returned error on download returns not 200 resp
|
2024-12-13 15:01:21 +03:30 |
|
|
mohamad
|
9b219d967e
|
feat: handle upgrade job
|
2024-12-13 15:00:43 +03:30 |
|
|
mohamad
|
89702d287a
|
fix(savepoint): missing savepoint path env and not handled savepoint errors
|
2024-12-13 14:57:55 +03:30 |
|
|
mohamad
|
b2d2295d07
|
feat: allow restore jobs that has not any taken save point
|
2024-12-13 02:50:43 +03:30 |
|
|
mohamad
|
c066a9fd90
|
ci: add tilt file
|
2024-12-13 02:49:40 +03:30 |
|
|
mohamad
|
5543f5ea79
|
feat(helm): enable ha for Flink cluster deployment
|
2024-12-13 02:49:21 +03:30 |
|
|
mohamad
|
a22198011c
|
perf: optimize docker image size
|
2024-12-13 02:48:19 +03:30 |
|
|
mohamad
|
5bf3571e4b
|
fix(helm): no config-map error in operator deployment
|
2024-12-13 02:47:54 +03:30 |
|
|
mohamad
|
d3fd04b20c
|
perf: remove lc dependency
|
2024-12-12 23:13:54 +03:30 |
|
|
mohamad
|
3912ecef44
|
fix(helm): wrong flink checkpoint and savepoint dirs config
|
2024-12-09 01:51:40 +03:30 |
|