Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18545

Sql api cannot specify flink job name

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Critical
    • Resolution: Done
    • Affects Version/s: 1.11.0
    • Fix Version/s: 1.11.3, 1.12.0
    • Environment:
    • Release Note:
      Introduce `pipeline.name` to allow users to specify job name by configuration. This option does not break existing pipelines.

      Description

      In Flink 1.11.0, StreamTableEnvironment.executeSql(sql) will explan and execute job Immediately, The job name will special as "insert-into_sink-table-name".  But we have Multiple sql job will insert into a same sink table, this is not very friendly. 

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              godfreyhe godfrey he
              Reporter:
              wxchunjhyy@163.com venn wu

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment