marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove SHUFFLE_WORKER_* env from orborus.go

Browse Source
This commit is contained in:
trusihin.andrey
2025-08-26 18:10:12 +03:00
parent f26f872835
commit dd89bbdd33
1 changed files with 0 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/orborus/orborus.go
-14
View File
@@ -1072,20 +1072,6 @@ func deployK8sWorker(image string, identifier string, env []string) error {
env = append(env, fmt.Sprintf("IS_KUBERNETES=true")) env = append(env, fmt.Sprintf("IS_KUBERNETES=true"))
env = append(env, fmt.Sprintf("KUBERNETES_NAMESPACE=%s", os.Getenv("KUBERNETES_NAMESPACE"))) env = append(env, fmt.Sprintf("KUBERNETES_NAMESPACE=%s", os.Getenv("KUBERNETES_NAMESPACE")))
// worker resource env
for _, k := range []string{
"SHUFFLE_WORKER_CPU_REQUEST",
"SHUFFLE_WORKER_MEMORY_REQUEST",
"SHUFFLE_WORKER_EPHEMERAL_STORAGE_REQUEST",
"SHUFFLE_WORKER_CPU_LIMIT",
"SHUFFLE_WORKER_MEMORY_LIMIT",
"SHUFFLE_WORKER_EPHEMERAL_STORAGE_LIMIT",
} {
if v := os.Getenv(k); v != "" {
env = append(env, fmt.Sprintf("%s=%s", k, v))
}
}
// app resource env // app resource env
for _, k := range []string{ for _, k := range []string{
"SHUFFLE_APP_CPU_REQUEST", "SHUFFLE_APP_CPU_REQUEST",