Class KubernetesWorkerNode

  • All Implemented Interfaces:
    org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable

    public class KubernetesWorkerNode
    extends Object
    implements org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable
    A stored Kubernetes worker, which contains the kubernetes pod.
    • Method Detail

      • getResourceID

        public org.apache.flink.runtime.clusterframework.types.ResourceID getResourceID()
        Specified by:
        getResourceID in interface org.apache.flink.runtime.clusterframework.types.ResourceIDRetrievable
      • getAttempt

        public long getAttempt()
                        throws org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException
        Throws:
        org.apache.flink.runtime.resourcemanager.exceptions.ResourceManagerException