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

Add option to manually set job ID

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.7.0
    • None
    • None

    Description

      When submitting Flink jobs programmatically it is desirable to have the option to manually set the job ID in order to have idempotent job submissions. This simplifies failure handling on the user side as duplicate submissions will be rejected by Flink. In general allowing to manually set the job ID can be beneficial for third party tooling.

      The default behavior should not be altered. The following job submission entry points should be extended to allow to specify this option:
      1. REST API
      2. StandaloneJobClusterEntrypoint
      3. CLI

      Note that for 2. FLINK-10921 already suggested to allow to configure the job ID manually.

      If there is agreement to have this feature, I'll go ahead and create sub tasks for the mentioned entry points (and provide the implementation for 1. and 2.).

      Attachments

        Activity

          People

            Unassigned Unassigned
            uce Ufuk Celebi
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 50m
                50m