diff --git a/go.mod b/go.mod index 987bada..8d95d45 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.1 + github.com/logi-camp/go-flink-client v0.2.0 github.com/samber/lo v1.47.0 go.uber.org/zap v1.27.0 k8s.io/apimachinery v0.31.3 diff --git a/internal/managed_job/run.go b/internal/managed_job/run.go index 5aa48f1..1e543c2 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, - ProgramArgsList: job.def.Spec.Args, + ProgramArg: job.def.Spec.Args, }) if err == nil { pkg.Logger.Info("[managed-job] [run] jar successfully ran", zap.Any("run-jar-resp", runJarResp))