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

Make the thread nums of io executor of ClusterEntrypoint and MiniCluster configurable

    XMLWordPrintableJSON

    Details

      Description

      FLINK-11851 introduce dedicated io executor for ClusterEntrypoint and MiniCluster with the the thread num as the cpu cores. However, this could introduce extra regression as we might use fewer threads compared with akka service before, e.g.FLINK-17073 . However, we cannot configure the thread num of the io executor to avoid such regression.

      One idea is to introduce such configuration to make the thread nums of io executor of ClusterEntrypoint and MiniCluster configurable.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                yunta Yun Tang
                Reporter:
                yunta Yun Tang
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: