From 2dd625ec7cb32e63f9ecafea0b09daf5369a00ac Mon Sep 17 00:00:00 2001 From: Mohammadreza Khani Date: Mon, 7 Apr 2025 11:28:33 +0330 Subject: [PATCH] feat: update flink http client library --- go.mod | 2 +- go.sum | 2 ++ helm/chart/values.yaml | 4 ++-- internal/managed_job/run.go | 2 +- 4 files changed, 6 insertions(+), 4 deletions(-) diff --git a/go.mod b/go.mod index 8d95d45..987bada 100644 --- a/go.mod +++ b/go.mod @@ -5,7 +5,7 @@ go 1.23.2 require ( github.com/danielgtaylor/huma/v2 v2.27.0 github.com/gofiber/fiber/v2 v2.52.6 - github.com/logi-camp/go-flink-client v0.2.0 + github.com/logi-camp/go-flink-client v0.2.1 github.com/samber/lo v1.47.0 go.uber.org/zap v1.27.0 k8s.io/apimachinery v0.31.3 diff --git a/go.sum b/go.sum index f198182..cf5f2d1 100644 --- a/go.sum +++ b/go.sum @@ -64,6 +64,8 @@ github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/logi-camp/go-flink-client v0.2.0 h1:PIyfJq7FjW28bnvemReCicIuQD7JzVgJDk2xPTZUS2s= github.com/logi-camp/go-flink-client v0.2.0/go.mod h1:A79abedX6wGQI0FoICdZI7SRoGHj15QwMwWowgsKYFI= +github.com/logi-camp/go-flink-client v0.2.1 h1:STfKamFm9+2SxxfZO3ysdFsb5MViQdThB4UHbnkUOE8= +github.com/logi-camp/go-flink-client v0.2.1/go.mod h1:A79abedX6wGQI0FoICdZI7SRoGHj15QwMwWowgsKYFI= github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0= github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc= github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= diff --git a/helm/chart/values.yaml b/helm/chart/values.yaml index 0bf2e4a..e8f8836 100644 --- a/helm/chart/values.yaml +++ b/helm/chart/values.yaml @@ -139,9 +139,9 @@ flink: taskManager: - numberOfTaskSlots: 12 # Number of task slots for TaskManager + numberOfTaskSlots: 12 # Number of task slots for task manager processMemory: 4096m # Size of task manager process memory - replicas: 1 + replicas: 1 # Number of task manager replicas storage: rocksDb: size: 4Gi diff --git a/internal/managed_job/run.go b/internal/managed_job/run.go index 1e543c2..5aa48f1 100644 --- a/internal/managed_job/run.go +++ b/internal/managed_job/run.go @@ -43,7 +43,7 @@ func (job *ManagedJob) Run(restoreMode bool) error { EntryClass: job.def.Spec.EntryClass, SavepointPath: savepointPath, Parallelism: job.def.Spec.Parallelism, - ProgramArg: job.def.Spec.Args, + ProgramArgsList: job.def.Spec.Args, }) if err == nil { pkg.Logger.Info("[managed-job] [run] jar successfully ran", zap.Any("run-jar-resp", runJarResp))