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

Add open method to PartitionCommitPolicy

    XMLWordPrintableJSON

Details

    Description

      Currently, the PartitionCommitPolicy do not have the open hook. The custom partition commit policy does not have an appropriate entry point for the init work.
      So I purpose to add an open method to make this work.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              aitozi WenJun Min
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: