What would you like to be added? I have two ephemeral volumes, on

<a class="user-mention notranslate" data-hovercard-type="user" data-hovercard-url="/us

<a class="user-mention notranslate" data-hovercard-type="user" data-hover

The code should be on line 235 <div cl

Ephemeral volume scheduling problems about kubernetes HOT 10 OPEN

kangzhiqin commented on September 27, 2024

Ephemeral volume scheduling problems

from kubernetes.

Comments (10)

k8s-ci-robot commented on September 27, 2024

This issue is currently awaiting triage.

If a SIG or subproject determines this is a relevant issue, they will accept it by applying the triage/accepted label and provide further guidance.

The triage/accepted label can be added by org members by writing /triage accepted in a comment.

Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the kubernetes-sigs/prow repository.

from kubernetes.

neolit123 commented on September 27, 2024

/sig storage

from kubernetes.

xing-yang commented on September 27, 2024

@kangzhiqin as a workaround, can you combine the two volumes and use subpath for different mounts?
Does localcsi driver support storage capacity tracking? If it relies on that feature, enhancement is still needed as it currently only supports one PVC per Pod.

from kubernetes.

xing-yang commented on September 27, 2024

/triage needs-more-information

from kubernetes.

k8s-ci-robot commented on September 27, 2024

@xing-yang: The label(s) triage/needs-more-information cannot be applied, because the repository doesn't have them.

In response to this:

/triage needs-more-information

from kubernetes.

xing-yang commented on September 27, 2024

/triage needs-information

from kubernetes.

kangzhiqin commented on September 27, 2024

@kangzhiqin as a workaround, can you combine the two volumes and use subpath for different mounts? Does localcsi driver support storage capacity tracking? If it relies on that feature, enhancement is still needed as it currently only supports one PVC per Pod.

Thank you for your reply. I'll think about this solution.

from kubernetes.

kangzhiqin commented on September 27, 2024

@kangzhiqin as a workaround, can you combine the two volumes and use subpath for different mounts? Does localcsi driver support storage capacity tracking? If it relies on that feature, enhancement is still needed as it currently only supports one PVC per Pod.

from kubernetes.

kangzhiqin commented on September 27, 2024

Will volumes be created in order of size? For example, creating 43 GB volumes first and then 100 MB volumes can avoid this problem.

from kubernetes.

kangzhiqin commented on September 27, 2024

The code should be on line 235

kubernetes/pkg/controller/volume/ephemeral/controller.go

Lines 213 to 243 in e67f889

 func (ec *ephemeralController) syncHandler(ctx context.Context, key string) error { 

 namespace, name, err := cache.SplitMetaNamespaceKey(key) 

 if err != nil { 

 return err 

 } 

 pod, err := ec.podLister.Pods(namespace).Get(name) 

 logger := klog.FromContext(ctx) 

 if err != nil { 

 if errors.IsNotFound(err) { 

 logger.V(5).Info("Ephemeral: nothing to do for pod, it is gone", "podKey", key) 

 return nil 

 } 

 logger.V(5).Info("Error getting pod from informer", "pod", klog.KObj(pod), "podUID", pod.UID, "err", err) 

 return err 

 } 

 // Ignore pods which are already getting deleted. 

 if pod.DeletionTimestamp != nil { 

 logger.V(5).Info("Ephemeral: nothing to do for pod, it is marked for deletion", "podKey", key) 

 return nil 

 } 

 for _, vol := range pod.Spec.Volumes { 

 if err := ec.handleVolume(ctx, pod, vol); err != nil { 

 ec.recorder.Event(pod, v1.EventTypeWarning, events.FailedBinding, fmt.Sprintf("ephemeral volume %s: %v", vol.Name, err)) 

 return fmt.Errorf("pod %s, ephemeral volume %s: %v", key, vol.Name, err) 

 } 

 } 

 return nil 

 }

from kubernetes.

Ephemeral volume scheduling problems about kubernetes HOT 10 OPEN

Comments (10)

Related Issues (20)

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent

	func (ec *ephemeralController) syncHandler(ctx context.Context, key string) error {
	namespace, name, err := cache.SplitMetaNamespaceKey(key)
	if err != nil {
	return err
	}
	pod, err := ec.podLister.Pods(namespace).Get(name)
	logger := klog.FromContext(ctx)
	if err != nil {
	if errors.IsNotFound(err) {
	logger.V(5).Info("Ephemeral: nothing to do for pod, it is gone", "podKey", key)
	return nil
	}
	logger.V(5).Info("Error getting pod from informer", "pod", klog.KObj(pod), "podUID", pod.UID, "err", err)
	return err
	}

	// Ignore pods which are already getting deleted.
	if pod.DeletionTimestamp != nil {
	logger.V(5).Info("Ephemeral: nothing to do for pod, it is marked for deletion", "podKey", key)
	return nil
	}

	for _, vol := range pod.Spec.Volumes {
	if err := ec.handleVolume(ctx, pod, vol); err != nil {
	ec.recorder.Event(pod, v1.EventTypeWarning, events.FailedBinding, fmt.Sprintf("ephemeral volume %s: %v", vol.Name, err))
	return fmt.Errorf("pod %s, ephemeral volume %s: %v", key, vol.Name, err)
	}
	}

	return nil
	}