[jira] [Commented] (FLINK-27154) Disable web.cancel.enable for application clusters

[ https://issues.apache.org/jira/browse/FLINK-27154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519990#comment-17519990 ] Nicholas Jiang commented on FLINK-27154: [~gyfora], I have worked this configuration. Please

[jira] [Commented] (FLINK-27141) Improve FlinkService#waitForClusterShutdown logic

[ https://issues.apache.org/jira/browse/FLINK-27141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519617#comment-17519617 ] Nicholas Jiang commented on FLINK-27141: [~gyfora], are you working for this ticket? If no, I

[jira] [Commented] (FLINK-27124) Flink Kubernetes operator prints starting logs with wrong version

[ https://issues.apache.org/jira/browse/FLINK-27124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518944#comment-17518944 ] Nicholas Jiang commented on FLINK-27124: [~wangyang0918], I have pushed a pull request for this

[jira] [Commented] (FLINK-27049) Add "What is Flink Kubernetes Operator?" link to flink website

[ https://issues.apache.org/jira/browse/FLINK-27049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518541#comment-17518541 ] Nicholas Jiang commented on FLINK-27049: [~gyfora], sorry for the mistake. Next time I will

[jira] [Updated] (FLINK-27097) Document custom validator implementations

[ https://issues.apache.org/jira/browse/FLINK-27097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-27097: --- Description: Currently we allow users to specify custom validator implementations through

[jira] [Updated] (FLINK-27097) Document custom validator implementations

[ https://issues.apache.org/jira/browse/FLINK-27097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-27097: --- Component/s: Kubernetes Operator > Document custom validator implementations >

[jira] [Created] (FLINK-27097) Document custom validator implementations

Nicholas Jiang created FLINK-27097: -- Summary: Document custom validator implementations Key: FLINK-27097 URL: https://issues.apache.org/jira/browse/FLINK-27097 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27023) Merge default flink and operator configuration settings for the operator

[ https://issues.apache.org/jira/browse/FLINK-27023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517581#comment-17517581 ] Nicholas Jiang commented on FLINK-27023: [~gyfora], do anyone work on this ticket? If no, I

[jira] [Commented] (FLINK-27029) DeploymentValidator should take default flink config into account during validation

[ https://issues.apache.org/jira/browse/FLINK-27029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17517576#comment-17517576 ] Nicholas Jiang commented on FLINK-27029: [~gyfora], do you mean that in

[jira] [Commented] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516015#comment-17516015 ] Nicholas Jiang commented on FLINK-26926: IMO, the configuration related to the job deployment

[jira] [Commented] (FLINK-26926) Allow users to force upgrade even if savepoint is in progress

[ https://issues.apache.org/jira/browse/FLINK-26926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515988#comment-17515988 ] Nicholas Jiang commented on FLINK-26926: [~gyfora], could the JobSpec add the

[jira] [Commented] (FLINK-26973) Emit events on state transitions for FlinkDeployment

[ https://issues.apache.org/jira/browse/FLINK-26973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515774#comment-17515774 ] Nicholas Jiang commented on FLINK-26973: [~matyas], is this ticket duplicated with FLINK-26891?

[jira] [Commented] (FLINK-26953) Introduce Operator Specific Metrics

[ https://issues.apache.org/jira/browse/FLINK-26953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515402#comment-17515402 ] Nicholas Jiang commented on FLINK-26953: [~matyas], are the states of the deployment in

[jira] [Commented] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515130#comment-17515130 ] Nicholas Jiang commented on FLINK-26938: [~martijnvisser], IMO, the problem could happen with

[jira] [Commented] (FLINK-26941) Support Pattern end with notFollowedBy with window

[ https://issues.apache.org/jira/browse/FLINK-26941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515104#comment-17515104 ] Nicholas Jiang commented on FLINK-26941: [~mayuehappy], does this improve affect the Flink

[jira] [Commented] (FLINK-26938) HybridSource recovery from savepoint fails When flink parallelism is greater than the number of Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-26938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515090#comment-17515090 ] Nicholas Jiang commented on FLINK-26938: [~MartijnVisser], could you please assign this ticket

[jira] [Commented] (FLINK-26935) Sort records by sequence number when continuous reading

[ https://issues.apache.org/jira/browse/FLINK-26935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515024#comment-17515024 ] Nicholas Jiang commented on FLINK-26935: Does this ticket depend on FLINK-26439? > Sort records

[jira] [Commented] (FLINK-26894) Support custom validator implementations

[ https://issues.apache.org/jira/browse/FLINK-26894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513905#comment-17513905 ] Nicholas Jiang commented on FLINK-26894: If nobody have interest to work for this ticket, I

[jira] [Commented] (FLINK-26894) Support custom validator implementations

[ https://issues.apache.org/jira/browse/FLINK-26894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513886#comment-17513886 ] Nicholas Jiang commented on FLINK-26894: [~gyfora], [~matyas], could we firstly make the

[jira] [Commented] (FLINK-26893) Validate checkpoint config with last-state upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-26893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513880#comment-17513880 ] Nicholas Jiang commented on FLINK-26893: [~gyfora], I could take this ticket to add the above

[jira] [Commented] (FLINK-26895) Improve cancelWithSavepoint timeout error message

[ https://issues.apache.org/jira/browse/FLINK-26895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513793#comment-17513793 ] Nicholas Jiang commented on FLINK-26895: Does the cancelWithSavepoint timeout error message need

[jira] [Commented] (FLINK-26893) Validate checkpoint config with last-state upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-26893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513781#comment-17513781 ] Nicholas Jiang commented on FLINK-26893: Does the validation if checkpointing is turned on when

[jira] [Commented] (FLINK-26894) Support custom validator implementations

[ https://issues.apache.org/jira/browse/FLINK-26894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513780#comment-17513780 ] Nicholas Jiang commented on FLINK-26894: About specifying custom validator implementations, we

[jira] [Closed] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-22888. -- > Matches results may be wrong when using notNext as the last part of the > pattern with Window

[jira] [Resolved] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-22888. Resolution: Fixed > Matches results may be wrong when using notNext as the last part of

[jira] [Comment Edited] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513170#comment-17513170 ] Nicholas Jiang edited comment on FLINK-22888 at 3/28/22, 10:05 AM: ---

[jira] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890 ] Nicholas Jiang deleted comment on FLINK-23890: was (Author: nicholasjiang): [~mayuehappy], IMO, when the watermark advances, the timers of all keys will be triggered and removed from

[jira] [Comment Edited] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513199#comment-17513199 ] Nicholas Jiang edited comment on FLINK-23890 at 3/28/22, 7:43 AM: --

[jira] [Comment Edited] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513199#comment-17513199 ] Nicholas Jiang edited comment on FLINK-23890 at 3/28/22, 7:32 AM: --

[jira] [Updated] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-22888: --- Description: the pattern is like  Pattern.begin("start").where(records == "a")            

[jira] [Comment Edited] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513199#comment-17513199 ] Nicholas Jiang edited comment on FLINK-23890 at 3/28/22, 7:21 AM: --

[jira] [Commented] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513199#comment-17513199 ] Nicholas Jiang commented on FLINK-23890: [~mayuehappy], after the offline discussion, the

[jira] [Comment Edited] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513170#comment-17513170 ] Nicholas Jiang edited comment on FLINK-22888 at 3/28/22, 6:58 AM: --

[jira] [Reopened] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang reopened FLINK-22888: > Matches results may be wrong when using notNext as the last part of the > pattern with

[jira] [Resolved] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-22888. Resolution: Won't Fix > Matches results may be wrong when using notNext as the last part

[jira] [Closed] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-22888. -- > Matches results may be wrong when using notNext as the last part of the > pattern with Window

[jira] [Comment Edited] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513170#comment-17513170 ] Nicholas Jiang edited comment on FLINK-22888 at 3/28/22, 6:32 AM: --

[jira] [Reopened] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang reopened FLINK-22888: > Matches results may be wrong when using notNext as the last part of the > pattern with

[jira] [Resolved] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-22888. Resolution: Won't Fix > Matches results may be wrong when using notNext as the last part

[jira] [Commented] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513170#comment-17513170 ] Nicholas Jiang commented on FLINK-22888: [~mayuehappy], after the offline discussion, the above

[jira] [Commented] (FLINK-26836) Add sanity check for state.savepoints.dir when using savepoint upgrade mode

[ https://issues.apache.org/jira/browse/FLINK-26836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511687#comment-17511687 ] Nicholas Jiang commented on FLINK-26836: [~wangyang0918], does this check add into

[jira] (FLINK-26487) Upgrade to Operator SDK 3.0.0 and replace custom informereventsource logic

[ https://issues.apache.org/jira/browse/FLINK-26487 ] Nicholas Jiang deleted comment on FLINK-26487: was (Author: nicholasjiang): [~gyfora], does the info of the release come from the java-operator-sdk channel? > Upgrade to Operator SDK

[jira] [Commented] (FLINK-26487) Upgrade to Operator SDK 3.0.0 and replace custom informereventsource logic

[ https://issues.apache.org/jira/browse/FLINK-26487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510212#comment-17510212 ] Nicholas Jiang commented on FLINK-26487: [~gyfora], does the info of the release come from the

[jira] (FLINK-26620) Mark CRD classes experimental

[ https://issues.apache.org/jira/browse/FLINK-26620 ] Nicholas Jiang deleted comment on FLINK-26620: was (Author: nicholasjiang): [~gyfora], sorry to trouble you for assign this ticket to me. > Mark CRD classes experimental >

[jira] [Commented] (FLINK-26714) Remove .sec from OperatorConfigOptions and use Duration type config instead

[ https://issues.apache.org/jira/browse/FLINK-26714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508702#comment-17508702 ] Nicholas Jiang commented on FLINK-26714: [~gyfora], sorry to trouble you for assign this ticket

[jira] [Commented] (FLINK-26620) Mark CRD classes experimental

[ https://issues.apache.org/jira/browse/FLINK-26620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508699#comment-17508699 ] Nicholas Jiang commented on FLINK-26620: [~gyfora], sorry to trouble you for assign this ticket

[jira] [Commented] (FLINK-26714) Remove .sec from OperatorConfigOptions and use Duration type config instead

[ https://issues.apache.org/jira/browse/FLINK-26714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508692#comment-17508692 ] Nicholas Jiang commented on FLINK-26714: [~gyfora], this ticket could be close. > Remove .sec

[jira] [Comment Edited] (FLINK-26702) Sporadic failures in JobObserverTest

[ https://issues.apache.org/jira/browse/FLINK-26702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508691#comment-17508691 ] Nicholas Jiang edited comment on FLINK-26702 at 3/18/22, 10:14 AM: ---

[jira] [Resolved] (FLINK-26702) Sporadic failures in JobObserverTest

[ https://issues.apache.org/jira/browse/FLINK-26702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-26702. Resolution: Fixed > Sporadic failures in JobObserverTest >

[jira] [Commented] (FLINK-26702) Sporadic failures in JobObserverTest

[ https://issues.apache.org/jira/browse/FLINK-26702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508691#comment-17508691 ] Nicholas Jiang commented on FLINK-26702: [~mbalassi], this problem has been solved in the PR of

[jira] [Updated] (FLINK-26714) Remove .sec from OperatorConfigOptions and use Duration type config instead

[ https://issues.apache.org/jira/browse/FLINK-26714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-26714: --- Description: The OperatorConfigOptions options mostly have .sec in their names to denote

[jira] [Commented] (FLINK-26714) Remove .sec from OperatorConfigOptions and use Duration type config instead

[ https://issues.apache.org/jira/browse/FLINK-26714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508510#comment-17508510 ] Nicholas Jiang commented on FLINK-26714: [~gyfora], the description of this ticket has something

[jira] (FLINK-26714) Remove .sec from OperatorConfigOptions and use Duration type config instead

[ https://issues.apache.org/jira/browse/FLINK-26714 ] Nicholas Jiang deleted comment on FLINK-26714: was (Author: nicholasjiang): [~gyfora], the description of this ticket has something wrong that the OperatorConfigOptions options mostly

[jira] [Commented] (FLINK-26695) Fabric8FlinkKubeClient.deleteConfigMap and deleteConfigMapsByLabels don't necessarily fail if the deletion didn't succeed

[ https://issues.apache.org/jira/browse/FLINK-26695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508042#comment-17508042 ] Nicholas Jiang commented on FLINK-26695: [~wangyang0918], if the retries of the deletion

[jira] [Commented] (FLINK-26695) Fabric8FlinkKubeClient.deleteConfigMap and deleteConfigMapsByLabels don't necessarily fail if the deletion didn't succeed

[ https://issues.apache.org/jira/browse/FLINK-26695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508039#comment-17508039 ] Nicholas Jiang commented on FLINK-26695: [~wangyang0918], as you said, this should add the check

[jira] (FLINK-26695) Fabric8FlinkKubeClient.deleteConfigMap and deleteConfigMapsByLabels don't necessarily fail if the deletion didn't succeed

[ https://issues.apache.org/jira/browse/FLINK-26695 ] Nicholas Jiang deleted comment on FLINK-26695: was (Author: nicholasjiang): [~wangyang0918], as you said, this should add the check whether the deleted ConfigMaps are existed and retry

[jira] [Commented] (FLINK-26695) Fabric8FlinkKubeClient.deleteConfigMap doesn't necessarily fail if the deletion didn't succeed

[ https://issues.apache.org/jira/browse/FLINK-26695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508002#comment-17508002 ] Nicholas Jiang commented on FLINK-26695: [~mapohl], does the

[jira] [Commented] (FLINK-26649) Add startTime in JobStatus

[ https://issues.apache.org/jira/browse/FLINK-26649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506844#comment-17506844 ] Nicholas Jiang commented on FLINK-26649: [~gyfora], IMO, the update time is different from the

[jira] [Commented] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504710#comment-17504710 ] Nicholas Jiang commented on FLINK-23890: [~dianfu], could you please assign this ticket to me?

[jira] [Commented] (FLINK-22888) Matches results may be wrong when using notNext as the last part of the pattern with Window

[ https://issues.apache.org/jira/browse/FLINK-22888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504711#comment-17504711 ] Nicholas Jiang commented on FLINK-22888: [~dianfu], could you please assign this ticket to me?

[jira] [Commented] (FLINK-26552) Try to use @EnableKubernetesMockClient(crud = true) in controller test

[ https://issues.apache.org/jira/browse/FLINK-26552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504091#comment-17504091 ] Nicholas Jiang commented on FLINK-26552: [~gyfora], what problems did you meet? And do you agree

[jira] (FLINK-26538) Ability to restart deployment w/o spec change

[ https://issues.apache.org/jira/browse/FLINK-26538 ] Nicholas Jiang deleted comment on FLINK-26538: was (Author: nicholasjiang): >From the user perspective, most of the users desire to only a single operation >to restart deployment, the

[jira] [Commented] (FLINK-26454) Improve operator logging

[ https://issues.apache.org/jira/browse/FLINK-26454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503572#comment-17503572 ] Nicholas Jiang commented on FLINK-26454: [~gyfora], I would like to start the discussion thread

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503501#comment-17503501 ] Nicholas Jiang commented on FLINK-26538: >From the user perspective, most of the users desire to

[jira] [Commented] (FLINK-26454) Improve operator logging

[ https://issues.apache.org/jira/browse/FLINK-26454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503272#comment-17503272 ] Nicholas Jiang commented on FLINK-26454: MDC +1. MDC solution looks more uniform and namespace +

[jira] [Commented] (FLINK-26506) Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-26506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503266#comment-17503266 ] Nicholas Jiang commented on FLINK-26506: [~dianfu], please help to assign this ticket to me. >

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

[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502781#comment-17502781 ] Nicholas Jiang commented on FLINK-26137: [~gyfora], I'm working for this ticket. Could you

[jira] [Commented] (FLINK-26508) Webhook should only validate on /validate endpoint end log errors for others

[ https://issues.apache.org/jira/browse/FLINK-26508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502213#comment-17502213 ] Nicholas Jiang commented on FLINK-26508: [~gyfora], could you please assign this ticket to me?

[jira] [Commented] (FLINK-26487) Upgrade to Operator SDK 2.2.0 and replace custom informereventsource logic

[ https://issues.apache.org/jira/browse/FLINK-26487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501486#comment-17501486 ] Nicholas Jiang commented on FLINK-26487: [~gyfora], could you please assign this ticket to me? I

[jira] [Comment Edited] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501185#comment-17501185 ] Nicholas Jiang edited comment on FLINK-26473 at 3/4/22, 6:48 AM: -

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501185#comment-17501185 ] Nicholas Jiang commented on FLINK-26473: [~wangyang0918], do you mean that the observer should

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500849#comment-17500849 ] Nicholas Jiang commented on FLINK-26179: [~matyas], thanks for opening the PR about manual

[jira] [Commented] (FLINK-26432) Cleanly separate validator, observer and reconciler modules

[ https://issues.apache.org/jira/browse/FLINK-26432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500845#comment-17500845 ] Nicholas Jiang commented on FLINK-26432: [~gyfora], IMO, this ticket could be closed. > Cleanly

[jira] [Closed] (FLINK-26447) Clean up webhook jar and dependency management

[ https://issues.apache.org/jira/browse/FLINK-26447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang closed FLINK-26447. -- > Clean up webhook jar and dependency management > --

[jira] [Resolved] (FLINK-26447) Clean up webhook jar and dependency management

[ https://issues.apache.org/jira/browse/FLINK-26447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang resolved FLINK-26447. Resolution: Fixed > Clean up webhook jar and dependency management >

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500270#comment-17500270 ] Nicholas Jiang commented on FLINK-26179: [~matyas],I need to take a look at your manual

[jira] [Comment Edited] (FLINK-26179) Support periodic savepointing in the operator

[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500225#comment-17500225 ] Nicholas Jiang edited comment on FLINK-26179 at 3/2/22, 3:49 PM: -

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500225#comment-17500225 ] Nicholas Jiang commented on FLINK-26179: [~gyfora], I have interest to support periodic

[jira] [Commented] (FLINK-26179) Support periodic savepointing in the operator

[ https://issues.apache.org/jira/browse/FLINK-26179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500164#comment-17500164 ] Nicholas Jiang commented on FLINK-26179: [~gyfora], does this ticket means that adds trigger

[jira] [Commented] (FLINK-26345) Observer should detect flink job even if deployment status is empty

[ https://issues.apache.org/jira/browse/FLINK-26345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1748#comment-1748 ] Nicholas Jiang commented on FLINK-26345: [~gyfora], I have reviewed the PR above mentioned and

[jira] [Commented] (FLINK-26345) Observer should detect flink job even if deployment status is empty

[ https://issues.apache.org/jira/browse/FLINK-26345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499891#comment-17499891 ] Nicholas Jiang commented on FLINK-26345: [~t...@apache.org], are you working for this ticket? If

[jira] [Commented] (FLINK-26367) Move sanity check in FlinkService#cancelJob to DefaultDeploymentValidator

[ https://issues.apache.org/jira/browse/FLINK-26367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497969#comment-17497969 ] Nicholas Jiang commented on FLINK-26367: [~wangyang0918], I would like to do the sanity check

[jira] [Commented] (FLINK-25986) Add FLIP-190 new API methods to python

[ https://issues.apache.org/jira/browse/FLINK-25986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497177#comment-17497177 ] Nicholas Jiang commented on FLINK-25986: [~slinkydeveloper], could you please assign this ticket

[jira] [Commented] (FLINK-26344) waitForClusterShutdown does not work correctly in Flink Kubernetes operator

[ https://issues.apache.org/jira/browse/FLINK-26344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497172#comment-17497172 ] Nicholas Jiang commented on FLINK-26344: [~wangyang0918], I would like to fix this bug above

[jira] [Updated] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24865: --- Affects Version/s: 1.15.0 > Support MATCH_RECOGNIZE in Batch mode >

[jira] [Updated] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang updated FLINK-24865: --- Fix Version/s: 1.15.0 > Support MATCH_RECOGNIZE in Batch mode >

[jira] [Comment Edited] (FLINK-25874) PyFlink package dependencies conflict

[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484095#comment-17484095 ] Nicholas Jiang edited comment on FLINK-25874 at 1/29/22, 8:21 AM: --

[jira] [Commented] (FLINK-25874) PyFlink package dependencies conflict

[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17484095#comment-17484095 ] Nicholas Jiang commented on FLINK-25874: [~hflhmartin], IMO, you could contribute a PR to

[jira] [Commented] (FLINK-25760) Support for extended SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-25760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17480792#comment-17480792 ] Nicholas Jiang commented on FLINK-25760: [~melin], is it duplicated with the

[jira] [Commented] (FLINK-24865) Support MATCH_RECOGNIZE in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-24865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467968#comment-17467968 ] Nicholas Jiang commented on FLINK-24865: [~MartijnVisser], I'm supporting for the

[jira] [Commented] (FLINK-25178) Throw exception when managed table sink needs checkpointing

[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466026#comment-17466026 ] Nicholas Jiang commented on FLINK-25178: [~lzljs3620320], I have pushed a pull request for this

[jira] [Commented] (FLINK-25177) Support "DESCRIBE TABLE EXTENDED" with managed table

[ https://issues.apache.org/jira/browse/FLINK-25177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464949#comment-17464949 ] Nicholas Jiang commented on FLINK-25177: [~lzljs3620320], are you working for this issue? If

[jira] [Commented] (FLINK-25435) Can not read jobmanager/taskmanager.log in yarn-per-job mode.

[ https://issues.apache.org/jira/browse/FLINK-25435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464936#comment-17464936 ] Nicholas Jiang commented on FLINK-25435: [~ZhangChaoming], even though the description of

[jira] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380 ] Nicholas Jiang deleted comment on FLINK-25380: was (Author: nicholasjiang): [~RocMarshal], you could firstly take the tickets of the FLINK-20628 and FLINK-21373. After these completion,

[jira] [Commented] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464907#comment-17464907 ] Nicholas Jiang commented on FLINK-25380: [~RocMarshal], you could firstly take the tickets of

[jira] [Commented] (FLINK-25435) Can not read jobmanager/taskmanager.log in yarn-per-job mode.

[ https://issues.apache.org/jira/browse/FLINK-25435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17464905#comment-17464905 ] Nicholas Jiang commented on FLINK-25435: [~ZhangChaoming], IMO, the SET statement doesn't do

[jira] [Commented] (FLINK-25380) Introduce DynamicTableSink & DynamicTableSource for RabbitMQ

[ https://issues.apache.org/jira/browse/FLINK-25380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462959#comment-17462959 ] Nicholas Jiang commented on FLINK-25380: [~RocMarshal], IMO, the RabbitMQ sql connector could

[jira] [Commented] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453997#comment-17453997 ] Nicholas Jiang commented on FLINK-25170: [~monster#12], we will submit the proposal about the

[jira] [Comment Edited] (FLINK-25170) cep supports dynamic rule updates

[ https://issues.apache.org/jira/browse/FLINK-25170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453997#comment-17453997 ] Nicholas Jiang edited comment on FLINK-25170 at 12/6/21, 12:39 PM: ---

[jira] [Commented] (FLINK-25178) Throw exception when managed table sink needs checkpointing

[ https://issues.apache.org/jira/browse/FLINK-25178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17453993#comment-17453993 ] Nicholas Jiang commented on FLINK-25178: [~lzljs3620320], could the planner check whether the

<    1   2   3   4   5   6   7   >