<la:message key="labels.joblog_link_list"/>
                            </la:link></li>
                            <li class="breadcrumb-item active"><la:message
                                    key="labels.joblog_link_details"/></li>
                        </ol>
                    </div>
                </div>
            </div>
        </div>

                                                <li
                                                        <c:if test="${p == pager.currentPageNumber}">class="page-item active"</c:if>>
                                                    <la:link
                                                            styleClass="page-link"

    /**
     * Enumeration of possible witness registration states.
     */
    public enum WitnessRegistrationState {
        /** Registration is in progress */
        REGISTERING,
        /** Registration is active and confirmed */
        REGISTERED,
        /** Unregistration is in progress */
        UNREGISTERING,
        /** Registration has failed */
        FAILED,
        /** Registration has expired due to timeout */

                            </la:link></li>
                            <c:if test="${crudMode == 4}">
                                <li class="breadcrumb-item active"><la:message
                                        key="labels.searchlog_configuration_link_details"/></li>
                            </c:if>
                        </ol>
                    </div>
                </div>

                        </h1>
                    </div>
                    <div class="col-sm-6">
                        <ol class="breadcrumb float-sm-right">
                            <li class="breadcrumb-item active"><la:link href="/admin/crawlinginfo">
                                <la:message key="labels.crawling_info_title"/>
                            </la:link></li>
                        </ol>
                    </div>

                                                <li
                                                        <c:if test="${p == pager.currentPageNumber}">class="page-item active"</c:if>>
                                                    <la:link
                                                            styleClass="page-link"

        File baseDirectory = getBaseDirectoryFromRequest(request);
        for (ProjectActivation.ProjectActivationSettings activation : projectSelectors) {
            if (activation.activationSettings().active()) {
                String selector = activation.selector();
                Optional<MavenProject> optSelectedProject =
                        findOptionalProjectBySelector(projects, baseDirectory, selector);

					continue
				case <-doneCh:
					return
				}
			}
		}
	}()

	return nil
}

// NumSubscribers returns the number of current subscribers,
// The mask is checked against the active subscribed types,
// and 0 will be returned if nobody is subscribed for the type(s).
func (ps *PubSub[T, M]) NumSubscribers(mask M) int32 {
	types := Mask(atomic.LoadUint64(&ps.types))
	if !types.Overlaps(Mask(mask.Mask())) {

# **Disaggregated HDP Spark and Hive with MinIO**

## **1. Cloud-native Architecture**

![cloud-native](https://github.com/minio/minio/blob/master/docs/bigdata/images/image1.png?raw=true "cloud native architecture")

Kubernetes manages stateless Spark and Hive containers elastically on the compute nodes. Spark has native scheduler integration with Kubernetes. Hive, for legacy reasons, uses YARN scheduler on top of Kubernetes.

      --ntasks;
      int active = 1;

      while (true) {
        Future<T> f = futureQueue.poll();
        if (f == null) {
          if (ntasks > 0) {
            --ntasks;
            futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue));
            ++active;
          } else if (active == 0) {
            break;
          } else if (timed) {