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

Enable configuration for state.checkpoint.dir in StreamExecutionEnvironment

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • None
    • None
    • None

    Description

      Usually we can set state.checkpoint.dir in flink-conf.yaml, but sometimes we run a flink job locally, and we're not able to set state.checkpoint.dir for background wrapped cluster, which will cause 

      throw new IllegalStateException("CheckpointConfig says to persist periodic " +
            "checkpoints, but no checkpoint directory has been configured. You can " +
            "configure configure one via key '" + ConfigConstants.CHECKPOINTS_DIRECTORY_KEY + "'.");
      

      I wonder if we could provide a public method in StreamExecutionEnvironment so that developers can use it to set state.checkpoint.dir for job.

      Attachments

        Activity

          People

            Unassigned Unassigned
            wind_ljy Jiayi Liao
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: