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

Refactor Flink on YARN configuration with relavent overlay classes to make hadoop user name env configurable

    XMLWordPrintableJSON

Details

    Description

      Our platform needs to provide a centralized submitter. We need to provide a customized env variable HADOOP_USER_NAME, it is hardcoded in ApplicationYarnClusterDescriptor :

      appMasterEnv.put(YarnConfigKeys.ENV_HADOOP_USER_NAME, UserGroupInformation.getCurrentUser().getUserName());
      

       

      There is an abstract layer beyond special deployment named ContainerOverlay

      However, currently, only Flink on Mesos used this mechanism. Flink on YARN still used some trivial configuration items in AbstractYarnClusterDescriptor. IMO we need to use container overlay to refactor Flink on YARN related implementation. 

      Attachments

        Activity

          People

            Unassigned Unassigned
            yanghua vinoyang
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: