[jira] [Updated] (FLINK-33386) Support tasks balancing at slot level for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33386: --- Summary: Support tasks balancing at slot level for Default Scheduler (was: Introduce the strategy f

[jira] [Updated] (FLINK-33388) Support tasks balancing at TM level for Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33388: --- Summary: Support tasks balancing at TM level for Default Scheduler (was: Implement tasks to taskman

[jira] [Created] (FLINK-33392) Add the documentation page for balanced tasks scheduling

RocMarshal created FLINK-33392: -- Summary: Add the documentation page for balanced tasks scheduling Key: FLINK-33392 URL: https://issues.apache.org/jira/browse/FLINK-33392 Project: Flink Issue Ty

[jira] [Created] (FLINK-33391) Support tasks balancing at TM level for Adaptive Scheduler

RocMarshal created FLINK-33391: -- Summary: Support tasks balancing at TM level for Adaptive Scheduler Key: FLINK-33391 URL: https://issues.apache.org/jira/browse/FLINK-33391 Project: Flink Issue

[jira] [Created] (FLINK-33390) Support slot balancing at TM level for Adaptive Scheduler

RocMarshal created FLINK-33390: -- Summary: Support slot balancing at TM level for Adaptive Scheduler Key: FLINK-33390 URL: https://issues.apache.org/jira/browse/FLINK-33390 Project: Flink Issue T

[jira] [Updated] (FLINK-33388) Implement tasks to taskmanagers balancing for the Default Scheduler

[ https://issues.apache.org/jira/browse/FLINK-33388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-33388: --- Summary: Implement tasks to taskmanagers balancing for the Default Scheduler (was: Implement slots

[jira] [Created] (FLINK-33389) Introduce the assigner for Adaptive Scheduler to pursuit task balancing based slots level

RocMarshal created FLINK-33389: -- Summary: Introduce the assigner for Adaptive Scheduler to pursuit task balancing based slots level Key: FLINK-33389 URL: https://issues.apache.org/jira/browse/FLINK-33389

[jira] [Created] (FLINK-33388) Implement slots to taskmanagers balancing for the Default Scheduler

RocMarshal created FLINK-33388: -- Summary: Implement slots to taskmanagers balancing for the Default Scheduler Key: FLINK-33388 URL: https://issues.apache.org/jira/browse/FLINK-33388 Project: Flink

[jira] [Created] (FLINK-33387) Introduce the abstraction and the interface about loading

RocMarshal created FLINK-33387: -- Summary: Introduce the abstraction and the interface about loading Key: FLINK-33387 URL: https://issues.apache.org/jira/browse/FLINK-33387 Project: Flink Issue T

[jira] [Created] (FLINK-33386) Introduce the strategy for Default Scheduler to pursue tasks balancing based on slots level.

RocMarshal created FLINK-33386: -- Summary: Introduce the strategy for Default Scheduler to pursue tasks balancing based on slots level. Key: FLINK-33386 URL: https://issues.apache.org/jira/browse/FLINK-33386

[jira] [Commented] (FLINK-33320) Support Dynamic Logger Level Adjustment

[ https://issues.apache.org/jira/browse/FLINK-33320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1522#comment-1522 ] RocMarshal commented on FLINK-33320: Hi, [~fanrui] Thank you for the assign~ I'm wil

[jira] [Created] (FLINK-33320) Support Dynamic Logger Level Adjustment

RocMarshal created FLINK-33320: -- Summary: Support Dynamic Logger Level Adjustment Key: FLINK-33320 URL: https://issues.apache.org/jira/browse/FLINK-33320 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17774850#comment-17774850 ] RocMarshal commented on FLINK-25420: Hi, [~eskabetxe] [~martijnvisser] Thank you ver

[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 ] RocMarshal updated FLINK-31757: --- Summary: Support Balanced Tasks Scheduling (was: Optimize Flink un-balanced tasks scheduling) > Su

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-31757: --- Labels: pull-request-available (was: pull-request-available stale-assigned) > Optimize Flink un-bal

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750078#comment-17750078 ] RocMarshal edited comment on FLINK-31757 at 8/2/23 3:54 AM:

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17750078#comment-17750078 ] RocMarshal commented on FLINK-31757: Hi, [~heigebupahei] Thanks for your attention.

[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&focusedCommentId=17739030#comment-17739030 ] RocMarshal commented on FLINK-29050: Hello, sorry for the late update. Could someone

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735249#comment-17735249 ] RocMarshal commented on FLINK-20628: [~martijnvisser] Yes,I'd like to do it. There's

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17734964#comment-17734964 ] RocMarshal commented on FLINK-20628: [~martijnvisser] Thank you for your reply. Yes,

[jira] [Commented] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17733990#comment-17733990 ] RocMarshal commented on FLINK-20628: Hi, [pscls|https://github.com/pscls] Thank you

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727041#comment-17727041 ] RocMarshal commented on FLINK-31757: I have compiled a draft   [https://docs.google.

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17727041#comment-17727041 ] RocMarshal edited comment on FLINK-31757 at 5/29/23 8:25 AM: -

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17715580#comment-17715580 ] RocMarshal commented on FLINK-31757: I am still working on this jira, and due to the

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711897#comment-17711897 ] RocMarshal commented on FLINK-31757: Thanks for your [~Weijie Guo] sorted concise an

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711895#comment-17711895 ] RocMarshal commented on FLINK-31757: Thank you  [~fanrui] & [~huwh] very much. I'll

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711875#comment-17711875 ] RocMarshal commented on FLINK-31757: Based on this problem, we has achieved balanced

[jira] [Reopened] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal reopened FLINK-31757: > Optimize Flink un-balanced tasks scheduling > --- > >

[jira] [Comment Edited] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711776#comment-17711776 ] RocMarshal edited comment on FLINK-31757 at 4/13/23 9:24 AM: -

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711776#comment-17711776 ] RocMarshal commented on FLINK-31757: h1. Problem description and impact Supposed a

[jira] [Commented] (FLINK-29672) Support oracle catalog

[ https://issues.apache.org/jira/browse/FLINK-29672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710104#comment-17710104 ] RocMarshal commented on FLINK-29672: It looks like a duplicated Jira as https://iss

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710022#comment-17710022 ] RocMarshal commented on FLINK-31757: [~Weijie Guo] Glad to get your attention and re

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-31757: --- Summary: Optimize Flink un-balanced tasks scheduling (was: Optimize Flink tasks un-balanced schedul

[jira] [Created] (FLINK-31757) Optimize Flink tasks un-balanced scheduling

RocMarshal created FLINK-31757: -- Summary: Optimize Flink tasks un-balanced scheduling Key: FLINK-31757 URL: https://issues.apache.org/jira/browse/FLINK-31757 Project: Flink Issue Type: Improveme

[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=17692057#comment-17692057 ] RocMarshal commented on FLINK-29816: As described in the historical comments and des

[jira] [Updated] (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:all-tabpanel ] RocMarshal updated FLINK-29816: --- Attachment: image-2023-02-22-17-26-06-200.png > Userfunction exception in ProcessWindowFunction was

[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=17691339#comment-17691339 ] RocMarshal commented on FLINK-29816: [~Weijie Guo] thanks for the reply. I'm interes

[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=17691132#comment-17691132 ] RocMarshal commented on FLINK-29816: hi, [~Weijie Guo] Any process on this issue ? 

[jira] [Commented] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state.

[ https://issues.apache.org/jira/browse/FLINK-30511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654895#comment-17654895 ] RocMarshal commented on FLINK-30511: Thank you [~Weijie Guo] [~kevin.cyj] . Looking

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652232#comment-17652232 ] RocMarshal commented on FLINK-25421: Get it. Thanks a lot~ [~eskabetxe]  > Port JDB

[jira] [Updated] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state.

[ https://issues.apache.org/jira/browse/FLINK-30511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-30511: --- Description: * Code segment: {code:java} public class OnTimerDemo { public static void main(St

[jira] [Created] (FLINK-30511) Ignore the Exception in user-timer Triggerble when recover form state.

RocMarshal created FLINK-30511: -- Summary: Ignore the Exception in user-timer Triggerble when recover form state. Key: FLINK-30511 URL: https://issues.apache.org/jira/browse/FLINK-30511 Project: Flink

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651050#comment-17651050 ] RocMarshal commented on FLINK-25421: Hi [~eskabetxe] Is here any new progress about

[jira] [Commented] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615467#comment-17615467 ] RocMarshal commented on FLINK-26999: [~rmetzger] , The FLIP current content should b

[jira] [Updated] (FLINK-29548) Remove deprecated class files of the 'flink-test-utils' module.

[ https://issues.apache.org/jira/browse/FLINK-29548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-29548: --- Fix Version/s: 1.17.0 (was: 1.16.1) > Remove deprecated class files of the 'f

[jira] [Created] (FLINK-29548) Remove deprecated class files of the 'flink-test-utils' module.

RocMarshal created FLINK-29548: -- Summary: Remove deprecated class files of the 'flink-test-utils' module. Key: FLINK-29548 URL: https://issues.apache.org/jira/browse/FLINK-29548 Project: Flink

[jira] [Commented] (FLINK-25540) [JUnit5 Migration] Module: flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17614358#comment-17614358 ] RocMarshal commented on FLINK-25540: Of course. anytime. [~mapohl]  Thank you~ > [J

[jira] [Closed] (FLINK-29049) Remove the deprecated classes in the flink-java module.

[ https://issues.apache.org/jira/browse/FLINK-29049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal closed FLINK-29049. -- Resolution: Duplicate > Remove the deprecated classes in the flink-java module. >

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

RocMarshal created FLINK-29050: -- Summary: [JUnit5 Migration] Module: flink-hadoop-compatibility Key: FLINK-29050 URL: https://issues.apache.org/jira/browse/FLINK-29050 Project: Flink Issue Type:

[jira] [Created] (FLINK-29049) Remove the deprecated classes in the flink-java module.

RocMarshal created FLINK-29049: -- Summary: Remove the deprecated classes in the flink-java module. Key: FLINK-29049 URL: https://issues.apache.org/jira/browse/FLINK-29049 Project: Flink Issue Typ

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576785#comment-17576785 ] RocMarshal commented on FLINK-25421: Hi, [~eskabetxe] Would you like to make the dra

[jira] [Commented] (FLINK-28659) [JUnit5 Migration] Module: flink-java

[ https://issues.apache.org/jira/browse/FLINK-28659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570471#comment-17570471 ] RocMarshal commented on FLINK-28659: HI, [~shengkai] , Could you help to assign this

[jira] [Updated] (FLINK-28659) [JUnit5 Migration] Module: flink-java

[ https://issues.apache.org/jira/browse/FLINK-28659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-28659: --- Parent: FLINK-25325 Issue Type: Sub-task (was: Improvement) > [JUnit5 Migration] Module: fl

[jira] [Created] (FLINK-28659) [JUnit5 Migration] Module: flink-java

RocMarshal created FLINK-28659: -- Summary: [JUnit5 Migration] Module: flink-java Key: FLINK-28659 URL: https://issues.apache.org/jira/browse/FLINK-28659 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17570418#comment-17570418 ] RocMarshal commented on FLINK-25545: Thx [~ruanhang1993] . The PR of the ticket was

[jira] [Comment Edited] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559129#comment-17559129 ] RocMarshal edited comment on FLINK-25420 at 6/27/22 11:35 AM:

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17559129#comment-17559129 ] RocMarshal commented on FLINK-25420: Hi, [~jingge] [~martijnvisser] . Would you mind

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550967#comment-17550967 ] RocMarshal commented on FLINK-25420: OKay. I'll give the Source part draft in the ne

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17550796#comment-17550796 ] RocMarshal commented on FLINK-25420: [~martijnvisser] Sorry for the late response.

[jira] [Commented] (FLINK-27794) The primary key obtained from MySQL is incorrect by using MysqlCatalog

[ https://issues.apache.org/jira/browse/FLINK-27794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17544366#comment-17544366 ] RocMarshal commented on FLINK-27794: Thanks [~dusukang] for the reporting it and [~m

[jira] [Comment Edited] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530288#comment-17530288 ] RocMarshal edited comment on FLINK-25545 at 4/30/22 1:03 AM: -

[jira] [Commented] (FLINK-25543) [JUnit5 Migration] Module: flink-yarn

[ https://issues.apache.org/jira/browse/FLINK-25543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530289#comment-17530289 ] RocMarshal commented on FLINK-25543: [~xtsong] Yes. Just ping me if there's anything

[jira] [Commented] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530288#comment-17530288 ] RocMarshal commented on FLINK-25545: Updated the state of the PR. > [JUnit5 Migrati

[jira] [Commented] (FLINK-26496) [JUnit5 Migration] Module: flink-yarn-test

[ https://issues.apache.org/jira/browse/FLINK-26496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17530285#comment-17530285 ] RocMarshal commented on FLINK-26496: [~xtsong] Yes. Just ping me if there's anything

[jira] [Created] (FLINK-27267) [JUnit5 Migration] Module: flink-contrib

RocMarshal created FLINK-27267: -- Summary: [JUnit5 Migration] Module: flink-contrib Key: FLINK-27267 URL: https://issues.apache.org/jira/browse/FLINK-27267 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27143) [JUnit5 Migration] Module: flink-docs

RocMarshal created FLINK-27143: -- Summary: [JUnit5 Migration] Module: flink-docs Key: FLINK-27143 URL: https://issues.apache.org/jira/browse/FLINK-27143 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516222#comment-17516222 ] RocMarshal commented on FLINK-25738: Hi [~martijnvisser] , I notice that the related

[jira] [Commented] (FLINK-26999) Introduce ClickHouse Connector

[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17516218#comment-17516218 ] RocMarshal commented on FLINK-26999: [~monster#12]  Thanks for the operation. Rece

[jira] [Commented] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17510194#comment-17510194 ] RocMarshal commented on FLINK-22315: [~lsy] Thanks for the comments,  cc [~jark] Ple

[jira] [Created] (FLINK-26758) [JUnit5 Migration] Module: flink-container

RocMarshal created FLINK-26758: -- Summary: [JUnit5 Migration] Module: flink-container Key: FLINK-26758 URL: https://issues.apache.org/jira/browse/FLINK-26758 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26747) [JUnit5 Migration] Module: flink-external-resources

[ https://issues.apache.org/jira/browse/FLINK-26747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-26747: --- Parent: FLINK-25325 Issue Type: Sub-task (was: Improvement) > [JUnit5 Migration] Module: fl

[jira] [Created] (FLINK-26747) [JUnit5 Migration] Module: flink-external-resources

RocMarshal created FLINK-26747: -- Summary: [JUnit5 Migration] Module: flink-external-resources Key: FLINK-26747 URL: https://issues.apache.org/jira/browse/FLINK-26747 Project: Flink Issue Type: I

[jira] [Commented] (FLINK-25213) Add @Public annotations to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-25213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503638#comment-17503638 ] RocMarshal commented on FLINK-25213: Hi, [~monster#12]   Is there any progress to re

[jira] [Updated] (FLINK-26496) [JUnit5 Migration] Module: flink-yarn-test

[ https://issues.apache.org/jira/browse/FLINK-26496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-26496: --- Parent: FLINK-25325 Issue Type: Sub-task (was: Improvement) > [JUnit5 Migration] Module: fl

[jira] [Commented] (FLINK-24349) Support customized Calalogs via JDBC

[ https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502720#comment-17502720 ] RocMarshal commented on FLINK-24349:  [~martijnvisser] [~Bo Cui]  Is there any progr

[jira] [Commented] (FLINK-26496) [JUnit5 Migration] Module: flink-yarn-test

[ https://issues.apache.org/jira/browse/FLINK-26496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501708#comment-17501708 ] RocMarshal commented on FLINK-26496: Could someone please assign this ticket to me ?

[jira] [Created] (FLINK-26496) [JUnit5 Migration] Module: flink-yarn-test

RocMarshal created FLINK-26496: -- Summary: [JUnit5 Migration] Module: flink-yarn-test Key: FLINK-26496 URL: https://issues.apache.org/jira/browse/FLINK-26496 Project: Flink Issue Type: Improvemen

[jira] (FLINK-22315) Support ADD column/constraint/watermark for ALTER TABLE statement

[ https://issues.apache.org/jira/browse/FLINK-22315 ] RocMarshal deleted comment on FLINK-22315: was (Author: rocmarshal): Changes in other SQL syntax can  cause easily conflicts between the current PR and the master branch, so it would be bett

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498890#comment-17498890 ] RocMarshal commented on FLINK-25544: [~arvid]  I'm very interested in this jira. Cou

[jira] [Commented] (FLINK-25540) [JUnit5 Migration] Module: flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-25540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17498889#comment-17498889 ] RocMarshal commented on FLINK-25540: Hi, [~chesnay]  I'm very interested in this jir

[jira] [Commented] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496776#comment-17496776 ] RocMarshal commented on FLINK-25738: [~baisike] I'll check it asap. Thanks for the t

[jira] [Commented] (FLINK-25545) [JUnit5 Migration] Module: flink-clients

[ https://issues.apache.org/jira/browse/FLINK-25545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17496764#comment-17496764 ] RocMarshal commented on FLINK-25545: [~chesnay]  [~ruanhang1993]  May I get the tick

[jira] [Commented] (FLINK-25420) Port JDBC Source to new Source API (FLIP-27)

[ https://issues.apache.org/jira/browse/FLINK-25420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495476#comment-17495476 ] RocMarshal commented on FLINK-25420: I'll give the refactor draft ASAP. [~MartijnVis

[jira] [Commented] (FLINK-24112) Embedded MariaDB cannot be instantiated on MacOS

[ https://issues.apache.org/jira/browse/FLINK-24112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17495475#comment-17495475 ] RocMarshal commented on FLINK-24112: [~mapohl]  [~arvid]    The embedded mariadb wa

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1744#comment-1744 ] RocMarshal commented on FLINK-25825: [~MartijnVisser] I have verified it locally on

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488737#comment-17488737 ] RocMarshal commented on FLINK-25825: [~gaoyunhaii] [~MartijnVisser] Could you help m

[jira] [Commented] (FLINK-24477) Add MongoDB sink

[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488580#comment-17488580 ] RocMarshal commented on FLINK-24477: Thanks  [~nir.tsruya] , cc [~monster#12] > Add

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17488140#comment-17488140 ] RocMarshal commented on FLINK-25825: Thanks [~MartijnVisser] [~gaoyunhaii] . I veri

[jira] [Comment Edited] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487871#comment-17487871 ] RocMarshal edited comment on FLINK-25825 at 2/7/22, 5:08 AM: -

[jira] [Commented] (FLINK-25825) MySqlCatalogITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487871#comment-17487871 ] RocMarshal commented on FLINK-25825: Sorry for not checking the issue in time. [~Ma

[jira] [Commented] (FLINK-24477) Add MongoDB sink

[ https://issues.apache.org/jira/browse/FLINK-24477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487652#comment-17487652 ] RocMarshal commented on FLINK-24477: Hi, guys . May I get any detailed difference b

[jira] [Updated] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page.

[ https://issues.apache.org/jira/browse/FLINK-25800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25800: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Update wrong links in the dat

[jira] [Created] (FLINK-25800) Update wrong links in the datastream/execution_mode.md page.

RocMarshal created FLINK-25800: -- Summary: Update wrong links in the datastream/execution_mode.md page. Key: FLINK-25800 URL: https://issues.apache.org/jira/browse/FLINK-25800 Project: Flink Iss

[jira] [Updated] (FLINK-25799) Translate table/filesystem.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25799: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Translate table/filesystem.md

[jira] [Created] (FLINK-25799) Translate table/filesystem.md page into Chinese.

RocMarshal created FLINK-25799: -- Summary: Translate table/filesystem.md page into Chinese. Key: FLINK-25799 URL: https://issues.apache.org/jira/browse/FLINK-25799 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-25798) Translate datastream/formats/text_files.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25798: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Translate datastream/formats/

[jira] [Created] (FLINK-25798) Translate datastream/formats/text_files.md page into Chinese.

RocMarshal created FLINK-25798: -- Summary: Translate datastream/formats/text_files.md page into Chinese. Key: FLINK-25798 URL: https://issues.apache.org/jira/browse/FLINK-25798 Project: Flink Is

[jira] [Updated] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

[ https://issues.apache.org/jira/browse/FLINK-25797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-25797: --- Parent: FLINK-25738 Issue Type: Sub-task (was: Improvement) > Translate datastream/formats/

[jira] [Created] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

RocMarshal created FLINK-25797: -- Summary: Translate datastream/formats/parquet.md page into Chinese. Key: FLINK-25797 URL: https://issues.apache.org/jira/browse/FLINK-25797 Project: Flink Issue

[jira] [Comment Edited] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17481536#comment-17481536 ] RocMarshal edited comment on FLINK-25738 at 1/25/22, 4:48 AM:

<    1   2   3   >