[jira] [Comment Edited] (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=17848416#comment-17848416 ] Rui Fan edited comment on FLINK-35215 at 5/25/24 3:17 PM: -- Merged to master

[jira] [Commented] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848430#comment-17848430 ] Rui Fan commented on FLINK-35293: - [~xiasun] Thanks for the update! :) > FLIP-445: Support dynamic

[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=17848416#comment-17848416 ] Rui Fan commented on FLINK-35215: - Merged to master via: * 46db92641602313c4f5c1390807222c344880e2d *

[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: Fix Version/s: 1.20.0 > The performance of serializerKryo and serializerKryoWithoutRegistration are >

[jira] [Comment Edited] (FLINK-25537) [JUnit5 Migration] Module: flink-core

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845561#comment-17845561 ] Rui Fan edited comment on FLINK-25537 at 5/21/24 1:29 AM: -- Merged to

[jira] [Commented] (FLINK-33892) FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847845#comment-17847845 ] Rui Fan commented on FLINK-33892: - [~JunRuiLi] Thank you very much for the quick update! > FLIP-383:

[jira] [Commented] (FLINK-33892) FLIP-383: Support Job Recovery from JobMaster Failures for Batch Jobs

[ https://issues.apache.org/jira/browse/FLINK-33892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847780#comment-17847780 ] Rui Fan commented on FLINK-33892: - Hi [~JunRuiLi] [~zhuzh] , I saw FLIP-383 is almost done in 1.20,

[jira] [Resolved] (FLINK-29481) Show JobType on WebUI

[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-29481. - Release Note: We display the JobType on the Flink WebUI. The job maintainer or platform administrator

[jira] [Resolved] (FLINK-35225) Remove Execution mode in Flink WebUI

[ https://issues.apache.org/jira/browse/FLINK-35225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35225. - Resolution: Fixed > Remove Execution mode in Flink WebUI > > >

[jira] [Commented] (FLINK-35225) Remove Execution mode in Flink WebUI

[ https://issues.apache.org/jira/browse/FLINK-35225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846901#comment-17846901 ] Rui Fan commented on FLINK-35225: - merged to master(1.20.0) via:

[jira] [Resolved] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35226. - Resolution: Fixed > Deprecate execution-mode in ExecutionConfigInfo related rest api >

[jira] [Commented] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846900#comment-17846900 ] Rui Fan commented on FLINK-35226: - merged to master(1.20.0) via:

[jira] [Resolved] (FLINK-34537) Autoscaler JDBC Support HikariPool

[ https://issues.apache.org/jira/browse/FLINK-34537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34537. - Fix Version/s: kubernetes-operator-1.9.0 (was: 1.8.0) Resolution: Fixed >

[jira] [Assigned] (FLINK-34537) Autoscaler JDBC Support HikariPool

[ https://issues.apache.org/jira/browse/FLINK-34537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34537: --- Assignee: ConradJam > Autoscaler JDBC Support HikariPool > -- > >

[jira] [Commented] (FLINK-34537) Autoscaler JDBC Support HikariPool

[ https://issues.apache.org/jira/browse/FLINK-34537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846840#comment-17846840 ] Rui Fan commented on FLINK-34537: - merged to 1.9.0 via eb191337251410d9d40300a0050a17d5c2300d8b >

[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=17846777#comment-17846777 ] Rui Fan commented on FLINK-33109: - Thanks [~YordanPavlov] for the feedback, let me close this JIRA. >

[jira] [Closed] (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:all-tabpanel ] Rui Fan closed FLINK-33109. --- Resolution: Not A Problem > Watermark alignment not applied after recovery from checkpoint >

[jira] [Commented] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document

[ https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846569#comment-17846569 ] Rui Fan commented on FLINK-35357: - IIUC, kubernetes.operator.plugins.listeners..class is similar to

[jira] [Commented] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document

[ https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846566#comment-17846566 ] Rui Fan commented on FLINK-35357: - Thanks [~xinzhuxianshenger] for reporting this JIRA. I checked the

[jira] [Assigned] (FLINK-35357) Add "kubernetes.operator.plugins.listeners" parameter description to the Operator configuration document

[ https://issues.apache.org/jira/browse/FLINK-35357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35357: --- Assignee: Yang Zhou > Add "kubernetes.operator.plugins.listeners" parameter description to the >

[jira] [Commented] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846473#comment-17846473 ] Rui Fan commented on FLINK-35293: - Hi [~xiasun] , I saw you added the release note for FLIP-445, would

[jira] [Resolved] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35041. - Fix Version/s: 1.20.0 Resolution: Fixed IIUC, this issue has been fixed in master  branch, so I

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845606#comment-17845606 ] Rui Fan commented on FLINK-35041: - Merged to master (1.20.0) via:  

[jira] [Commented] (FLINK-25537) [JUnit5 Migration] Module: flink-core

[ https://issues.apache.org/jira/browse/FLINK-25537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845561#comment-17845561 ] Rui Fan commented on FLINK-25537: - Merged to master(1.20.0) via:

[jira] [Assigned] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35041: --- Assignee: Rui Fan (was: Feifan Wang) >

[jira] [Resolved] (FLINK-34212) Autoscaler Standalone should clean up stopped jobs to prevent memory leaks

[ https://issues.apache.org/jira/browse/FLINK-34212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34212. - Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed > Autoscaler Standalone should clean

[jira] [Commented] (FLINK-34212) Autoscaler Standalone should clean up stopped jobs to prevent memory leaks

[ https://issues.apache.org/jira/browse/FLINK-34212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844906#comment-17844906 ] Rui Fan commented on FLINK-34212: - merged to main(1.9.0) via 04829bf1fadb45d8f76849f4263596c01b94fee3 >

[jira] [Commented] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844903#comment-17844903 ] Rui Fan commented on FLINK-35040: - I attached 3 flamegraphs here, these flamegraphs are generated on

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: result1.html result2.html result3.html > The performance of

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844901#comment-17844901 ] Rui Fan commented on FLINK-35041: -

[jira] [Updated] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes

[ https://issues.apache.org/jira/browse/FLINK-35315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35315: Fix Version/s: 1.20.0 > MemoryManagerConcurrentModReleaseTest executes more than 15 minutes >

[jira] [Created] (FLINK-35315) MemoryManagerConcurrentModReleaseTest executes more than 15 minutes

Rui Fan created FLINK-35315: --- Summary: MemoryManagerConcurrentModReleaseTest executes more than 15 minutes Key: FLINK-35315 URL: https://issues.apache.org/jira/browse/FLINK-35315 Project: Flink

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: (was: result5.html) > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: (was: result6.html) > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: (was: result4.html) > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: (was: result2.html) > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: (was: result3.html) > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: (was: result1.html) > The performance of serializerHeavyString regresses since April 3 >

[jira] [Updated] (FLINK-35040) The performance of serializerHeavyString regresses since April 3

[ https://issues.apache.org/jira/browse/FLINK-35040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35040: Attachment: result4.html result5.html result1.html

[jira] [Resolved] (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 resolved FLINK-33463. - Fix Version/s: jdbc-3.3.0 Resolution: Fixed > Support the implementation of dynamic source

[jira] [Commented] (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=17844836#comment-17844836 ] Rui Fan commented on FLINK-33463: - Merged to main(3.3.0) via: *

[jira] [Resolved] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35306. - Resolution: Fixed > Flink cannot compile with jdk17 > --- > >

[jira] [Commented] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844605#comment-17844605 ] Rui Fan commented on FLINK-35306: - Merged to master(1.20) via 1c34ca011cacdbb3b0f48b485eac89dd913d29bf

[jira] [Commented] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844530#comment-17844530 ] Rui Fan commented on FLINK-35306: - Sounds make sense to me, let's follow FLINK-35307. > Flink cannot

[jira] [Updated] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35306: Component/s: Build System / CI Tests > Flink cannot compile with jdk17 >

[jira] [Updated] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35306: Description: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=59380=results]

[jira] [Updated] (FLINK-35306) Flink cannot compile with jdk17

[ https://issues.apache.org/jira/browse/FLINK-35306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35306: Description: Reason: TypeSerializerUpgradeTestBase.UpgradeVerifier update the schemaCompatibilityMatcher

[jira] [Created] (FLINK-35306) Flink cannot compile with jdk17

Rui Fan created FLINK-35306: --- Summary: Flink cannot compile with jdk17 Key: FLINK-35306 URL: https://issues.apache.org/jira/browse/FLINK-35306 Project: Flink Issue Type: Bug Affects Versions:

[jira] [Commented] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844507#comment-17844507 ] Rui Fan commented on FLINK-34954: - Hi [~q.xu] , I wanna check with you did you meet this issue in your

[jira] [Assigned] (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 reassigned FLINK-35215: --- Assignee: Rui Fan > The performance of serializerKryo and serializerKryoWithoutRegistration are >

[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=17844504#comment-17844504 ] Rui Fan commented on FLINK-35215: - Thanks [~kkrugler] for the feedback! {quote} * I was surprised that

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844215#comment-17844215 ] Rui Fan commented on FLINK-35041: - I have asked [~Feifan Wang] offline, he will check it this week with

[jira] [Resolved] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level

[ https://issues.apache.org/jira/browse/FLINK-35105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35105. - Resolution: Fixed > Support setting default Autoscaler options at autoscaler standalone level >

[jira] [Commented] (FLINK-35105) Support setting default Autoscaler options at autoscaler standalone level

[ https://issues.apache.org/jira/browse/FLINK-35105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844136#comment-17844136 ] Rui Fan commented on FLINK-35105: - Merged to main(1.9.0) via: 249a6945aaa847a506c42111d7332ad072578095

[jira] [Commented] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844098#comment-17844098 ] Rui Fan commented on FLINK-35176: - Merged to main(3.3.0) via: *

[jira] [Resolved] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35176. - Resolution: Fixed > Support property authentication connection for JDBC catalog & dynamic table >

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

[ https://issues.apache.org/jira/browse/FLINK-32852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-32852. - Resolution: Fixed > [JUnit5 Migration] The scheduler package of flink-runtime module >

[jira] [Comment Edited] (FLINK-32852) [JUnit5 Migration] The scheduler package of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805348#comment-17805348 ] Rui Fan edited comment on FLINK-32852 at 5/7/24 2:01 AM: - Merged to master(1.19)

[jira] [Resolved] (FLINK-34980) Translate overview document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-34980. - Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed > Translate overview document into

[jira] [Commented] (FLINK-34980) Translate overview document into Chinese

[ https://issues.apache.org/jira/browse/FLINK-34980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843696#comment-17843696 ] Rui Fan commented on FLINK-34980: - Merged to main(1.9.0) via :9db83bcb7afd9754ea538e293297a7e86cfae781

[jira] [Commented] (FLINK-35222) Adding getJobType for AccessExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-35222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841854#comment-17841854 ] Rui Fan commented on FLINK-35222: - Merged to master(1.20.0) via:

[jira] [Commented] (FLINK-35224) Show the JobType on Flink WebUI

[ https://issues.apache.org/jira/browse/FLINK-35224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841856#comment-17841856 ] Rui Fan commented on FLINK-35224: - Merged to master(1.20.0) via:

[jira] [Resolved] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35223. - Resolution: Fixed > Add jobType in JobDetailsInfo related rest api >

[jira] [Resolved] (FLINK-35224) Show the JobType on Flink WebUI

[ https://issues.apache.org/jira/browse/FLINK-35224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35224. - Resolution: Fixed > Show the JobType on Flink WebUI > --- > >

[jira] [Resolved] (FLINK-35222) Adding getJobType for AccessExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-35222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35222. - Resolution: Fixed > Adding getJobType for AccessExecutionGraph >

[jira] [Commented] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841855#comment-17841855 ] Rui Fan commented on FLINK-35223: - Merged to master(1.20.0) via:

[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=17840693#comment-17840693 ] Rui Fan commented on FLINK-35215: - Here is the benchmark result for my test:  

[jira] [Comment Edited] (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=17840693#comment-17840693 ] Rui Fan edited comment on FLINK-35215 at 4/25/24 8:00 AM: -- Here is the

[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=17840678#comment-17840678 ] Rui Fan commented on FLINK-35215: - Hi [~q.xu]  [~kkrugler] , flink community has a performance

[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: Attachment: image-2024-04-25-15-00-32-410.png > The performance of serializerKryo and

[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: Attachment: image-2024-04-25-14-57-55-231.png > The performance of serializerKryo and

[jira] [Assigned] (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 reassigned FLINK-33463: --- Assignee: RocMarshal > Support the implementation of dynamic source tables based on the new source

[jira] [Assigned] (FLINK-33462) Sort out the document page about the new Jdbc source.

[ https://issues.apache.org/jira/browse/FLINK-33462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33462: --- Assignee: RocMarshal > Sort out the document page about the new Jdbc source. >

[jira] [Assigned] (FLINK-33461) Support streaming related semantics for the new jdbc source

[ https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33461: --- Assignee: RocMarshal > Support streaming related semantics for the new jdbc source >

[jira] [Assigned] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35176: --- Assignee: RocMarshal > Support property authentication connection for JDBC catalog & dynamic table

[jira] [Resolved] (FLINK-33460) Support property authentication connection.

[ https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33460. - Resolution: Fixed > Support property authentication connection. >

[jira] [Updated] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35176: Fix Version/s: jdbc-3.3.0 > Support property authentication connection for JDBC catalog & dynamic table >

[jira] [Resolved] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-29050. - Fix Version/s: 1.20.0 Resolution: Fixed > [JUnit5 Migration] Module: flink-hadoop-compatibility

[jira] [Updated] (FLINK-33460) Support property authentication connection.

[ https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-33460: Fix Version/s: jdbc-3.3.0 > Support property authentication connection. >

[jira] [Commented] (FLINK-29050) [JUnit5 Migration] Module: flink-hadoop-compatibility

[ https://issues.apache.org/jira/browse/FLINK-29050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840618#comment-17840618 ] Rui Fan commented on FLINK-29050: - Merged to master(1.20.0) via: *

[jira] [Commented] (FLINK-33460) Support property authentication connection.

[ https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840615#comment-17840615 ] Rui Fan commented on FLINK-33460: - Merged to main via bb43b3c18fda6a2e587b3a3941d697803fe86441 >

[jira] [Assigned] (FLINK-33460) Support property authentication connection.

[ https://issues.apache.org/jira/browse/FLINK-33460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-33460: --- Assignee: RocMarshal > Support property authentication connection. >

[jira] [Resolved] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-35088. - Fix Version/s: 1.20.0 Resolution: Fixed > watermark alignment maxAllowedWatermarkDrift and

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840610#comment-17840610 ] Rui Fan commented on FLINK-35088: - Merged to master(1.20) via: 09531994e3cde35ec159315389cf20396c8e21bd

[jira] [Created] (FLINK-35227) Remove execution-mode in ExecutionConfigInfo

Rui Fan created FLINK-35227: --- Summary: Remove execution-mode in ExecutionConfigInfo Key: FLINK-35227 URL: https://issues.apache.org/jira/browse/FLINK-35227 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35226: Component/s: Runtime / REST (was: Runtime / Web Frontend) > Deprecate execution-mode

[jira] [Updated] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

[ https://issues.apache.org/jira/browse/FLINK-35223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35223: Component/s: Runtime / REST (was: Runtime / Web Frontend) > Add jobType in

[jira] [Created] (FLINK-35226) Deprecate execution-mode in ExecutionConfigInfo related rest api

Rui Fan created FLINK-35226: --- Summary: Deprecate execution-mode in ExecutionConfigInfo related rest api Key: FLINK-35226 URL: https://issues.apache.org/jira/browse/FLINK-35226 Project: Flink

[jira] [Created] (FLINK-35222) Adding getJobType for AccessExecutionGraph

Rui Fan created FLINK-35222: --- Summary: Adding getJobType for AccessExecutionGraph Key: FLINK-35222 URL: https://issues.apache.org/jira/browse/FLINK-35222 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35225) Remove Execution mode in Flink WebUI

Rui Fan created FLINK-35225: --- Summary: Remove Execution mode in Flink WebUI Key: FLINK-35225 URL: https://issues.apache.org/jira/browse/FLINK-35225 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35224) Show the JobType on Flink WebUI

Rui Fan created FLINK-35224: --- Summary: Show the JobType on Flink WebUI Key: FLINK-35224 URL: https://issues.apache.org/jira/browse/FLINK-35224 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35223) Add jobType in JobDetailsInfo related rest api

Rui Fan created FLINK-35223: --- Summary: Add jobType in JobDetailsInfo related rest api Key: FLINK-35223 URL: https://issues.apache.org/jira/browse/FLINK-35223 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-29481) Show JobType on WebUI

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

[jira] [Comment Edited] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840040#comment-17840040 ] Rui Fan edited comment on FLINK-35088 at 4/24/24 2:10 AM: -- Hi [~elon] , thanks

[jira] [Assigned] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-35088: --- Assignee: elon_X > watermark alignment maxAllowedWatermarkDrift and updateInterval param need >

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840043#comment-17840043 ] Rui Fan commented on FLINK-35088: - [~elon] thank you for your volunteering, assigned. > watermark

[jira] [Commented] (FLINK-35088) watermark alignment maxAllowedWatermarkDrift and updateInterval param need check

[ https://issues.apache.org/jira/browse/FLINK-35088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17840040#comment-17840040 ] Rui Fan commented on FLINK-35088: - Hi [~elon] , thanks for reporting this issue. It makes sense to add

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839977#comment-17839977 ] Rui Fan commented on FLINK-35187: - Thank you very much for the feedback and update! > FLIP-435:

[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=17839949#comment-17839949 ] Rui Fan commented on FLINK-35215: - Hi [~q.xu] , would you mind taking a look this issue in your free

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

Rui Fan created FLINK-35215: --- Summary: The performance of serializerKryo and serializerKryoWithoutRegistration are regressed Key: FLINK-35215 URL: https://issues.apache.org/jira/browse/FLINK-35215 Project:

  1   2   3   4   5   6   7   8   9   10   >