[jira] [Commented] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

[ https://issues.apache.org/jira/browse/FLINK-36109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17884626#comment-17884626 ] Gyula Fora commented on FLINK-36109: I think adding these labels makes sense for now

[jira] [Closed] (FLINK-36353) Allow adding affinity for the pod template in the helm chart

[ https://issues.apache.org/jira/browse/FLINK-36353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36353. -- Resolution: Fixed merged to main d946f3f9f3a7f12098cd82db2545de7c89e220ff > Allow adding affinity for

[jira] [Commented] (FLINK-36340) Can not stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883990#comment-17883990 ] Gyula Fora commented on FLINK-36340: Thanks for reporting this issue, I am inclined

[jira] [Closed] (FLINK-36179) Bump log4j version

[ https://issues.apache.org/jira/browse/FLINK-36179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36179. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Siddharth R Resolution: Fixed merg

[jira] [Commented] (FLINK-36192) Optimize the logic to make it the common divisor of the partition number of the data source when determining the parallelism of the source task.

[ https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878531#comment-17878531 ] Gyula Fora commented on FLINK-36192: cc [~mxm]  > Optimize the logic to make it the

[jira] [Closed] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference

[ https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36162. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main d9282263baad879a6a00

[jira] [Assigned] (FLINK-36169) Support namespace level resource check before scaling up

[ https://issues.apache.org/jira/browse/FLINK-36169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36169: -- Assignee: Zhenqiu Huang > Support namespace level resource check before scaling up >

[jira] [Closed] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36145. -- Resolution: Won't Fix > Change JobSpec.flinkStateSnapshotReference to snapshotReference >

[jira] [Closed] (FLINK-35266) Add e2e tests for FlinkStateSnapshot CRs

[ https://issues.apache.org/jira/browse/FLINK-35266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35266. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main cdd81c7973a9920916f6

[jira] [Commented] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference

[ https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877086#comment-17877086 ] Gyula Fora commented on FLINK-36162: cc [~thw]  > Remove flinkStateSnapshotReferenc

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877085#comment-17877085 ] Gyula Fora commented on FLINK-36145: I will probably close this in favour of https:

[jira] [Created] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference

Gyula Fora created FLINK-36162: -- Summary: Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference Key: FLINK-36162 URL: https://issues.apache.org/jira/browse/FLINK-36162 Pro

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876624#comment-17876624 ] Gyula Fora commented on FLINK-36145: I also like initialStateReference more, we coul

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876532#comment-17876532 ] Gyula Fora commented on FLINK-36145: [~mateczagany] let's hold off on this for a lit

[jira] [Created] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

Gyula Fora created FLINK-36145: -- Summary: Change JobSpec.flinkStateSnapshotReference to snapshotReference Key: FLINK-36145 URL: https://issues.apache.org/jira/browse/FLINK-36145 Project: Flink

[jira] [Commented] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876296#comment-17876296 ] Gyula Fora commented on FLINK-36145: What do you think [~mateczagany] ? > Change Jo

[jira] [Commented] (FLINK-33803) Add observedGeneration to Operator's status spec

[ https://issues.apache.org/jira/browse/FLINK-33803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17876196#comment-17876196 ] Gyula Fora commented on FLINK-33803: a10fb4501011be4e88fb6164156e3b9e8527950e > Add

[jira] [Closed] (FLINK-36110) Periodic save points trigger continuously

[ https://issues.apache.org/jira/browse/FLINK-36110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36110. -- Resolution: Fixed merged to main 0ef627edf001b56aac7d57ea8839546d7ed87681 > Periodic save points trig

[jira] [Created] (FLINK-36137) Missing JarURI leads to null pointer in reconciler

Gyula Fora created FLINK-36137: -- Summary: Missing JarURI leads to null pointer in reconciler Key: FLINK-36137 URL: https://issues.apache.org/jira/browse/FLINK-36137 Project: Flink Issue Type: Bu

[jira] [Closed] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API

[ https://issues.apache.org/jira/browse/FLINK-36031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36031. -- Resolution: Fixed merged to main 39e10d0f0bcec081ca9a91b7c053262f6ce09488 > Migrate kubernetes operat

[jira] [Closed] (FLINK-35493) Make max history age and count configurable for FlinkStateSnapshot resources

[ https://issues.apache.org/jira/browse/FLINK-35493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35493. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Mate Czagany Resolution: Fixed mer

[jira] [Assigned] (FLINK-36110) Periodic save points trigger continuously

[ https://issues.apache.org/jira/browse/FLINK-36110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36110: -- Assignee: Mate Czagany > Periodic save points trigger continuously > ---

[jira] [Updated] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

[ https://issues.apache.org/jira/browse/FLINK-36109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-36109: --- Priority: Critical (was: Major) > Improve FlinkStateSnapshot resource labels for efficient filterin

[jira] [Created] (FLINK-36110) Periodic save points trigger continuously

Gyula Fora created FLINK-36110: -- Summary: Periodic save points trigger continuously Key: FLINK-36110 URL: https://issues.apache.org/jira/browse/FLINK-36110 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36109) Improve FlinkStateSnapshot resource labels for efficient filtering

Gyula Fora created FLINK-36109: -- Summary: Improve FlinkStateSnapshot resource labels for efficient filtering Key: FLINK-36109 URL: https://issues.apache.org/jira/browse/FLINK-36109 Project: Flink

[jira] [Closed] (FLINK-36037) Add compability for 1.9 last savepoint info on upgrade/recovery

[ https://issues.apache.org/jira/browse/FLINK-36037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36037. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Mate Czagany Resolution: Fixed mer

[jira] [Commented] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17873506#comment-17873506 ] Gyula Fora commented on FLINK-35265: d10918c626c19964635a340fd99a627691fedf54 > Imp

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872859#comment-17872859 ] Gyula Fora commented on FLINK-36018: [~mxm] or simply `autoscaler.scale-down.interva

[jira] [Assigned] (FLINK-36031) Migrate kubernetes operator metrics from OKHttp Interceptor API to Fabric8 Interceptor API

[ https://issues.apache.org/jira/browse/FLINK-36031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36031: -- Assignee: Sam Barker > Migrate kubernetes operator metrics from OKHttp Interceptor API to Fab

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872783#comment-17872783 ] Gyula Fora commented on FLINK-36018: Based on your proposals how about simply `job.a

[jira] [Closed] (FLINK-35267) Documentation and examples for FlinkStateSnapshot CR

[ https://issues.apache.org/jira/browse/FLINK-35267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35267. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: Mate Czagany Resolution: Fixed mer

[jira] [Commented] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872402#comment-17872402 ] Gyula Fora commented on FLINK-36018: Hey Guys, I completely agree with what was said

[jira] [Closed] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35265. -- Resolution: Fixed > Implement FlinkStateSnapshot custom resource > ---

[jira] [Updated] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-35265: --- Fix Version/s: kubernetes-operator-1.10.0 > Implement FlinkStateSnapshot custom resource > -

[jira] [Commented] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872060#comment-17872060 ] Gyula Fora commented on FLINK-35265: merged to main: 0f390144cb8516d31aac61e46b9ce06

[jira] [Assigned] (FLINK-35265) Implement FlinkStateSnapshot custom resource

[ https://issues.apache.org/jira/browse/FLINK-35265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35265: -- Assignee: Mate Czagany > Implement FlinkStateSnapshot custom resource > -

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868784#comment-17868784 ] Gyula Fora commented on FLINK-35285: What we currently don't have is any measurement

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868726#comment-17868726 ] Gyula Fora commented on FLINK-35285: [~trystan] let meg give you a somewhat artifica

[jira] [Closed] (FLINK-35857) Operator restart failed job without latest checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35857. -- Fix Version/s: kubernetes-operator-1.10.0 Assignee: chenyuzhi Resolution: Fixed merged

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868252#comment-17868252 ] Gyula Fora commented on FLINK-35285: Looping in [~mxm] as he may have input here too

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868251#comment-17868251 ] Gyula Fora commented on FLINK-35285: "always act" would only make sense if we disabl

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868169#comment-17868169 ] Gyula Fora commented on FLINK-35285: It's much better to not scale down than to unde

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868168#comment-17868168 ] Gyula Fora commented on FLINK-35285: {noformat} I would argue that a current paralle

[jira] [Closed] (FLINK-35292) Set dummy savepoint path during last-state upgrade

[ https://issues.apache.org/jira/browse/FLINK-35292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35292. -- Resolution: Fixed merged to main 207b149f9b556d68c4ab98d16cdde2f7820659c0 > Set dummy savepoint path

[jira] [Closed] (FLINK-35776) Simplify job observe logic

[ https://issues.apache.org/jira/browse/FLINK-35776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35776. -- Resolution: Fixed merged to main 15f648ce46537d6a1df3a87cfd653a3f855d0dcd > Simplify job observe logi

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868069#comment-17868069 ] Gyula Fora commented on FLINK-35285: Hey [~trystan] sorry for the late reply. I see

[jira] [Commented] (FLINK-35857) Operator restart failed job without latest checkpoint

[ https://issues.apache.org/jira/browse/FLINK-35857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1783#comment-1783 ] Gyula Fora commented on FLINK-35857: Please upgrade to the latest operator version,

[jira] [Closed] (FLINK-35126) Improve checkpoint progress health check config and enable by default

[ https://issues.apache.org/jira/browse/FLINK-35126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35126. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main cb90b10c93241f9994ac

[jira] [Closed] (FLINK-35831) Rotate job id on savepoint upgrade as well

[ https://issues.apache.org/jira/browse/FLINK-35831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35831. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main 2b82a9343140515646f8

[jira] [Created] (FLINK-35831) Rotate job id on savepoint upgrade as well

Gyula Fora created FLINK-35831: -- Summary: Rotate job id on savepoint upgrade as well Key: FLINK-35831 URL: https://issues.apache.org/jira/browse/FLINK-35831 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-35814) Don't scale up continuously when the throughout cannot be increased after scaling up

[ https://issues.apache.org/jira/browse/FLINK-35814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865082#comment-17865082 ] Gyula Fora commented on FLINK-35814: I am generally in favour of enabling this by de

[jira] [Commented] (FLINK-35814) Don't scale up continuously when the throughout cannot be increased after scaling up

[ https://issues.apache.org/jira/browse/FLINK-35814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865024#comment-17865024 ] Gyula Fora commented on FLINK-35814: We already have the ineffective scaling detecti

[jira] [Created] (FLINK-35777) Observe session jobs during cleanup

Gyula Fora created FLINK-35777: -- Summary: Observe session jobs during cleanup Key: FLINK-35777 URL: https://issues.apache.org/jira/browse/FLINK-35777 Project: Flink Issue Type: Improvement

[jira] [Assigned] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob

[ https://issues.apache.org/jira/browse/FLINK-35279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35279: -- Assignee: Gyula Fora (was: Alan Zhang) > Support "last-state" upgrade mode for FlinkSessionJ

[jira] [Created] (FLINK-35776) Simplify job observe logic

Gyula Fora created FLINK-35776: -- Summary: Simplify job observe logic Key: FLINK-35776 URL: https://issues.apache.org/jira/browse/FLINK-35776 Project: Flink Issue Type: Improvement Comp

[jira] [Created] (FLINK-35746) Add logic to override observed config based on settings observed through REST API

Gyula Fora created FLINK-35746: -- Summary: Add logic to override observed config based on settings observed through REST API Key: FLINK-35746 URL: https://issues.apache.org/jira/browse/FLINK-35746 Project

[jira] [Closed] (FLINK-35640) Deprecate Flink 1.15 in the operator

[ https://issues.apache.org/jira/browse/FLINK-35640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35640. -- Assignee: Mate Czagany Resolution: Fixed merged to main f2adb1593393765d7b4c03213fda31e3683b120a

[jira] [Closed] (FLINK-35699) Incorrect Jackson shade through fabric8 in flink-kubernetes

[ https://issues.apache.org/jira/browse/FLINK-35699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35699. -- Assignee: Ferenc Csaky Resolution: Fixed 1.20: 7f40c35fc744a9cacb3310f3dcfbc8b8a82e5c7d 1.19: 74

[jira] [Commented] (FLINK-35699) Incorrect Jackson shade through fabric8 in flink-kubernetes

[ https://issues.apache.org/jira/browse/FLINK-35699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860785#comment-17860785 ] Gyula Fora commented on FLINK-35699: merged to master b32703f77f1e427411ef04a32c4fa2

[jira] [Closed] (FLINK-35649) Bump Flink version to 1.19.1 in k8s-operator

[ https://issues.apache.org/jira/browse/FLINK-35649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35649. -- Assignee: Ferenc Csaky Resolution: Fixed merged to main 7b01553101875ca669447335e4ff5d3be40eada1

[jira] [Assigned] (FLINK-31215) Backpropagate processing rate limits from non-scalable bottlenecks to upstream operators

[ https://issues.apache.org/jira/browse/FLINK-31215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-31215: -- Assignee: Artem Plyusnin (was: Gyula Fora) > Backpropagate processing rate limits from non-s

[jira] [Updated] (FLINK-31502) Limit the number of concurrent scale operations to reduce cluster churn

[ https://issues.apache.org/jira/browse/FLINK-31502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-31502: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-33789) Expose restart time as a metric

[ https://issues.apache.org/jira/browse/FLINK-33789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33789: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-33799) Add e2e's for tls enabled operator

[ https://issues.apache.org/jira/browse/FLINK-33799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33799: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-33673) SizeLimits not being set on emptyDir

[ https://issues.apache.org/jira/browse/FLINK-33673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33673: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-34907) jobRunningTs should be the timestamp that all tasks are running

[ https://issues.apache.org/jira/browse/FLINK-34907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34907: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-35471) Kubernetes operator bumps the flink version to 1.19

[ https://issues.apache.org/jira/browse/FLINK-35471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-35471: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-34539) Tune JobManager memory

[ https://issues.apache.org/jira/browse/FLINK-34539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34539: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-32119) Revise source partition skew logic

[ https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-32119: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-34151) Integrate Karpenter resource limits into cluster capacity check

[ https://issues.apache.org/jira/browse/FLINK-34151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34151: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-32120) Add autoscaler config option to disable parallelism key group alignment

[ https://issues.apache.org/jira/browse/FLINK-32120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-32120: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-34540) Tune number of task slots

[ https://issues.apache.org/jira/browse/FLINK-34540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34540: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Updated] (FLINK-33773) Add fairness to scaling decisions

[ https://issues.apache.org/jira/browse/FLINK-33773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33773: --- Fix Version/s: kubernetes-operator-1.10.0 (was: kubernetes-operator-1.9.0) >

[jira] [Closed] (FLINK-35594) Downscaling doesn't release TaskManagers.

[ https://issues.apache.org/jira/browse/FLINK-35594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35594. -- Resolution: Duplicate > Downscaling doesn't release TaskManagers. > --

[jira] [Updated] (FLINK-33977) Adaptive scheduler may not minimize the number of TMs during downscaling

[ https://issues.apache.org/jira/browse/FLINK-33977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33977: --- Affects Version/s: 1.19.0 1.20.0 > Adaptive scheduler may not minimize the nu

[jira] [Closed] (FLINK-35052) Webhook validator should reject unsupported Flink versions

[ https://issues.apache.org/jira/browse/FLINK-35052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35052. -- Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed merged to main ebd720329eeea983ce4ec

[jira] [Closed] (FLINK-35328) AutoScale supports setting the maximum floating parallelism by the number of Pulsar partitions

[ https://issues.apache.org/jira/browse/FLINK-35328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35328. -- Fix Version/s: kubernetes-operator-1.9.0 Assignee: Wenbing Shen Resolution: Fixed merg

[jira] [Created] (FLINK-35466) Cannot pass all columns to SQL UDFs using `*`

Gyula Fora created FLINK-35466: -- Summary: Cannot pass all columns to SQL UDFs using `*` Key: FLINK-35466 URL: https://issues.apache.org/jira/browse/FLINK-35466 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-35310) Replace RBAC verb wildcards with actual verbs

[ https://issues.apache.org/jira/browse/FLINK-35310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35310. -- Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed merged to main f21ed8d28b1e50ffe8300

[jira] [Assigned] (FLINK-35310) Replace RBAC verb wildcards with actual verbs

[ https://issues.apache.org/jira/browse/FLINK-35310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35310: -- Assignee: Tim > Replace RBAC verb wildcards with actual verbs > -

[jira] [Created] (FLINK-35414) Cancel jobs through rest api for last-state upgrades

Gyula Fora created FLINK-35414: -- Summary: Cancel jobs through rest api for last-state upgrades Key: FLINK-35414 URL: https://issues.apache.org/jira/browse/FLINK-35414 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-35126) Improve checkpoint progress health check config and enable by default

[ https://issues.apache.org/jira/browse/FLINK-35126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35126: -- Assignee: Gyula Fora > Improve checkpoint progress health check config and enable by default

[jira] [Created] (FLINK-35292) Set dummy savepoint path during last-state upgrade

Gyula Fora created FLINK-35292: -- Summary: Set dummy savepoint path during last-state upgrade Key: FLINK-35292 URL: https://issues.apache.org/jira/browse/FLINK-35292 Project: Flink Issue Type: Im

[jira] [Commented] (FLINK-35285) Autoscaler key group optimization can interfere with scale-down.max-factor

[ https://issues.apache.org/jira/browse/FLINK-35285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843254#comment-17843254 ] Gyula Fora commented on FLINK-35285: I think you make a good point here but we have

[jira] [Assigned] (FLINK-35279) Support "last-state" upgrade mode for FlinkSessionJob

[ https://issues.apache.org/jira/browse/FLINK-35279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35279: -- Assignee: Alan Zhang > Support "last-state" upgrade mode for FlinkSessionJob > -

[jira] [Commented] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842607#comment-17842607 ] Gyula Fora commented on FLINK-35192: Merged b1f4b3f35f907e1f6425ad2401dbf24309e6fb59

[jira] [Updated] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-35192: --- Fix Version/s: kubernetes-operator-1.9.0 > operator oom > > > Key: FLIN

[jira] [Updated] (FLINK-35192) Kubernetes operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-35192: --- Summary: Kubernetes operator oom (was: operator oom) > Kubernetes operator oom > --

[jira] [Commented] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842249#comment-17842249 ] Gyula Fora commented on FLINK-35192: That makes sense [~bgeng777] this would be a go

[jira] [Assigned] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish

[ https://issues.apache.org/jira/browse/FLINK-35157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-35157: -- Assignee: elon_X > Sources with watermark alignment get stuck once some subtasks finish > ---

[jira] [Closed] (FLINK-34574) Add CPU and memory size autoscaler quota

[ https://issues.apache.org/jira/browse/FLINK-34574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34574. -- Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed merged to main baad90088ea5b5b240186

[jira] [Created] (FLINK-35157) Sources with watermark alignment get stuck once some subtasks finish

Gyula Fora created FLINK-35157: -- Summary: Sources with watermark alignment get stuck once some subtasks finish Key: FLINK-35157 URL: https://issues.apache.org/jira/browse/FLINK-35157 Project: Flink

[jira] [Closed] (FLINK-31860) FlinkDeployments never finalize when namespace is deleted

[ https://issues.apache.org/jira/browse/FLINK-31860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31860. -- Fix Version/s: kubernetes-operator-1.9.0 Assignee: Zhou JIANG (was: Jayme Howard) Reso

[jira] [Created] (FLINK-35126) Improve checkpoint progress health check config and enable by default

Gyula Fora created FLINK-35126: -- Summary: Improve checkpoint progress health check config and enable by default Key: FLINK-35126 URL: https://issues.apache.org/jira/browse/FLINK-35126 Project: Flink

[jira] [Commented] (FLINK-35123) Flink Kubernetes Operator should not do deleteHAData

[ https://issues.apache.org/jira/browse/FLINK-35123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837610#comment-17837610 ] Gyula Fora commented on FLINK-35123: I agree that if the rest api is accessible we c

[jira] [Closed] (FLINK-35108) Deployment recovery is triggered on terminal jobs after jm shutdown ttl

[ https://issues.apache.org/jira/browse/FLINK-35108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35108. -- Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed merged to main be3b79b64440065c9ae9d

[jira] [Created] (FLINK-35108) Deployment recovery is triggered on terminal jobs after jm shutdown ttl

Gyula Fora created FLINK-35108: -- Summary: Deployment recovery is triggered on terminal jobs after jm shutdown ttl Key: FLINK-35108 URL: https://issues.apache.org/jira/browse/FLINK-35108 Project: Flink

[jira] [Comment Edited] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836106#comment-17836106 ] Gyula Fora edited comment on FLINK-34704 at 4/11/24 10:41 AM:

[jira] [Commented] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836107#comment-17836107 ] Gyula Fora commented on FLINK-34704: So restricting the optimisation to the head of

[jira] [Commented] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

[ https://issues.apache.org/jira/browse/FLINK-34704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836106#comment-17836106 ] Gyula Fora commented on FLINK-34704: I agree with [~pnowojski] here, the currently b

  1   2   3   4   5   6   7   8   9   10   >