79124687

Date: 2024-10-25 07:36:27
Score: 1
Natty:
Report link

Actually we can do it like this:

val tEnv = StreamTableEnvironment.create(env)
val tableConf = tEnv.getConfig.getConfiguration
tableConf.setString("pipeline.name", "MyJobName")

or using SET statement in SQL Cli:

-- setting the job name
SET 'pipeline.name' = 'MyJobName';
Reasons:
  • Low length (0.5):
  • Has code block (-0.5):
  • Self-answer (0.5):
  • Low reputation (0.5):
Posted by: Niko