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

Default RPC timeout is used when triggering savepoint via JobMasterGateway

    XMLWordPrintableJSON

Details

    Description

      When calling JobMasterGateway#triggerSavepoint(String, boolean, Time), the default timeout is used because the time parameter of the method is not annotated with @RpcTimeout.

      Expected behavior

      • timeout for the RPC should be RpcUtils.INF_TIMEOUT

      Attachments

        1. SlowToCheckpoint.java
          3 kB
          Ufuk Celebi

        Issue Links

          Activity

            People

              gjy Gary Yao
              gjy Gary Yao
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: