From 7f78faeed76a9bf16f172074025975d0e1b1a7a5 Mon Sep 17 00:00:00 2001 From: Mohammadreza Khani Date: Fri, 4 Apr 2025 13:51:57 +0330 Subject: [PATCH] fix(helm): missing task-manager and job-manager configs in values --- helm/chart/Chart.yaml | 2 +- helm/chart/templates/flink/deploy.yaml | 13 +++++----- helm/chart/values.yaml | 12 +++++++++- helm/flink-kube-operator-0.1.14.tgz | Bin 0 -> 5926 bytes helm/index.yaml | 32 ++++++++++++++++--------- 5 files changed, 39 insertions(+), 20 deletions(-) create mode 100644 helm/flink-kube-operator-0.1.14.tgz diff --git a/helm/chart/Chart.yaml b/helm/chart/Chart.yaml index 196e63a..9fc1a17 100644 --- a/helm/chart/Chart.yaml +++ b/helm/chart/Chart.yaml @@ -2,5 +2,5 @@ apiVersion: v2 name: flink-kube-operator description: Helm chart for flink kube operator type: application -version: 0.1.13 +version: 0.1.14 appVersion: "0.1.0" diff --git a/helm/chart/templates/flink/deploy.yaml b/helm/chart/templates/flink/deploy.yaml index c8f619a..5a7c74e 100644 --- a/helm/chart/templates/flink/deploy.yaml +++ b/helm/chart/templates/flink/deploy.yaml @@ -6,8 +6,8 @@ - name: FLINK_PROPERTIES value: | jobmanager.rpc.address: localhost - jobmanager.memory.process.size: 2048m - taskmanager.memory.process.size: 2048m + jobmanager.memory.process.size: {{ .Values.flink.jobManager.processMemory }} + taskmanager.memory.process.size: {{ .Values.flink.taskManager.processMemory }} taskmanager.data.port: 6125 taskmanager.numberOfTaskSlots: {{ .Values.flink.taskManager.numberOfTaskSlots }} parallelism.default: {{ .Values.flink.parallelism.default }} @@ -18,15 +18,15 @@ high-availability.type: kubernetes kubernetes.namespace: {{ .Release.Namespace }} kubernetes.cluster-id: {{ .Values.clusterId | default (print .Release.Name "-cluster") }} - execution.checkpointing.interval: 5min - execution.checkpointing.mode: EXACTLY_ONCE + execution.checkpointing.interval: {{ .Values.flink.checkpoint.interval }} + execution.checkpointing.mode: {{ .Values.flink.checkpoint.mode }} web.upload.dir: {{ .Values.flink.state.data.dir }}/web-upload state.checkpoints.dir: file://{{ .Values.flink.state.data.dir }}/checkpoints state.backend.rocksdb.localdir: file://{{ .Values.flink.state.data.dir }}/rocksdb high-availability.storageDir: file://{{ .Values.flink.state.ha.dir }} state.savepoints.dir: file://{{ .Values.flink.state.savepoints.dir }} - state.backend.incremental: false - rest.profiling.enabled: true + state.backend.incremental: {{ .Values.flink.state.incremental }} + rest.profiling.enabled: true {{- end }} {{- define "flink.volumeMounts" -}} @@ -110,7 +110,6 @@ spec: fieldPath: status.podIP volumeMounts: {{- include "flink.volumeMounts" . | nindent 12 }} - - name: taskmanager image: {{ .Values.flink.image.repository }}:{{ .Values.flink.image.tag }} imagePullPolicy: Always diff --git a/helm/chart/values.yaml b/helm/chart/values.yaml index f1d0a90..a9ec791 100644 --- a/helm/chart/values.yaml +++ b/helm/chart/values.yaml @@ -121,9 +121,14 @@ flink: parallelism: default: 1 # Default parallelism for Flink jobs + + checkpoint: + interval: 5min + mode: EXACTLY_ONCE state: backend: rocksdb # Use RocksDB for state backend + incremental: true savepoints: dir: "/opt/flink/savepoints" # Directory to store savepoints pvcName: flink-savepoints-pvc # PVC for savepoints persistence @@ -136,8 +141,13 @@ flink: dir: "/opt/flink/ha" # Directory to store ha data pvcName: flink-ha-pvc # PVC for ha size: 10Gi # PVC size for ha + + jobManager: + processMemory: 4096m # Size of job manager process memory + taskManager: - numberOfTaskSlots: 100 # Number of task slots for TaskManager + numberOfTaskSlots: 12 # Number of task slots for TaskManager + processMemory: 4096m # Size of task manager process memory # clusterId: some-id \ No newline at end of file diff --git a/helm/flink-kube-operator-0.1.14.tgz b/helm/flink-kube-operator-0.1.14.tgz new file mode 100644 index 0000000000000000000000000000000000000000..34661e2a2f42cc037b601f491e445469ce3d4f31 GIT binary patch literal 5926 zcmV+>7uo0^iwG0|00000|0w_~VMtOiV@ORlOnEsqVl!4SWK%V1T2nbTPgYhoO;>Dc zVQyr3R8em|NM&qo0PH<$bK5wQ^O?V*Ps!FiE~FlQ&9N$V<*_|k?!4^TFyV2-I1C0harX;=bZ}JiLS%x{1jCYR` z#APr?Q~J%Lq+YMr+uz;Q|9ib&^M7y9-}|P&dvLIGu+#7F^}gx#_j-E=-$3ti(63Ip zkcfZN`)pjz#{G*Vl#zFs3&PS6W&;mpS^3xt`a#c&v4}Xyq|W*~rc;QNc)*x((82>s zc%Tp-FGW)vLW@{=a-QK3P?k{=AqCHyxv2WP-q&Wv|HIU#|1(5$EFNzFSgrs4!C-g4 zssB5J-L3vVMS2Fuc#Lu?!Ss5i*L9%?yk~Hg5CKF0f?p5cy!OY8Pmz>3hB2X76*$Hb zMI6Hnae_t^3y=&(7&0UTj)A0-!JOqBB%WpzNh|`dfO|_Q1%V~V1Ovx7X2&D@0nB{2<3FbJ2M9NHr-L9gWr&vKJtQ)gPbR(8VIFq7#%lHjtDArk$ zGfFWR-3ndTv%ilN+7S9BeF96NX;T#uNihd9MHBpJq?K?*R|6JZPyY`+Q2bzmNXF+O z(1-_=O-O{MSs-zgbSW8e#OK|%K^LG&f0k1U8KWec>&`aF0uS_?p?(pWbfFR>!h9q`4@wtqbNZe?ykI5wG*w0w(mwnJxboiPA-=g+8o)97V-1f^br}R>j zE<*V2cc)>J0kb@Fc%lqrpv_~!&=5KuZ=6%Qkm)_MeHQ74jdDU`0W6o6VSGj+3@CbB zZ#~a9Kn7t$@Sfsj3^}R1!qRe|rE()ijz~K}%C6H6L_Opg30l zTKJ~wS7k%EySLhcbzcD+w{lxD$OR5`+0!wkOzL3^rLk?976G2)7k~^PB4C13rI0v= zTqyBYfQz0lM?(+5%$~Fa)bvDPDOJ6Hmfg3|P8hOS4Z=S&-XakRj&4{kHxmRUy)%Mu z^>9hjiGNFE;?(Qv^77QY=Cl8WBn)!NMp8K+IWI{PyAS^=ti`V-%mKbbi5@{FzWJ z=0f7BBf30K55*ZvRe@&qTY-59eN9R`gY(Q$z{eXCG(6#_SX#aodF7}Owpf{h4mIh2 z5@McZ`G^vcsE#ko6$6=~LK!o&1UaI)keHti+pHtwQala8V}fbyiwsA;#;PnZ<1&OD zx06SdMK>*7t!;5S;aHegUy@{tr|a1ts>5-rW_WQ3V?>3L(}*G=&WiD?ZERKCuA{c_ z0$n$RbVAY(tpz0&K8iGKr4|Z)!i3b6C>2u=p)s^R{(z<##Q|jzqWV2RhGb$3n+hr; zgl?H*id<>=I91iBI5pH;GZ!iGp~lo}#rEyQ#WcBw+Lu&V?XSpuR-kU9(&JdLoJY8_ zL%(3iMXpUE#}S)OaT;rDBN+%y)4ZH~m9@1Qk_;$DGd1~8vvoCLk60=q!g51alrW{6 z#RM!DmQ6NmUUPzt4q!KUD})9AP04 zpTE%U=XlCycIuULI)@QQnm1#KIec5O`rE()osz1LqAb_r?9@I_@l?;d`-30f5ZlB* zax6BjQJ)wJEUofVGQ+9TUPCg9iGIpB8{y9$fmTm$tNelpza+p{>tUH^z9FRR6-9>X zSv6UqeTAjbCRdNl=%rqJCAbIGYD{}u>{~9Gh>%_(JpPi;4a0oy4w8WTVZ?x1bFX@?HQ^e?n-eE@G za%x>|;g7u^`<~~eEXJ3Z;z%-XCODE&HS;vX@Nd6+9vY8HO61(Ueg>~78zJg0|CMz9 ztX+FC&M2EJUGxkZ51?F>K4@90%j<<;KN$3ap09X|t_MMX;J-&R)Iad2BqfnC&7QJ_ zh$BidC1Pr@*}*P^zG7P8ws4AR;tk>N*+>m_$}FilWX4EpMUSKs^BJNc>`h6kv!+Zf zyH5V+@aXFGuh-{iM<)uukZP5p3ye^7gVQ(!&Y~L;j}-p50>g!RJpRc@sVZKSw3s4p z%m^(fa{vO(uqLN8M={|cbh<2)hE?6FNJqDnaNVDCJ$^_f_Em|(zRjXD$MIUd_p@1~ zfDGRq88XW^kf{~AkT{L7g(AqGSjp}yQdChn&3cLiG%xc5P5US>D2AY5NkSdDGsI#5AL7MS>P7Z4g=(@jyxU8`|lHRX$<)<$`r9;L)h4P2T}N0^_FuaLO8q)e*u zY@phCreElVF%mZ*)H_YwRRv-bf^_X=6g>kw2%N?t2sXt&iNCg&^xrqN`TtArZ1?Q^ z>f|zzALM7@ShN4Pv)k)6{QvuV`@OCI|0z;GfLGS(?(EFL+l$vQnyU$aYTZ==gPNA3 zG!~(Ecjp5cL-5Y*6cx)jJ4u53dtHK~bb{fzS^+`$a-pa)NB5v0xKMLdMu!G#$r5VTy{#5 z?V>o)-V6;7e^B#QI6FT+xgMThT)lk$ol>GmQkY-~zMrBg78!~#C_*kURV%9CtjxW? z2cN-v!BR!!%g$Y(mO_E{1pL90syEXDuh!BQ#1#OZZIGi<6AX9&!sb=bwR@E(C$p386s2(ZQytU;8&LG)x<55 zQ36EIc~m=HmH76--7RJj__q)2#BZxkyga#hcY4&)j~ehM6g&(y_u>{y_V2T)MH5ygrMf6VwT;;}=%!Vx~NGsU$4U)%nE?X-IScb#CWmWhGPJ|h%l z-TZHFuNnVwu)Dvvo&P;Wy1VQC;GKNPwBNX~^QpbQf%ik#j=(VMc^bj~j{Zrem-%>1K0wFsG^T2vru4|{u%Z%!GFfx@BS(~s369ke zVt3kq!3MT2FBJyW9swg9AvNNtrKP(msavl1WCS3NjaL}k&0`|qyU|>8<@oGUl~r>9 zH5h&$c&B6FW=JwXN()tO`~#6D!eyl0?XmI7E8;D+8!@@E&jq8MNq94mpy1!q_nYuu z*EmfHdu#p|h6xK;kk^QaOgs--Q1+(P_XkNH-U?_MbHYbb3~4 zjtyi~y{dcHii#ooJO9~%&UNSEs>P;LmKtis zX4IOphTH_xX&{oWZb7(qs%aY<7*bZ371p8s+M){_$+B!XECY_zyTw^n8ELBK4+~X3 z!XG)4xWSf1D8^+K`=fbSn~2y@l~%SE-uMSGw%KC8l^hc+via<@1w=9X3>PL=tE9ha zDB440Hf^dK=5w}ebgLH&Y@|)Y+gM}pa8tMC&iGPb=-3|%D~?tG3uDOFw)Tr@ z_582$;|JL+`qYTvb@Bf@2aWmPptnER#{WM_s>T2Jy&ICoAqf=+Vjr3pd0)P5>fHm>|yMz6MrvC44_5W$o zf_V;bIx`m7w_5&>^PjHY9G)G%I=Q&M7#>|89v@$vTwZ!$R4Igxj$uleke#y9+2Na$ z%i-bCNmXo_>!z&p^Xt>Ie_jtS&W9%#SEnZqhL2kR-?Ne3Gz@qa6@KOrO7zWAW=k=! zJB)$ZTwNGCs@>F}wr^Rum?aW74}<9JsICWTMoS$8v)>==Exd2pja`Xwp?rbViIfP+ zSc(NuEu{(oW{fR^A(o86_I*)_VGfd$n9H0F3_EqyG$}*hB zm|x&=5V2G+iUW?v@Dh&9)1fV3_UXwa@vTFjP$K7n3HPjKytZx!r}hjiJowT#R;!4fX0Mkvst$eo>O&E`T`rEVZtXL2)P#A zu^=>dj&ZymW>P?O=&RynHfe9YbgP~PwJ@S3aGWxAz2j_5sOtVQeoY4=)faY63oz4@ zzBl^lN8J=uaX22BgBn8}$+rR1b)`puQ+1xmN2XSh^$5`GLRVsNvmXIVO;t)HPHr7X zvKfX-9P8CsqFb)Uj;kQd_9a-uZQ~aKm&W5{NL%4OT3WxY)@p}QvC`wU$XFpcl6W#Vlo+FY zfsG4Cy)NQaO)w^sQS#cM{8MRvIQ3AT#ImF~+*XO!sQPreK7}%Xg17qjg41lhAF$2Q z7L;KWKvE))%6(n;sDx>hQFC99AAW+O8z*4Ggaj|jyv`4tBb)d4;gUiUO)6Tn{i+T< z^_*-QgA~GV9g%cisQHxo8zt;E1^>ccNwA?kdVsxopz(N^6<9l>Z#-6aes_4~+VRkh zZ_&|Ebzx~3{Qy2fO41mo68eLxXQCAnQZ2l`uxOOWZx;?Lm-@vgLWxL4QjIY>Vxi6v zA8OGHdM&mC@C^P@t`6a1c%-Y=Di#AV&!V*ecN+jll#R45W4;`)Dzp~zUIX$UIp%XU zTqUG+kLcm>^!n|^>o%!# zoS$LoUTZ?RJbZUDJU>0Vx*i^0{k}#(({-C1<7XLnE%FMy0R)>xCoI+_5sOm-pQZw_E@X z--uh;maT7EJq-&M?k`ir+EJp);Y!R+OZu86{6S)#B5H@;+DNxr|I4iEBA72= z|9j2z|ARrVzm5NUlC)v}CmH%;>%T#-x3duc+27v({3NMy%)+_#%Dv5@7M$SRk~JGx zi}82H$)7Bhhz?nNXiH$;K4*Nu8T5v!S#-56Ig#Xgkak`3q3OEP<9X?pZwtLp`3vC} zm4SG0D{9w;IrCPR;Z7M_$-Po+S*5Cst%M~fk;}05?p=L3S>bi_%XkelCHLxH+RA-r z_!4D#nPU*RURMLk!RPKj&9Iu(J1>_uc{9ozzR9(mSaJW_Co;p{X!Jz<*ns|jl|xC} z^kiv6`(NC<^GS1nb@so%+g$(kx8HwwqO|5FC%<9*t4o1{n;*@|+G5doYO4NqOn%F5 zRM9-=Zeml?y{y<?$ycgM2wb@72ZOLj>UjVycu{Tla7Do)fiw#}W})$8e@ zTJ?M}62V@(+Y*&xjt^<@&(}vav`n(L6O4bQw4wdyjD9iy?@q6`aQ<_@zuo_RlH?k9 zK0=XNSR`sOuZ`h?k-uQH%`N;HvFDFt>q}GOtJS>zZbv!p`^Fz!znxltDQ0*I6IHah z$3ov7{SP*Rql;s^^VA4NvatO3Y$TjP(|k21qd7;kyct7ZX%^)|vS|rOgPCDIav)By zEPqoXs)zD~gn7)f*nNyK#m-}fWR#RoxAw_p2mIEt5uMJ*27c?9YsIH16P*{($ylua z7k5tD8ir(5TGOOTOt4h{6vgVl#;AT6GSx3bp@yno{=P^M$}-VLl-|f2=Tu<1Kte0x z7T9*1(8_Qdmg*>v3E0x-ch=#nIAGh?f_f8VEAjm9dA{%0PX%qLoVAJG?FevY)xmn(LI)3#x# zB%!GH^p3MO{SOjMr(}{cjvocbI{n{k>VJQ4aM0iC|5K!AFho*fZayMwI$bT^>_>;y zqAf$wjrl}$@v+Q2GoQ&638oY#RDWMcMhQtLFMwl;B$;9D3wQES8hg(m#S`;|k?%5& z$K(T!jdK3S_W_)zbPg=lH5EyaVXnXU7kI((<@Kdx9DC2eUR3+;=n`VWg%?bS?CQUU zd@mUN$-DY*k&#Tg>QC_~W@)zqG(yo$p6L^C!uuf*x0&}tFhV!p4}qMj-;9%q_rw2s z&)^;6gyjNGk57abWSps`rx%bIqpm5=*?TXTiHOCxyLEhT(>86>Upf6>00030{|U^L IlK_YS0HR-?lK=n! literal 0 HcmV?d00001 diff --git a/helm/index.yaml b/helm/index.yaml index 347073e..678c5d9 100644 --- a/helm/index.yaml +++ b/helm/index.yaml @@ -1,6 +1,16 @@ apiVersion: v1 entries: flink-kube-operator: + - apiVersion: v2 + appVersion: 0.1.0 + created: "2025-04-04T13:50:27.971040367+03:30" + description: Helm chart for flink kube operator + digest: 00acef7878bcf372d036fabaac400913097d678087a756102b54a28428197bdf + name: flink-kube-operator + type: application + urls: + - flink-kube-operator-0.1.14.tgz + version: 0.1.14 - apiVersion: v2 appVersion: 0.1.0 created: "2025-03-04T23:13:19.698003661+03:30" @@ -43,7 +53,7 @@ entries: version: 0.1.10 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.495842696+03:30" + created: "2025-04-04T13:50:27.975218534+03:30" description: Helm chart for flink kube operator digest: abc08853c65ba36ff3485f182555522408e150f2508d4cac672d588972ddca3c name: flink-kube-operator @@ -53,7 +63,7 @@ entries: version: 0.1.9 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.495392608+03:30" + created: "2025-04-04T13:50:27.974750898+03:30" description: Helm chart for flink kube operator digest: 3986a0a2348db1e17a1524eb0d87eabf6d64050d4007c5b393f723393cc4b675 name: flink-kube-operator @@ -63,7 +73,7 @@ entries: version: 0.1.8 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.494948853+03:30" + created: "2025-04-04T13:50:27.974306458+03:30" description: Helm chart for flink kube operator digest: 1bbeb92ecd10e36fa7d742a61cced0d842139ada0cfeff6fa1b0cf8718189235 name: flink-kube-operator @@ -73,7 +83,7 @@ entries: version: 0.1.7 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.49450822+03:30" + created: "2025-04-04T13:50:27.973833587+03:30" description: Helm chart for flink kube operator digest: 4031f4a79e65f6c5e60b6ebf9dd7e2a663b1fb6f893056ad81ca33660f94406e name: flink-kube-operator @@ -83,7 +93,7 @@ entries: version: 0.1.6 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.494040193+03:30" + created: "2025-04-04T13:50:27.972800097+03:30" description: Helm chart for flink kube operator digest: 22ed155c8538ca5e7dc26863304eb9f76b09c454edbf709a891d7ccc440f35f6 name: flink-kube-operator @@ -93,7 +103,7 @@ entries: version: 0.1.5 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.493584927+03:30" + created: "2025-04-04T13:50:27.972374168+03:30" description: Helm chart for flink kube operator digest: b548a64ef89bbcd12d92fefffd1fd37758e8fccda02aecd97c7519a08f10fa4a name: flink-kube-operator @@ -103,7 +113,7 @@ entries: version: 0.1.4 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.493138547+03:30" + created: "2025-04-04T13:50:27.971952322+03:30" description: Helm chart for flink kube operator digest: 05a9664f574e2d5d1cca764efb6481ad21b9176663b907973a8ef5264f15a91f name: flink-kube-operator @@ -113,7 +123,7 @@ entries: version: 0.1.3 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.492696005+03:30" + created: "2025-04-04T13:50:27.971461428+03:30" description: Helm chart for flink kube operator digest: 89345b1a9a79aa18b646705aeb8cfdc547629600cb8a00708a3f64d188f296f2 name: flink-kube-operator @@ -123,7 +133,7 @@ entries: version: 0.1.2 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.490170385+03:30" + created: "2025-04-04T13:50:27.968770748+03:30" description: Helm chart for flink kube operator digest: 1d2af9af6b9889cc2962d627946464766f1b65b05629073b7fffb9a98cd957e2 name: flink-kube-operator @@ -133,7 +143,7 @@ entries: version: 0.1.1 - apiVersion: v2 appVersion: 0.1.0 - created: "2025-03-04T18:04:35.489734651+03:30" + created: "2025-04-04T13:50:27.968266924+03:30" description: Helm chart for flink kube operator digest: 0890d955904e6a3b2155c086a933b27e45266d896fb69eaad0e811dea40414da name: flink-kube-operator @@ -141,4 +151,4 @@ entries: urls: - flink-kube-operator-0.1.0.tgz version: 0.1.0 -generated: "2025-03-04T23:13:19.694944031+03:30" +generated: "2025-04-04T13:50:27.967565847+03:30"