[jira] [Commented] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode

[ https://issues.apache.org/jira/browse/FLINK-35659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856672#comment-17856672 ] dalongliu commented on FLINK-35659: --- Merged in master: b92a5944c42a66f88ae63127ae1ff14

[jira] [Resolved] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode

[ https://issues.apache.org/jira/browse/FLINK-35659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-35659. --- Resolution: Fixed > Fix TestFileSystem Connector error setting execution mode > ---

[jira] [Assigned] (FLINK-35587) Job fails with "The read buffer is null in credit-based input channel" on TPC-DS 10TB benchmark

[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35587: -- Assignee: Yuxin Tan (was: Weijie Guo) > Job fails with "The read buffer is null in credit-ba

[jira] [Comment Edited] (FLINK-35587) Job fails with "The read buffer is null in credit-based input channel" on TPC-DS 10TB benchmark

[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856671#comment-17856671 ] Weijie Guo edited comment on FLINK-35587 at 6/21/24 6:25 AM: -

[jira] [Commented] (FLINK-35587) Job fails with "The read buffer is null in credit-based input channel" on TPC-DS 10TB benchmark

[ https://issues.apache.org/jira/browse/FLINK-35587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856671#comment-17856671 ] Weijie Guo commented on FLINK-35587: Thanks [~JunRuiLi] for reporting this! I think

[jira] [Commented] (FLINK-35664) Flink CDC pipeline transform supports mask function

[ https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856667#comment-17856667 ] melin commented on FLINK-35664: --- yes, see hive mask function: [https://cwiki.apache.org/c

[jira] [Commented] (FLINK-35664) Flink CDC pipeline transform supports mask function

[ https://issues.apache.org/jira/browse/FLINK-35664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856665#comment-17856665 ] yux commented on FLINK-35664: - Hi [~melin], just to confirm, are you suggesting adding built

[jira] [Created] (FLINK-35664) Flink CDC pipeline transform supports mask function

melin created FLINK-35664: - Summary: Flink CDC pipeline transform supports mask function Key: FLINK-35664 URL: https://issues.apache.org/jira/browse/FLINK-35664 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

[ https://issues.apache.org/jira/browse/FLINK-35658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-35658. -- Resolution: Fixed master(1.20) via 1f96cf8645a8fc60bff9ddc858965eb176ca7481. > Hybrid shuffle externa

[jira] [Updated] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

[ https://issues.apache.org/jira/browse/FLINK-35658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35658: --- Fix Version/s: 1.20.0 > Hybrid shuffle external tier can not work with UnknownInputChannel > ---

[jira] [Commented] (FLINK-35636) Streaming File Sink s3 end-to-end test did not finish after 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-35636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856645#comment-17856645 ] Weijie Guo commented on FLINK-35636: https://dev.azure.com/apache-flink/apache-flink

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Description: This describes how to verify FLINK-34914 FLIP-436: Introduce Catalog-related Syntax. The

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Attachment: image-2024-06-21-09-45-43-807.png > Release Testing: FLIP-436: Introduce Catalog-related Syn

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Attachment: image-2024-06-21-09-44-26-213.png > Release Testing: FLIP-436: Introduce Catalog-related Syn

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Description: This describes how to verify FLINK-34914 FLIP-436: Introduce Catalog-related Syntax. The

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Attachment: image-2024-06-21-09-43-58-460.png > Release Testing: FLIP-436: Introduce Catalog-related Syn

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Attachment: image-2024-06-21-09-43-47-391.png > Release Testing: FLIP-436: Introduce Catalog-related Syn

[jira] [Updated] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-35663: - Description: This describes how to verify FLINK-34914 FLIP-436: Introduce Catalog-related Syntax. The

[jira] [Created] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

Yubin Li created FLINK-35663: Summary: Release Testing: FLIP-436: Introduce Catalog-related Syntax Key: FLINK-35663 URL: https://issues.apache.org/jira/browse/FLINK-35663 Project: Flink Issue Ty

[jira] [Updated] (FLINK-35588) flink sql redis connector

[ https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] cris niu updated FLINK-35588: - Attachment: 1.png > flink sql redis connector > - > > Key: FLINK

[jira] [Updated] (FLINK-35588) flink sql redis connector

[ https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] cris niu updated FLINK-35588: - Attachment: (was: Snipaste_2024-06-20_16-03-54.png) > flink sql redis connector > --

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856606#comment-17856606 ] Alexis Sarda-Espinosa edited comment on FLINK-25920 at 6/20/24 9:02 PM: --

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856606#comment-17856606 ] Alexis Sarda-Espinosa commented on FLINK-25920: --- Sure thing, I still have

[jira] [Closed] (FLINK-33451) Implement FileSytem based AutoScalerStateStore (e.g : HbaseAutoScalerStateStore)

[ https://issues.apache.org/jira/browse/FLINK-33451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb closed FLINK-33451. -- Resolution: Won't Do > Implement FileSytem based AutoScalerStateStore (e.g : > HbaseAutoScalerStateSt

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti edited comment on FLINK-31762 at 6/20/24 2:48 PM:

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti edited comment on FLINK-31762 at 6/20/24 2:48 PM:

[jira] [Comment Edited] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti edited comment on FLINK-31762 at 6/20/24 2:44 PM:

[jira] [Commented] (FLINK-31762) Subscribe to multiple Kafka topics may cause partition assignment skew

[ https://issues.apache.org/jira/browse/FLINK-31762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856514#comment-17856514 ] Lorenzo Affetti commented on FLINK-31762: - Thank you [~jingge] !   This would

[jira] [Resolved] (FLINK-32229) Implement metrics and logging for Initial implementation

[ https://issues.apache.org/jira/browse/FLINK-32229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32229. - Fix Version/s: aws-connector-4.4.0 Resolution: Fixed > Implement metrics and logg

[jira] [Commented] (FLINK-32229) Implement metrics and logging for Initial implementation

[ https://issues.apache.org/jira/browse/FLINK-32229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856502#comment-17856502 ] Hong Liang Teoh commented on FLINK-32229: -  merged commit [{{9e418f7}}|https://

[jira] [Updated] (FLINK-35640) Deprecate Flink 1.15 in the operator

[ https://issues.apache.org/jira/browse/FLINK-35640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mate Czagany updated FLINK-35640: - Description: As the operator only supports the latest 4 stable minor Flink versions, 1.15 should

[jira] [Updated] (FLINK-35640) Deprecate Flink 1.15 in the operator

[ https://issues.apache.org/jira/browse/FLINK-35640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mate Czagany updated FLINK-35640: - Summary: Deprecate Flink 1.15 in the operator (was: Drop Flink 1.15 support for the operator)

[jira] [Created] (FLINK-35662) Use maven batch mode in k8s-operator CI

Ferenc Csaky created FLINK-35662: Summary: Use maven batch mode in k8s-operator CI Key: FLINK-35662 URL: https://issues.apache.org/jira/browse/FLINK-35662 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856485#comment-17856485 ] Fabian Paul commented on FLINK-25920: - [~asardaes] can you provide us with some more

[jira] [Assigned] (FLINK-25920) Allow receiving updates of CommittableSummary

[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-25920: --- Assignee: Fabian Paul > Allow receiving updates of CommittableSummary > ---

[jira] [Assigned] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode

[ https://issues.apache.org/jira/browse/FLINK-35659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35659: - Assignee: dalongliu > Fix TestFileSystem Connector error setting execution mode >

[jira] [Assigned] (FLINK-35646) Add gateway refresh rest api doc

[ https://issues.apache.org/jira/browse/FLINK-35646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35646: - Assignee: dalongliu > Add gateway refresh rest api doc > > >

[jira] [Commented] (FLINK-35654) Add Flink CDC verification guide in docs

[ https://issues.apache.org/jira/browse/FLINK-35654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856450#comment-17856450 ] Muhammet Orazov commented on FLINK-35654: - Thanks [~xiqian_yu] ! This is indeed

[jira] [Created] (FLINK-35661) MiniBatchGroupAggFunction can silently drop records under certain conditions

Ivan Burmistrov created FLINK-35661: --- Summary: MiniBatchGroupAggFunction can silently drop records under certain conditions Key: FLINK-35661 URL: https://issues.apache.org/jira/browse/FLINK-35661 Pr

[jira] [Commented] (FLINK-35657) Flink UI not support show float metric value

[ https://issues.apache.org/jira/browse/FLINK-35657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856439#comment-17856439 ] Luke Chen commented on FLINK-35657: --- PR to fix this issue: https://github.com/apache/f

[jira] [Created] (FLINK-35660) Implement parent-child ordering for DDB Streams source

Aleksandr Pilipenko created FLINK-35660: --- Summary: Implement parent-child ordering for DDB Streams source Key: FLINK-35660 URL: https://issues.apache.org/jira/browse/FLINK-35660 Project: Flink

[jira] [Commented] (FLINK-33142) Prometheus Sink Connector - Update Documentation

[ https://issues.apache.org/jira/browse/FLINK-33142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856428#comment-17856428 ] Hong Liang Teoh commented on FLINK-33142: - Done - thanks [~nicusX]    > Promet

[jira] [Assigned] (FLINK-33142) Prometheus Sink Connector - Update Documentation

[ https://issues.apache.org/jira/browse/FLINK-33142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33142: --- Assignee: Lorenzo Nicora > Prometheus Sink Connector - Update Documentation > -

[jira] [Updated] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

[ https://issues.apache.org/jira/browse/FLINK-35658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuxin Tan updated FLINK-35658: -- Labels: pull-request-available (was: ) > Hybrid shuffle external tier can not work with UnknownInputC

[jira] [Created] (FLINK-35659) Fix TestFileSystem Connector error setting execution mode

dalongliu created FLINK-35659: - Summary: Fix TestFileSystem Connector error setting execution mode Key: FLINK-35659 URL: https://issues.apache.org/jira/browse/FLINK-35659 Project: Flink Issue Ty

[jira] [Created] (FLINK-35658) Hybrid shuffle external tier can not work with UnknownInputChannel

Yuxin Tan created FLINK-35658: - Summary: Hybrid shuffle external tier can not work with UnknownInputChannel Key: FLINK-35658 URL: https://issues.apache.org/jira/browse/FLINK-35658 Project: Flink

[jira] [Updated] (FLINK-35588) flink sql redis connector

[ https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] cris niu updated FLINK-35588: - Labels: newbie (was: pull-request-available) > flink sql redis connector > - >

[jira] [Commented] (FLINK-35588) flink sql redis connector

[ https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856420#comment-17856420 ] cris niu commented on FLINK-35588: -- I have upload the related code to github, please tr

[jira] [Updated] (FLINK-35588) flink sql redis connector

[ https://issues.apache.org/jira/browse/FLINK-35588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] cris niu updated FLINK-35588: - Attachment: Snipaste_2024-06-20_16-03-54.png > flink sql redis connector > - > >

[jira] [Updated] (FLINK-35657) Flink UI not support show float metric value

[ https://issues.apache.org/jira/browse/FLINK-35657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Can Luo updated FLINK-35657: Description: Flink ui show float metric value as int/long. For example, `outPoolUsage`/`inPoolUsage` are

[jira] [Updated] (FLINK-35657) Flink UI not support show float metric value

[ https://issues.apache.org/jira/browse/FLINK-35657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Can Luo updated FLINK-35657: Description: Flink ui show float metric value as int/long. For example, `outPoolUsage`/`inPoolUsage` are

[jira] [Updated] (FLINK-35657) Flink UI not support show float metric value

[ https://issues.apache.org/jira/browse/FLINK-35657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Can Luo updated FLINK-35657: Attachment: image-2024-06-20-15-42-41-004.png > Flink UI not support show float metric value > ---

[jira] [Created] (FLINK-35657) Flink UI not support show float metric value

Can Luo created FLINK-35657: --- Summary: Flink UI not support show float metric value Key: FLINK-35657 URL: https://issues.apache.org/jira/browse/FLINK-35657 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-35656) Hive Source has issues setting max parallelism in dynamic inference mode

[ https://issues.apache.org/jira/browse/FLINK-35656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-35656: --- Assignee: xingbe > Hive Source has issues setting max parallelism in dynamic inference mode > -

[jira] [Created] (FLINK-35656) Hive Source has issues setting max parallelism in dynamic inference mode

xingbe created FLINK-35656: -- Summary: Hive Source has issues setting max parallelism in dynamic inference mode Key: FLINK-35656 URL: https://issues.apache.org/jira/browse/FLINK-35656 Project: Flink