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

Sql api cannot specify flink job name

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Critical
    • Resolution: Done
    • Affects Version/s: 1.11.0
    • Fix Version/s: 1.12.0, 1.11.3
    • 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
              • Votes:
                0 Vote for this issue
                Watchers:
                22 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: