(self, tags)
return running_apps
Return a dictionary of {app_id: (app_name, tracking_url)} for running Spark applications.
Return a dictionary of {app_id: (app_name, tracking_url)} for running Spark applications.
Return a dictionary of { app_id : ( app_name tracking_url ) } for running Spark applications .
def _yarn_init(self, tags):
        """
        Return a dictionary of {app_id: (app_name, tracking_url)} for running Spark applications.
        """
        running_apps = self._yarn_get_running_spark_apps(tags)

        # Report success after gathering all metrics from ResourceManager
        self.service_check(
            YARN_SERVICE_CHECK,
            AgentCheck.OK,
            tags=['url:%s' % self.master_address] + tags,
        )

        return running_apps
def _yarn_init ( self , tags ) : running_apps = self . _yarn_get_running_spark_apps ( tags ) # Report success after gathering all metrics from ResourceManager self . service_check ( YARN_SERVICE_CHECK , AgentCheck . OK , tags = [ 'url:%s' % self . master_address ] + tags , ) return running_apps