[jira] [Closed] (FLINK-19445) Several tests for HBase connector 1.4 failed with "NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V"

[ https://issues.apache.org/jira/browse/FLINK-19445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-19445. -- Resolution: Fixed Master: f30caf87879a013920622039c0707e0c6d7cf08c > Several tests for HBase connecto

[jira] [Commented] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT"

[ https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204538#comment-17204538 ] Gyula Fora commented on FLINK-19469: Not sure what to do with this: ReasonPhrase:Ser

[jira] [Closed] (FLINK-17617) Flink SQL CLI Autocomplete does not return correct hints

[ https://issues.apache.org/jira/browse/FLINK-17617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-17617. -- Resolution: Fixed Merged: a17da14fc00a1b13e6e8106863a3e049fbc217f5 > Flink SQL CLI Autocomplete does

[jira] [Created] (FLINK-18752) Yarn ship logic should support files

Gyula Fora created FLINK-18752: -- Summary: Yarn ship logic should support files Key: FLINK-18752 URL: https://issues.apache.org/jira/browse/FLINK-18752 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17174124#comment-17174124 ] Gyula Fora commented on FLINK-16441: I think it would make more sense to upgrade thi

[jira] [Assigned] (FLINK-19447) HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "Master not initialized after 200000ms"

[ https://issues.apache.org/jira/browse/FLINK-19447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-19447: -- Assignee: Miklos Gergely > HBaseConnectorITCase.HBaseTestingClusterAutoStarter failed with "M

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242301#comment-17242301 ] Gyula Fora commented on FLINK-20221: master: 02f16958346483d91cd59cb902e0cce63fa5875

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242543#comment-17242543 ] Gyula Fora commented on FLINK-20221: release-1.12: b82a3dc3939bcf4fa5e6f398eafb7d0e9

[jira] [Commented] (FLINK-20221) DelimitedInputFormat does not restore compressed filesplits correctly leading to dataloss

[ https://issues.apache.org/jira/browse/FLINK-20221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245825#comment-17245825 ] Gyula Fora commented on FLINK-20221: Do you think we should also backport this to 1.

[jira] [Resolved] (FLINK-23356) HBase delegation token expired after 7 days

[ https://issues.apache.org/jira/browse/FLINK-23356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-23356. Resolution: Fixed Fixed for master via 657df14677a8f4e500efdc79627f095e32e8c4b4 > HBase delegatio

[jira] [Assigned] (FLINK-23693) Add principal creation possibilities to SecureTestEnvironment

[ https://issues.apache.org/jira/browse/FLINK-23693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-23693: -- Assignee: Gyula Fora > Add principal creation possibilities to SecureTestEnvironment > --

[jira] [Assigned] (FLINK-23688) Make JaasModule.getAppConfigurationEntries public

[ https://issues.apache.org/jira/browse/FLINK-23688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-23688: -- Assignee: Gyula Fora > Make JaasModule.getAppConfigurationEntries public > --

[jira] [Commented] (FLINK-23688) Make JaasModule.getAppConfigurationEntries public

[ https://issues.apache.org/jira/browse/FLINK-23688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17396508#comment-17396508 ] Gyula Fora commented on FLINK-23688: Straightforward change to expose a valuable uti

[jira] [Updated] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-24020: --- Affects Version/s: 1.14.0 > Aggregate HTTP requests before custom netty handers are getting the data

[jira] [Assigned] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-24020: -- Assignee: Gabor Somogyi > Aggregate HTTP requests before custom netty handers are getting the

[jira] [Commented] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405667#comment-17405667 ] Gyula Fora commented on FLINK-24020: Thanks for catching this issue Gabor, lets try

[jira] [Commented] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410447#comment-17410447 ] Gyula Fora commented on FLINK-24020: Merged to master in 6af5c9af6a252a7088c69ac64ab

[jira] [Commented] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410449#comment-17410449 ] Gyula Fora commented on FLINK-24020: We will cherry-pick this to 1.14 as well to mak

[jira] [Commented] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410586#comment-17410586 ] Gyula Fora commented on FLINK-24020: Merged to release-1.14 in c3e64ad654137fe196af3

[jira] [Resolved] (FLINK-24020) Aggregate HTTP requests before custom netty handers are getting the data

[ https://issues.apache.org/jira/browse/FLINK-24020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-24020. Resolution: Fixed > Aggregate HTTP requests before custom netty handers are getting the data > ---

[jira] [Resolved] (FLINK-23688) Make JaasModule.getAppConfigurationEntries public

[ https://issues.apache.org/jira/browse/FLINK-23688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-23688. Resolution: Fixed Merged to master: 0a0e37e6f2656c99a01305d9e736cea8d8a9febd   > Make JaasModule

[jira] [Resolved] (FLINK-23693) Add principal creation possibilities to SecureTestEnvironment

[ https://issues.apache.org/jira/browse/FLINK-23693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-23693. Resolution: Fixed Merged to master: f22b6ddc08dcd046458b4aeebfe828073410952a > Add principal crea

[jira] [Assigned] (FLINK-24674) Create corresponding resouces for task manager Pods

[ https://issues.apache.org/jira/browse/FLINK-24674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-24674: -- Assignee: L. C. Hsieh > Create corresponding resouces for task manager Pods > ---

[jira] [Created] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

Gyula Fora created FLINK-26078: -- Summary: Initial Kubernetes Operator Prototype contribution Key: FLINK-26078 URL: https://issues.apache.org/jira/browse/FLINK-26078 Project: Flink Issue Type: Su

[jira] [Updated] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

[ https://issues.apache.org/jira/browse/FLINK-26078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-26078: --- Component/s: Deployment / Kubernetes > Initial Kubernetes Operator Prototype contribution >

[jira] [Commented] (FLINK-26078) Initial Kubernetes Operator Prototype contribution

[ https://issues.apache.org/jira/browse/FLINK-26078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490976#comment-17490976 ] Gyula Fora commented on FLINK-26078: [~wangyang0918] Thank you, your operator poc he

[jira] [Closed] (FLINK-1493) Support for streaming jobs preserving global ordering of records

[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-1493. - Resolution: Won't Do > Support for streaming jobs preserving global ordering of records > ---

[jira] [Created] (FLINK-26135) Separate job and deployment errors in FlinkDeployment status

Gyula Fora created FLINK-26135: -- Summary: Separate job and deployment errors in FlinkDeployment status Key: FLINK-26135 URL: https://issues.apache.org/jira/browse/FLINK-26135 Project: Flink Iss

[jira] [Created] (FLINK-26136) Implement shared validation logic for FlinkDeployment objects

Gyula Fora created FLINK-26136: -- Summary: Implement shared validation logic for FlinkDeployment objects Key: FLINK-26136 URL: https://issues.apache.org/jira/browse/FLINK-26136 Project: Flink Is

[jira] [Created] (FLINK-26138) Create controller test

Gyula Fora created FLINK-26138: -- Summary: Create controller test Key: FLINK-26138 URL: https://issues.apache.org/jira/browse/FLINK-26138 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-26137) Create webhook REST api test

Gyula Fora created FLINK-26137: -- Summary: Create webhook REST api test Key: FLINK-26137 URL: https://issues.apache.org/jira/browse/FLINK-26137 Project: Flink Issue Type: Sub-task Compo

[jira] [Created] (FLINK-26139) Improve JobStatus tracking and handle different job states

Gyula Fora created FLINK-26139: -- Summary: Improve JobStatus tracking and handle different job states Key: FLINK-26139 URL: https://issues.apache.org/jira/browse/FLINK-26139 Project: Flink Issue

[jira] [Created] (FLINK-26140) Add basic handling mechanism to deal with job upgrade errors

Gyula Fora created FLINK-26140: -- Summary: Add basic handling mechanism to deal with job upgrade errors Key: FLINK-26140 URL: https://issues.apache.org/jira/browse/FLINK-26140 Project: Flink Iss

[jira] [Created] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

Gyula Fora created FLINK-26142: -- Summary: Integrate flink-kubernetes-operator repo with CI/CD Key: FLINK-26142 URL: https://issues.apache.org/jira/browse/FLINK-26142 Project: Flink Issue Type: S

[jira] [Created] (FLINK-26141) Support last-state upgrade mode

Gyula Fora created FLINK-26141: -- Summary: Support last-state upgrade mode Key: FLINK-26141 URL: https://issues.apache.org/jira/browse/FLINK-26141 Project: Flink Issue Type: Sub-task Co

[jira] [Assigned] (FLINK-26157) Containers Should Not Run As Root

[ https://issues.apache.org/jira/browse/FLINK-26157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26157: -- Assignee: Matyas Orhidi > Containers Should Not Run As Root > ---

[jira] [Commented] (FLINK-26142) Integrate flink-kubernetes-operator repo with CI/CD

[ https://issues.apache.org/jira/browse/FLINK-26142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17492541#comment-17492541 ] Gyula Fora commented on FLINK-26142: Github actions sound perfect to me as long as w

[jira] [Created] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces

Gyula Fora created FLINK-26163: -- Summary: Refactor FlinkUtils#getEffectiveConfig into smaller pieces Key: FLINK-26163 URL: https://issues.apache.org/jira/browse/FLINK-26163 Project: Flink Issue

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652434#comment-17652434 ] Gyula Fora commented on FLINK-30518: This may be related to: https://issues.apache.

[jira] [Created] (FLINK-30519) Add e2e tests for operator dynamic config

Gyula Fora created FLINK-30519: -- Summary: Add e2e tests for operator dynamic config Key: FLINK-30519 URL: https://issues.apache.org/jira/browse/FLINK-30519 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652503#comment-17652503 ] Gyula Fora commented on FLINK-30518: You are right [~tbnguyen1407] , those issues ar

[jira] [Updated] (FLINK-30519) Add e2e tests for operator dynamic config

[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30519: --- Priority: Critical (was: Blocker) > Add e2e tests for operator dynamic config > ---

[jira] [Updated] (FLINK-30519) Add e2e tests for operator dynamic config

[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30519: --- Issue Type: Technical Debt (was: New Feature) > Add e2e tests for operator dynamic config > ---

[jira] [Created] (FLINK-30527) Last-state suspend followed by flinkVersion change may lead to state loss

Gyula Fora created FLINK-30527: -- Summary: Last-state suspend followed by flinkVersion change may lead to state loss Key: FLINK-30527 URL: https://issues.apache.org/jira/browse/FLINK-30527 Project: Flink

[jira] [Created] (FLINK-30528) Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing

Gyula Fora created FLINK-30528: -- Summary: Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing Key: FLINK-30528 URL: https://issues.apache.org/jira/browse/FLINK-30528

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652512#comment-17652512 ] Gyula Fora commented on FLINK-30518: [~bgeng777] I think this is not related to any

[jira] [Created] (FLINK-30529) Use simple cancel for savepoint upgrades on failing jobs

Gyula Fora created FLINK-30529: -- Summary: Use simple cancel for savepoint upgrades on failing jobs Key: FLINK-30529 URL: https://issues.apache.org/jira/browse/FLINK-30529 Project: Flink Issue Ty

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652529#comment-17652529 ] Gyula Fora commented on FLINK-30518: Strange, the standalone and native integration

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: kubernetes-operator-1.3.0 (was: 1.16.0)

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Component/s: Kubernetes Operator (was: API / Core) > Arguments contains with '#

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: (was: kubernetes-operator-1.3.0) > Arguments contains with '#' will error spl

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Component/s: API / Core (was: Kubernetes Operator) > Arguments contains with '#

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: 1.15.3 1.16.0 > Arguments contains with '#' will error spl

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652532#comment-17652532 ] Gyula Fora commented on FLINK-30518: But can you clarify what doesn't work with mult

[jira] [Closed] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error

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

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652535#comment-17652535 ] Gyula Fora commented on FLINK-30518: Please test this with replicas 1 and 2 and see

[jira] [Assigned] (FLINK-30527) Last-state suspend followed by flinkVersion change may lead to state loss

[ https://issues.apache.org/jira/browse/FLINK-30527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30527: -- Assignee: Gyula Fora > Last-state suspend followed by flinkVersion change may lead to state l

[jira] [Assigned] (FLINK-30528) Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing

[ https://issues.apache.org/jira/browse/FLINK-30528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30528: -- Assignee: Gyula Fora > Job may be stuck in upgrade loop when last-state fallback is disabled

[jira] [Closed] (FLINK-30429) Flink command stops with IllegalArgumentException

[ https://issues.apache.org/jira/browse/FLINK-30429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30429. -- Fix Version/s: 1.17.0 Resolution: Fixed merged to master: 259c7a4776af4d9d7f174f871fb2d4145787f

[jira] [Assigned] (FLINK-30404) Do not redeploy taskmanagers on standalone application scaling

[ https://issues.apache.org/jira/browse/FLINK-30404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30404: -- Assignee: (was: Gyula Fora) > Do not redeploy taskmanagers on standalone application scal

[jira] [Assigned] (FLINK-29607) Simplify controller flow by introducing FlinkControllerContext

[ https://issues.apache.org/jira/browse/FLINK-29607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-29607: -- Assignee: Gyula Fora > Simplify controller flow by introducing FlinkControllerContext > -

[jira] [Updated] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30530: --- Affects Version/s: (was: 1.15.2) > Flink configuration from user-provided ConfigMap > --

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653132#comment-17653132 ] Gyula Fora commented on FLINK-30530: Because flink and log config is probably differ

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653133#comment-17653133 ] Gyula Fora commented on FLINK-30530: The YAML descriptor too is very application spe

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653167#comment-17653167 ] Gyula Fora commented on FLINK-30530: At the end of the day you would still need to c

[jira] [Closed] (FLINK-30527) Last-state suspend followed by flinkVersion change may lead to state loss

[ https://issues.apache.org/jira/browse/FLINK-30527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30527. -- Fix Version/s: kubernetes-operator-1.4.0 kubernetes-operator-1.3.1 Resolution

[jira] [Closed] (FLINK-30528) Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing

[ https://issues.apache.org/jira/browse/FLINK-30528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30528. -- Fix Version/s: kubernetes-operator-1.4.0 kubernetes-operator-1.3.1 Resolution

[jira] [Commented] (FLINK-30361) Cluster deleted and created back while updating replicas

[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653432#comment-17653432 ] Gyula Fora commented on FLINK-30361: release-1.3 7da3cdd6ec4bfd20f24d27dc70df1c40abe

[jira] [Updated] (FLINK-30361) Cluster deleted and created back while updating replicas

[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30361: --- Fix Version/s: kubernetes-operator-1.3.1 > Cluster deleted and created back while updating replicas

[jira] [Updated] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error

[ https://issues.apache.org/jira/browse/FLINK-30406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30406: --- Issue Type: Bug (was: Improvement) > Jobmanager Deployment error without HA metadata should not lea

[jira] [Assigned] (FLINK-30408) Add unit test for HA metadata check logic

[ https://issues.apache.org/jira/browse/FLINK-30408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30408: -- Assignee: Gyula Fora > Add unit test for HA metadata check logic > --

[jira] [Assigned] (FLINK-30329) flink-kubernetes-operator helm chart does not work with dynamic config because of use of volumeMount subPath

[ https://issues.apache.org/jira/browse/FLINK-30329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30329: -- Assignee: Andrew Otto > flink-kubernetes-operator helm chart does not work with dynamic confi

[jira] [Comment Edited] (FLINK-29634) Support periodic checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653583#comment-17653583 ] Gyula Fora edited comment on FLINK-29634 at 1/2/23 11:22 AM: -

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653583#comment-17653583 ] Gyula Fora commented on FLINK-29634: Let's clear a few things up here a little. The

[jira] [Closed] (FLINK-30213) The edge is wrong when the vertex parallelism is changed

[ https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30213. -- Resolution: Fixed Merged to main: ded2df542fd5d585842e77d021fb84a92a5bea76..1c2f4eb4ba1d1b5ad403d79911

[jira] [Commented] (FLINK-29634) Support periodic checkpoint triggering

[ https://issues.apache.org/jira/browse/FLINK-29634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653846#comment-17653846 ] Gyula Fora commented on FLINK-29634: Yea, the Mock classes can be tricky [~Jiale] I

[jira] [Updated] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30411: --- Fix Version/s: kubernetes-operator-1.4.0 > Flink deployment stuck in UPGRADING state when deploy fli

[jira] [Closed] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30411. -- Resolution: Fixed merged to main 4feee47f0175d12ad192fbfc89d483793dcae5b8 > Flink deployment stuck in

[jira] [Updated] (FLINK-30466) Detect ineffective scaling operations

[ https://issues.apache.org/jira/browse/FLINK-30466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30466: --- Fix Version/s: (was: kubernetes-operator-1.4.0) > Detect ineffective scaling operations > --

[jira] [Closed] (FLINK-30466) Detect ineffective scaling operations

[ https://issues.apache.org/jira/browse/FLINK-30466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30466. -- Resolution: Won't Fix I am closing this in order to replace with some more concrete tasks around scal

[jira] [Created] (FLINK-30571) Compute scale parallelism based on observed scalability

Gyula Fora created FLINK-30571: -- Summary: Compute scale parallelism based on observed scalability Key: FLINK-30571 URL: https://issues.apache.org/jira/browse/FLINK-30571 Project: Flink Issue Ty

[jira] [Created] (FLINK-30574) Do not scale further up if last scaling was ineffective

Gyula Fora created FLINK-30574: -- Summary: Do not scale further up if last scaling was ineffective Key: FLINK-30574 URL: https://issues.apache.org/jira/browse/FLINK-30574 Project: Flink Issue Typ

[jira] [Created] (FLINK-30575) Autoscaler doesn't scale down on 0 load

Gyula Fora created FLINK-30575: -- Summary: Autoscaler doesn't scale down on 0 load Key: FLINK-30575 URL: https://issues.apache.org/jira/browse/FLINK-30575 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-29607) Simplify controller flow by introducing FlinkControllerContext

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

[jira] [Commented] (FLINK-30577) OpenShift FlinkSessionJob artifact write error on non-default namespaces

[ https://issues.apache.org/jira/browse/FLINK-30577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655131#comment-17655131 ] Gyula Fora commented on FLINK-30577: Or users on open shift could simply configure t

[jira] [Commented] (FLINK-30577) OpenShift FlinkSessionJob artifact write error on non-default namespaces

[ https://issues.apache.org/jira/browse/FLINK-30577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655285#comment-17655285 ] Gyula Fora commented on FLINK-30577: I just wanted to point out this possiblity as w

[jira] [Created] (FLINK-30593) Determine restart time on the fly for Autoscaler

Gyula Fora created FLINK-30593: -- Summary: Determine restart time on the fly for Autoscaler Key: FLINK-30593 URL: https://issues.apache.org/jira/browse/FLINK-30593 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-30574) Do not scale further up if last scaling was ineffective

[ https://issues.apache.org/jira/browse/FLINK-30574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30574: --- Component/s: Autoscaler > Do not scale further up if last scaling was ineffective >

[jira] [Updated] (FLINK-30575) Autoscaler doesn't scale down on 0 load

[ https://issues.apache.org/jira/browse/FLINK-30575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30575: --- Component/s: Autoscaler > Autoscaler doesn't scale down on 0 load >

[jira] [Updated] (FLINK-30571) Compute scale parallelism based on observed scalability

[ https://issues.apache.org/jira/browse/FLINK-30571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30571: --- Component/s: Autoscaler > Compute scale parallelism based on observed scalability > ---

[jira] [Updated] (FLINK-30594) Update Java version because of JDK bug in the operator

[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30594: --- Fix Version/s: kubernetes-operator-1.4.0 > Update Java version because of JDK bug in the operator >

[jira] [Updated] (FLINK-30594) Update Java version because of JDK bug in the operator

[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30594: --- Priority: Critical (was: Blocker) > Update Java version because of JDK bug in the operator > --

[jira] [Commented] (FLINK-30609) Add ephemeral storage to CRD

[ https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17657075#comment-17657075 ] Gyula Fora commented on FLINK-30609: Are you suggesting simply adding: ``` ephemeral

[jira] [Commented] (FLINK-30609) Add ephemeral storage to CRD

[ https://issues.apache.org/jira/browse/FLINK-30609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17657076#comment-17657076 ] Gyula Fora commented on FLINK-30609: +1 from my part, this indeed seems to be a comm

[jira] [Commented] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675593#comment-17675593 ] Gyula Fora commented on FLINK-30638: I think the problem is that last-state mode use

[jira] [Commented] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675618#comment-17675618 ] Gyula Fora commented on FLINK-30638: Yes, we set the right configuration but allowNo

[jira] [Commented] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675628#comment-17675628 ] Gyula Fora commented on FLINK-30638: Yes, you could do that and that will work. Or y

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675911#comment-17675911 ] Gyula Fora commented on FLINK-30518: [~usamj] could you please take a look? > [flin

[jira] [Closed] (FLINK-30574) Do not scale further up if last scaling was ineffective

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

[jira] [Created] (FLINK-30652) Use max busytime instead of average to compute true processing rate

Gyula Fora created FLINK-30652: -- Summary: Use max busytime instead of average to compute true processing rate Key: FLINK-30652 URL: https://issues.apache.org/jira/browse/FLINK-30652 Project: Flink

<    3   4   5   6   7   8   9   10   11   12   >