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

OperatorCoordinator.start()'s JavaDoc mismatches its behavior

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.16.0
    • None
    • Documentation
    • None

    Description

      The following description lies in the JavaDoc of OperatorCoordinator.start().

      This method is called once at the beginning, before any other methods.

      This description is incorrect because the method resetToCheckpoint() can be invoked before start(). For example, RecreateOnResetOperatorCoordinator.DeferrableCoordinator.resetAndStart() uses these methods in this way. Thus the JavaDoc of OperatorCoordinator's methods should be modified to match this behavior.

      Attachments

        Activity

          People

            Unassigned Unassigned
            yunfengzhou Yunfeng Zhou
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: