[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35215: Description: The performance of serializerKryo and serializerKryoWithoutRegistration are regressed[1][2],

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850904#comment-17850904 ] Rui Fan commented on FLINK-35215: - The performance seems already recovered, let me close

[jira] [Closed] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35215. --- Resolution: Fixed > The performance of serializerKryo and serializerKryoWithoutRegistration are > regressed

[jira] [Assigned] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35496: --- Assignee: RocMarshal > The annotations of the new JDBC connector should be changed to > non-Public

[jira] [Assigned] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35496: --- Assignee: (was: RocMarshal) > The annotations of the new JDBC connector should be changed to >

[jira] [Assigned] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35496: --- Assignee: João Boto > The annotations of the new JDBC connector should be changed to > non-Public/

[jira] [Reopened] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reopened FLINK-33463: - > Support the implementation of dynamic source tables based on the new source >

[jira] [Comment Edited] (FLINK-33463) Support the implementation of dynamic source tables based on the new source

[ https://issues.apache.org/jira/browse/FLINK-33463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844836#comment-17844836 ] Rui Fan edited comment on FLINK-33463 at 6/1/24 2:40 AM: - Merged

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851478#comment-17851478 ] Rui Fan commented on FLINK-35496: - Merged to main(jdbc-3.3.0) via: b955e8b5479c65512f94e

[jira] [Resolved] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35496. - Fix Version/s: jdbc-3.2.0 Resolution: Fixed > The annotations of the new JDBC connector should be

[jira] [Comment Edited] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851478#comment-17851478 ] Rui Fan edited comment on FLINK-35496 at 6/3/24 2:00 AM: - Merged

[jira] [Commented] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851865#comment-17851865 ] Rui Fan commented on FLINK-35496: - Thanks [~leonard] for the clarification, I misunderst

[jira] [Assigned] (FLINK-35516) Update the Experimental annotation to PublicEvolving for files connector

[ https://issues.apache.org/jira/browse/FLINK-35516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35516: --- Assignee: RocMarshal > Update the Experimental annotation to PublicEvolving for files connector >

[jira] [Commented] (FLINK-35517) CI pipeline triggered by pull request seems unstable

[ https://issues.apache.org/jira/browse/FLINK-35517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851995#comment-17851995 ] Rui Fan commented on FLINK-35517: - Hi [~jingge] , may I know whether all old PRs can be

[jira] [Comment Edited] (FLINK-35517) CI pipeline triggered by pull request seems unstable

[ https://issues.apache.org/jira/browse/FLINK-35517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851995#comment-17851995 ] Rui Fan edited comment on FLINK-35517 at 6/4/24 10:52 AM: -- Hi [

[jira] [Comment Edited] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851478#comment-17851478 ] Rui Fan edited comment on FLINK-35496 at 6/5/24 9:28 AM: - Merged

[jira] [Updated] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35496: Fix Version/s: jdbc-3.3.0 (was: jdbc-3.2.0) > The annotations of the new JDBC conne

[jira] [Comment Edited] (FLINK-35496) The annotations of the new JDBC connector should be changed to non-Public/non-PublicEvolving

[ https://issues.apache.org/jira/browse/FLINK-35496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851478#comment-17851478 ] Rui Fan edited comment on FLINK-35496 at 6/5/24 9:28 AM: - Merged

[jira] [Commented] (FLINK-34633) Support unnesting array constants

[ https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853040#comment-17853040 ] Rui Fan commented on FLINK-34633: - Hi [~qingyue] [~jeyhunkarimov] , during I review the

[jira] [Commented] (FLINK-32987) BlobClientSslTest>BlobClientTest.testSocketTimeout expected SocketTimeoutException but identified SSLException

[ https://issues.apache.org/jira/browse/FLINK-32987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760758#comment-17760758 ] Rui Fan commented on FLINK-32987: - Thanks [~mapohl]  for the report and [~ferenc-csaky] 

[jira] [Resolved] (FLINK-32987) BlobClientSslTest>BlobClientTest.testSocketTimeout expected SocketTimeoutException but identified SSLException

[ https://issues.apache.org/jira/browse/FLINK-32987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32987. - Fix Version/s: 1.19.0 Resolution: Fixed > BlobClientSslTest>BlobClientTest.testSocketTimeout expe

[jira] [Created] (FLINK-33042) Allow trigger flamegraph when task is initializing

Rui Fan created FLINK-33042: --- Summary: Allow trigger flamegraph when task is initializing Key: FLINK-33042 URL: https://issues.apache.org/jira/browse/FLINK-33042 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

Rui Fan created FLINK-33065: --- Summary: Optimize the exception message when the program plan could not be fetched Key: FLINK-33065 URL: https://issues.apache.org/jira/browse/FLINK-33065 Project: Flink

[jira] [Resolved] (FLINK-33042) Allow trigger flamegraph when task is initializing

[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33042. - Fix Version/s: 1.19.0 Resolution: Fixed > Allow trigger flamegraph when task is initializing > -

[jira] [Commented] (FLINK-33042) Allow trigger flamegraph when task is initializing

[ https://issues.apache.org/jira/browse/FLINK-33042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763344#comment-17763344 ] Rui Fan commented on FLINK-33042: - Merged via 53702736382b80fa905494e69654061a84741e84

[jira] [Commented] (FLINK-32818) Support region failover for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763391#comment-17763391 ] Rui Fan commented on FLINK-32818: - Hi, [~talat] , thanks for your interest in Adaptive S

[jira] [Updated] (FLINK-32818) Support region failover for adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-32818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32818: Component/s: Runtime / Coordination > Support region failover for adaptive scheduler > ---

[jira] [Commented] (FLINK-32895) Introduce the max attempts for Exponential Delay Restart Strategy

[ https://issues.apache.org/jira/browse/FLINK-32895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763394#comment-17763394 ] Rui Fan commented on FLINK-32895: - Hi [~zhuzh] , I created the FLIP-364 in advance due t

[jira] [Resolved] (FLINK-32854) [JUnit5 Migration] The state package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32854. - Fix Version/s: 1.19.0 Resolution: Fixed > [JUnit5 Migration] The state package of flink-runtime m

[jira] [Commented] (FLINK-32854) [JUnit5 Migration] The state package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763765#comment-17763765 ] Rui Fan commented on FLINK-32854: - Merged via 554810abbbd44a656a446d051b3dd199b0df9055

[jira] [Resolved] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

[ https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33065. - Fix Version/s: 1.19.0 Resolution: Fixed > Optimize the exception message when the program plan co

[jira] [Commented] (FLINK-33065) Optimize the exception message when the program plan could not be fetched

[ https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764472#comment-17764472 ] Rui Fan commented on FLINK-33065: - Merged via d5b2cdb618cd7a50818d7eaa575c0fac6aaeac9a

[jira] [Created] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

Rui Fan created FLINK-33092: --- Summary: Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler Key: FLINK-33092 URL: https://issues.apache.org/jira/browse/FLINK-33092

[jira] [Updated] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33092: Description: !image-2023-09-15-14-43-35-104.png|width=1103,height=779! h1. 1. Propose The above is the st

[jira] [Updated] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33092: Description: !image-2023-09-15-14-43-35-104.png|width=916,height=647! h1. 1. Propose The above is the sta

[jira] [Commented] (FLINK-33092) Improve the resource-stabilization-timeout mechanism when rescale a job for Adaptive Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17765483#comment-17765483 ] Rui Fan commented on FLINK-33092: - Hi [~chesnay]  [~dmvk] , would you mind helping take

[jira] [Updated] (FLINK-32947) Autoscaler standalone mode supports the metric report

[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Parent: (was: FLINK-32723) Issue Type: New Feature (was: Sub-task) > Autoscaler standalone mo

[jira] [Created] (FLINK-33097) Initialize the generic autoscaler module and interfaces

Rui Fan created FLINK-33097: --- Summary: Initialize the generic autoscaler module and interfaces Key: FLINK-33097 URL: https://issues.apache.org/jira/browse/FLINK-33097 Project: Flink Issue Type: Sub

[jira] [Updated] (FLINK-32723) FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-32723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32723: Summary: FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler (was: FLIP

[jira] [Created] (FLINK-33098) Support kubernetes autoscaler using generic interface

Rui Fan created FLINK-33098: --- Summary: Support kubernetes autoscaler using generic interface Key: FLINK-33098 URL: https://issues.apache.org/jira/browse/FLINK-33098 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-33099) Support the Standalone Autoscaler

Rui Fan created FLINK-33099: --- Summary: Support the Standalone Autoscaler Key: FLINK-33099 URL: https://issues.apache.org/jira/browse/FLINK-33099 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-33100) Implement YarnJobFetcher for Standalone Autoscaler

Rui Fan created FLINK-33100: --- Summary: Implement YarnJobFetcher for Standalone Autoscaler Key: FLINK-33100 URL: https://issues.apache.org/jira/browse/FLINK-33100 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Description: The flink kubernetes operator itself sets up the metrics reporters and provides the base metr

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Summary: Standalone autoscaler supports the metric reporter (was: Autoscaler standalone mode supports the

[jira] [Updated] (FLINK-32947) Standalone autoscaler supports the metric reporter

[ https://issues.apache.org/jira/browse/FLINK-32947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32947: Parent: FLINK-32723 Issue Type: Sub-task (was: New Feature) > Standalone autoscaler supports the

[jira] [Created] (FLINK-33101) Add the integration test for standalone autoscaler

Rui Fan created FLINK-33101: --- Summary: Add the integration test for standalone autoscaler Key: FLINK-33101 URL: https://issues.apache.org/jira/browse/FLINK-33101 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33102) Document the standalone autoscaler

Rui Fan created FLINK-33102: --- Summary: Document the standalone autoscaler Key: FLINK-33102 URL: https://issues.apache.org/jira/browse/FLINK-33102 Project: Flink Issue Type: Sub-task Rep

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766401#comment-17766401 ] Rui Fan commented on FLINK-33109: - Hi [~YordanPavlov] , thanks for your report. I'm not

[jira] [Comment Edited] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17766401#comment-17766401 ] Rui Fan edited comment on FLINK-33109 at 9/18/23 2:19 PM: -- Hi [

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767128#comment-17767128 ] Rui Fan commented on FLINK-33109: - Could you try this image? It's the offcial image base

[jira] [Comment Edited] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767162#comment-17767162 ] Rui Fan edited comment on FLINK-33123 at 9/20/23 3:30 PM: -- Hi [

[jira] [Commented] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767162#comment-17767162 ] Rui Fan commented on FLINK-33123: - Hi [~Zhanghao Chen] , thanks for your report! Your a

[jira] [Updated] (FLINK-33098) Support kubernetes autoscaler using generic interface

[ https://issues.apache.org/jira/browse/FLINK-33098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33098: Description: # Moving all classes aren't related to kubernetes to flink-autoscaler module # Support kuber

[jira] [Updated] (FLINK-33098) Support kubernetes autoscaler using generic interface

[ https://issues.apache.org/jira/browse/FLINK-33098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33098: Description: # Moving all classes aren't related to kubernetes to flink-autoscaler module # Support kube

[jira] [Updated] (FLINK-31757) Support Balanced Tasks Scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31757: Description: This is a umbrella JIRA of [FLIP-370|https://cwiki.apache.org/confluence/x/U56zDw].   Supp

[jira] [Updated] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31757: Summary: FLIP-370: Support Balanced Tasks Scheduling (was: Support Balanced Tasks Scheduling) > FLIP-370

[jira] [Updated] (FLINK-31757) FLIP-370: Support Balanced Tasks Scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31757: Description: This is an umbrella JIRA of [FLIP-370|https://cwiki.apache.org/confluence/x/U56zDw]. (was: T

[jira] [Commented] (FLINK-26586) FileSystem uses unbuffered read I/O

[ https://issues.apache.org/jira/browse/FLINK-26586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770815#comment-17770815 ] Rui Fan commented on FLINK-26586: - Thanks [~masteryhx] [~Matthias Schwalbe]  for discuss

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772920#comment-17772920 ] Rui Fan commented on FLINK-33109: - Hi [~YordanPavlov] , I guess the bug has been fixed i

[jira] [Comment Edited] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772920#comment-17772920 ] Rui Fan edited comment on FLINK-33109 at 10/8/23 4:50 AM: -- Hi [

[jira] [Updated] (FLINK-29816) Fix the bug that StreamTask doesn't handle exception during restoring

[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-29816: Summary: Fix the bug that StreamTask doesn't handle exception during restoring (was: Userfunction excepti

[jira] [Created] (FLINK-33237) Optimize the data type of JobStatus#state from String to Enum

Rui Fan created FLINK-33237: --- Summary: Optimize the data type of JobStatus#state from String to Enum Key: FLINK-33237 URL: https://issues.apache.org/jira/browse/FLINK-33237 Project: Flink Issue Ty

[jira] [Updated] (FLINK-32866) Unify the TestLoggerExtension config of junit5

[ https://issues.apache.org/jira/browse/FLINK-32866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32866: Labels: pull-request-available starter (was: pull-request-available stale-assigned starter) > Unify the

[jira] [Created] (FLINK-33287) Using the flink shaded jackson for flink-autoscaler

Rui Fan created FLINK-33287: --- Summary: Using the flink shaded jackson for flink-autoscaler Key: FLINK-33287 URL: https://issues.apache.org/jira/browse/FLINK-33287 Project: Flink Issue Type: Sub-tas

[jira] [Commented] (FLINK-33097) Initialize the generic autoscaler module and interfaces

[ https://issues.apache.org/jira/browse/FLINK-33097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776248#comment-17776248 ] Rui Fan commented on FLINK-33097: - Merged main via 5c76d01c79a91a255b40e0f08d384d7b0326b

[jira] [Resolved] (FLINK-33097) Initialize the generic autoscaler module and interfaces

[ https://issues.apache.org/jira/browse/FLINK-33097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33097. - Fix Version/s: kubernetes-operator-1.7.0 Resolution: Fixed > Initialize the generic autoscaler mo

[jira] [Commented] (FLINK-33098) Support kubernetes autoscaler using generic interface

[ https://issues.apache.org/jira/browse/FLINK-33098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776252#comment-17776252 ] Rui Fan commented on FLINK-33098: - Thanks for the review and merging! > Support kuberne

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687864#comment-17687864 ] Rui Fan commented on FLINK-31036: - Thanks [~mapohl]  reports this issue, and thanks [~ro

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688437#comment-17688437 ] Rui Fan commented on FLINK-31036: - Hi [~mapohl] [~roman] , I'm sorry, after analysis, I

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17688783#comment-17688783 ] Rui Fan commented on FLINK-31036: - {quote} I'm only aware of this one test failure. {quo

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689468#comment-17689468 ] Rui Fan commented on FLINK-31036: - {quote}Why would you assume to get more from the logs

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689591#comment-17689591 ] Rui Fan commented on FLINK-31036: - Hi, [~pnowojski] , do you have time help take a look

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689608#comment-17689608 ] Rui Fan commented on FLINK-31036: - {quote}Reverting FLINK-26803 by then sounds reasonabl

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689614#comment-17689614 ] Rui Fan commented on FLINK-31036: - I see that StateCheckpointedITCase fails when this co

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689628#comment-17689628 ] Rui Fan edited comment on FLINK-31036 at 2/16/23 9:06 AM: -- {quo

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689628#comment-17689628 ] Rui Fan commented on FLINK-31036: - {quote}Is this a copy&paste error? The commit  [331ab

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689670#comment-17689670 ] Rui Fan commented on FLINK-31036: - {quote}Looks like it's not really a one-time thing: [

[jira] [Updated] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31036: Attachment: image-2023-02-16-20-29-52-050.png > StateCheckpointedITCase timed out due to deadlock > --

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out due to deadlock

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689746#comment-17689746 ] Rui Fan commented on FLINK-31036: - {quote}Here's the actual one: [https://dev.azure.com/

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690125#comment-17690125 ] Rui Fan commented on FLINK-31036: - Hi [~pnowojski] , thanks a lot for the analysis, soun

[jira] [Updated] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31036: Component/s: Tests > StateCheckpointedITCase timed out > - > >

[jira] [Created] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the doc

Rui Fan created FLINK-31131: --- Summary: The INITIALIZING of ExecutionState is missed in the doc Key: FLINK-31131 URL: https://issues.apache.org/jira/browse/FLINK-31131 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31131: Summary: The INITIALIZING of ExecutionState is missed in the state_machine doc (was: The INITIALIZING of

[jira] [Created] (FLINK-31141) CreateTableAsITCase.testCreateTableAs fails

Rui Fan created FLINK-31141: --- Summary: CreateTableAsITCase.testCreateTableAs fails Key: FLINK-31141 URL: https://issues.apache.org/jira/browse/FLINK-31141 Project: Flink Issue Type: Bug C

[jira] [Commented] (FLINK-31141) CreateTableAsITCase.testCreateTableAs fails

[ https://issues.apache.org/jira/browse/FLINK-31141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691212#comment-17691212 ] Rui Fan commented on FLINK-31141: - Hi [~lsy] , I see you created the test in FLINK-29219

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691214#comment-17691214 ] Rui Fan commented on FLINK-31036: - merged commit ae53a8de47b31e248fef216428a83c8bf3f07b1

[jira] [Commented] (FLINK-31138) Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out

[ https://issues.apache.org/jira/browse/FLINK-31138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691219#comment-17691219 ] Rui Fan commented on FLINK-31138: - Hi [~mapohl] , I checked the StreamCheckpointingITCas

[jira] [Commented] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691222#comment-17691222 ] Rui Fan commented on FLINK-31036: - {quote}Is FLINK-31138 a duplicate of this Jira issue?

[jira] [Comment Edited] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691214#comment-17691214 ] Rui Fan edited comment on FLINK-31036 at 2/21/23 3:49 AM: -- merg

[jira] [Commented] (FLINK-31138) Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out

[ https://issues.apache.org/jira/browse/FLINK-31138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691397#comment-17691397 ] Rui Fan commented on FLINK-31138: - Too many tests run slowly, I'm not sure whether the c

[jira] [Closed] (FLINK-31036) StateCheckpointedITCase timed out

[ https://issues.apache.org/jira/browse/FLINK-31036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31036. --- Resolution: Fixed > StateCheckpointedITCase timed out > - > >

[jira] [Commented] (FLINK-31138) Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out

[ https://issues.apache.org/jira/browse/FLINK-31138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691592#comment-17691592 ] Rui Fan commented on FLINK-31138: - {quote}where do you see that {{StreamCheckpointingITC

[jira] [Updated] (FLINK-31138) Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out

[ https://issues.apache.org/jira/browse/FLINK-31138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-31138: Attachment: logs-cron_azure-test_cron_azure_finegrained_resource_management-1676692614.zip > Either Strea

[jira] [Commented] (FLINK-31141) CreateTableAsITCase.testCreateTableAs fails

[ https://issues.apache.org/jira/browse/FLINK-31141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691874#comment-17691874 ] Rui Fan commented on FLINK-31141: - Yep, I just found it failing once. > CreateTableAsIT

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692203#comment-17692203 ] Rui Fan commented on FLINK-29816: - Hi [~Weijie Guo] [~RocMarshal] , thanks for your anal

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692250#comment-17692250 ] Rui Fan commented on FLINK-29816: - Hi [~Weijie Guo] , thanks for your reminder. I have r

[jira] [Commented] (FLINK-29816) Userfunction exception in ProcessWindowFunction was called before invoke during restore state(subtask was in INITIALIZING state), but SteamTask skip handle Exception

[ https://issues.apache.org/jira/browse/FLINK-29816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693756#comment-17693756 ] Rui Fan commented on FLINK-29816: - Thanks [~RocMarshal] for your contribution, and [~Wei

[jira] [Assigned] (FLINK-31221) Fix Typo in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-31221: --- Assignee: Shilun Fan > Fix Typo in YarnConfigOptions > - > >

[jira] [Commented] (FLINK-31221) Fix Typo in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694424#comment-17694424 ] Rui Fan commented on FLINK-31221: - Hi [~slfan1989] , thanks for your fix:) apache:maste

[jira] [Closed] (FLINK-31221) Fix Typo in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-31221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31221. --- Resolution: Fixed > Fix Typo in YarnConfigOptions > - > > Key: F

<    5   6   7   8   9   10   11   12   13   14   >