[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=1522#comment-1522 ] RocMarshal commented on FLINK-33320: Hi, [~fanrui] Thank you for the assign~ I'm willing to

[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=17774850#comment-17774850 ] RocMarshal commented on FLINK-25420: Hi, [~eskabetxe] [~martijnvisser] Thank you very much for

[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) >

[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

[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=17750078#comment-17750078 ] RocMarshal edited comment on FLINK-31757 at 8/2/23 3:54 AM: Hi,

[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=17750078#comment-17750078 ] RocMarshal commented on FLINK-31757: Hi, [~heigebupahei] Thanks for your attention. we've updated

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

[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=17735249#comment-17735249 ] RocMarshal commented on FLINK-20628: [~martijnvisser] Yes,I'd like to do it. There's nothing better.

[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=17734964#comment-17734964 ] RocMarshal commented on FLINK-20628: [~martijnvisser] Thank you for your reply. Yes, I'd like to

[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=17733990#comment-17733990 ] RocMarshal commented on FLINK-20628: Hi, [pscls|https://github.com/pscls] Thank you very much for

[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=17727041#comment-17727041 ] RocMarshal commented on FLINK-31757: I have compiled a draft  

[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=17727041#comment-17727041 ] RocMarshal edited comment on FLINK-31757 at 5/29/23 8:25 AM: - I have

[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=17715580#comment-17715580 ] RocMarshal commented on FLINK-31757: I am still working on this jira, and due to the Labor Day

[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=17711897#comment-17711897 ] RocMarshal commented on FLINK-31757: Thanks for your [~Weijie Guo] sorted concise and precise

[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=17711895#comment-17711895 ] RocMarshal commented on FLINK-31757: Thank you  [~fanrui] & [~huwh] very much. I'll prepare a design

[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=17711875#comment-17711875 ] RocMarshal commented on FLINK-31757: Based on this problem, we has achieved balanced task

[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=17711776#comment-17711776 ] RocMarshal edited comment on FLINK-31757 at 4/13/23 9:24 AM: - h1. Problem

[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=17711776#comment-17711776 ] RocMarshal commented on FLINK-31757: h1. Problem description and impact Supposed a Job has 21

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

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

[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=17710022#comment-17710022 ] RocMarshal commented on FLINK-31757: [~Weijie Guo] Glad to get your attention and reminding~:) I'll

[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

[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:

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

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

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

[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=17654895#comment-17654895 ] RocMarshal commented on FLINK-30511: Thank you [~Weijie Guo] [~kevin.cyj] . Looking forward to the

[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=17652232#comment-17652232 ] RocMarshal commented on FLINK-25421: Get it. Thanks a lot~ [~eskabetxe]  > Port JDBC Sink to new

[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

[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=17651050#comment-17651050 ] RocMarshal commented on FLINK-25421: Hi [~eskabetxe] Is here any new progress about sink ? > Port

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

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

[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

[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=17614358#comment-17614358 ] RocMarshal commented on FLINK-25540: Of course. anytime. [~mapohl]  Thank you~ > [JUnit5 Migration]

[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

[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

[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=17576785#comment-17576785 ] RocMarshal commented on FLINK-25421: Hi, [~eskabetxe] Would you like to make the draft changes

[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=17570471#comment-17570471 ] RocMarshal commented on FLINK-28659: HI, [~shengkai] , Could you help to assign this ticket to me ?

[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:

[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=17570418#comment-17570418 ] RocMarshal commented on FLINK-25545: Thx [~ruanhang1993] . The PR of the ticket was marked as ready

[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=17559129#comment-17559129 ] RocMarshal edited comment on FLINK-25420 at 6/27/22 11:35 AM: -- Hi,

[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=17559129#comment-17559129 ] RocMarshal commented on FLINK-25420: Hi, [~jingge] [~martijnvisser] . Would you mind pointing the ML

[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=17550967#comment-17550967 ] RocMarshal commented on FLINK-25420: OKay. I'll give the Source part draft in the new FLIP this

[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=17550796#comment-17550796 ] RocMarshal commented on FLINK-25420: [~martijnvisser] Sorry for the late response. I have made the

[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=17544366#comment-17544366 ] RocMarshal commented on FLINK-27794: Thanks [~dusukang] for the reporting it and [~martijnvisser]

[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=17530288#comment-17530288 ] RocMarshal edited comment on FLINK-25545 at 4/30/22 1:03 AM: - I Updated the

[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=17530289#comment-17530289 ] RocMarshal commented on FLINK-25543: [~xtsong] Yes. Just ping me if there's anything to do from my

[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=17530288#comment-17530288 ] RocMarshal commented on FLINK-25545: Updated the state of the PR. > [JUnit5 Migration] Module:

[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=17530285#comment-17530285 ] RocMarshal commented on FLINK-26496: [~xtsong] Yes. Just ping me if there's anything to do from my

[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=17516222#comment-17516222 ] RocMarshal commented on FLINK-25738: Hi [~martijnvisser] , I notice that the related PRs were

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

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

[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=17510194#comment-17510194 ] RocMarshal commented on FLINK-22315: [~lsy] Thanks for the comments,  cc [~jark] Please let us know

[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:

[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:

[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=17503638#comment-17503638 ] RocMarshal commented on FLINK-25213: Hi, [~monster#12]   Is there any progress to report from your

[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:

[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=17502720#comment-17502720 ] RocMarshal commented on FLINK-24349:  [~martijnvisser] [~Bo Cui]  Is there any progress ? May I help

[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=17501708#comment-17501708 ] RocMarshal commented on FLINK-26496: Could someone please assign this ticket to me ? Thx:) >

[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:

[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

[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=17498890#comment-17498890 ] RocMarshal commented on FLINK-25544: [~arvid]  I'm very interested in this jira. Could you please

[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=17498889#comment-17498889 ] RocMarshal commented on FLINK-25540: Hi, [~chesnay]  I'm very interested in this jira. Could you

[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=17496776#comment-17496776 ] RocMarshal commented on FLINK-25738: [~baisike] I'll check it asap. Thanks for the translation. >

[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=17496764#comment-17496764 ] RocMarshal commented on FLINK-25545: [~chesnay]  [~ruanhang1993]  May I get the ticket ?:)  >

[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=17495476#comment-17495476 ] RocMarshal commented on FLINK-25420: I'll give the refactor draft ASAP. [~MartijnVisser] Thanks for

[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=17495475#comment-17495475 ] RocMarshal commented on FLINK-24112: [~mapohl]  [~arvid]    The embedded mariadb was removed in

[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=1744#comment-1744 ] RocMarshal commented on FLINK-25825: [~MartijnVisser] I have verified it locally on ubuntu 20 with

[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=17488737#comment-17488737 ] RocMarshal commented on FLINK-25825: [~gaoyunhaii] [~MartijnVisser] Could you help me to open the

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

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

[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=17488140#comment-17488140 ] RocMarshal commented on FLINK-25825: Thanks [~MartijnVisser] [~gaoyunhaii] . I verified carefully

[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=17487871#comment-17487871 ] RocMarshal edited comment on FLINK-25825 at 2/7/22, 5:08 AM: - Sorry for not

[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=17487871#comment-17487871 ] RocMarshal commented on FLINK-25825: Sorry for not checking the issue in time. [~MartijnVisser] I

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

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

[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

[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

[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

[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:

[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

[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

[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

[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=17481536#comment-17481536 ] RocMarshal edited comment on FLINK-25738 at 1/25/22, 4:48 AM: -- I checked

[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=17481536#comment-17481536 ] RocMarshal commented on FLINK-25738: I checked docs/content.zh/docs/deployment/filesystems/s3.md.

[jira] [Updated] (FLINK-25789) Translate the formats/hadoop page into Chinese.

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

[jira] [Created] (FLINK-25789) Translate the formats/hadoop page into Chinese.

RocMarshal created FLINK-25789: -- Summary: Translate the formats/hadoop page into Chinese. Key: FLINK-25789 URL: https://issues.apache.org/jira/browse/FLINK-25789 Project: Flink Issue Type:

[jira] [Created] (FLINK-25783) Translate azure_table_storage.md page into Chinese.

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

[jira] [Updated] (FLINK-25783) Translate azure_table_storage.md page into Chinese.

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

[jira] [Updated] (FLINK-25782) Translate datastream filesystem.md page into Chinese.

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

[jira] [Created] (FLINK-25782) Translate datastream filesystem.md page into Chinese.

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

[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=17480459#comment-17480459 ] RocMarshal commented on FLINK-25738: Hi, [~Zhiwu Wang] Thank you so much. If you don't mind, you

[jira] [Updated] (FLINK-25761) Translate Avro format page into Chinese.

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

<    1   2   3   >