[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Release Note: Support Full Partition Processing On Non-keyed DataStream New Features: fullWindowPa

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Release Note: New Features: fullWindowPartition Method: Introduced in the DataStream class to enab

[jira] [Created] (FLINK-35795) FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

Wencong Liu created FLINK-35795: --- Summary: FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2 Key: FLINK-35795 URL: https://issues.apache.org/jira/browse/FLINK-35795 Project: Flink

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818186#comment-17818186 ] Wencong Liu commented on FLINK-34448: - Maybe [~Yanfei Lei] could take a look 😄. > C

[jira] [Created] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

Wencong Liu created FLINK-34543: --- Summary: Support Full Partition Processing On Non-keyed DataStream Key: FLINK-34543 URL: https://issues.apache.org/jira/browse/FLINK-34543 Project: Flink Issue

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Description: 1. Introduce MapParititon, SortPartition, Aggregate, Reduce API in DataStream. 2. Int

[jira] [Updated] (FLINK-34543) Support Full Partition Processing On Non-keyed DataStream

[ https://issues.apache.org/jira/browse/FLINK-34543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-34543: Description: Introduce the PartitionWindowedStream and provide multiple full window operations in

[jira] [Updated] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

[ https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33356: Attachment: image-2023-10-25-12-34-22-790.png > The navigation bar on Flink’s official website is

[jira] [Commented] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

[ https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779330#comment-17779330 ] Wencong Liu commented on FLINK-33356: - Hello [~JunRuiLi] , I found this case is due

[jira] [Comment Edited] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

[ https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779330#comment-17779330 ] Wencong Liu edited comment on FLINK-33356 at 10/25/23 5:58 AM: ---

[jira] [Commented] (FLINK-33356) The navigation bar on Flink’s official website is messed up.

[ https://issues.apache.org/jira/browse/FLINK-33356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781629#comment-17781629 ] Wencong Liu commented on FLINK-33356: - This is because of a recent failure in the do

[jira] [Created] (FLINK-33445) Translate DataSet migration guideline to Chinese

Wencong Liu created FLINK-33445: --- Summary: Translate DataSet migration guideline to Chinese Key: FLINK-33445 URL: https://issues.apache.org/jira/browse/FLINK-33445 Project: Flink Issue Type: Im

[jira] [Updated] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33445: Description: The FLIINK-33041 about adding an introduction about how to migrate DataSet API to Da

[jira] [Updated] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33445: Labels: starter (was: ) > Translate DataSet migration guideline to Chinese >

[jira] [Updated] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33445: Component/s: chinese-translation (was: Documentation) > Translate DataSet mig

[jira] [Updated] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33445: Description: The [FLIINK-33041|https://issues.apache.org/jira/browse/FLINK-33041] about adding an

[jira] [Commented] (FLINK-33445) Translate DataSet migration guideline to Chinese

[ https://issues.apache.org/jira/browse/FLINK-33445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17782384#comment-17782384 ] Wencong Liu commented on FLINK-33445: - Thanks [~liyubin117] ! Assigned to you. Pleas

[jira] [Commented] (FLINK-33323) HybridShuffleITCase fails with produced an uncaught exception in FatalExitExceptionHandler

[ https://issues.apache.org/jira/browse/FLINK-33323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17784350#comment-17784350 ] Wencong Liu commented on FLINK-33323: - Thanks for your reminder! [~mapohl] . Could y

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787224#comment-17787224 ] Wencong Liu commented on FLINK-33502: - Thank you for your reminder [~mapohl] . I wou

[jira] [Updated] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33502: Attachment: image-2023-11-20-14-37-37-321.png > HybridShuffleITCase caused a fatal error > ---

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787828#comment-17787828 ] Wencong Liu commented on FLINK-33502: - Thank you for your detailed reply. I am curre

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788998#comment-17788998 ] Wencong Liu commented on FLINK-33502: - Thank [~mapohl]  for your help. The fix shoul

[jira] [Comment Edited] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17788998#comment-17788998 ] Wencong Liu edited comment on FLINK-33502 at 11/23/23 6:49 AM: ---

[jira] [Updated] (FLINK-33626) Wrong style in flink ui

[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33626: Attachment: image-2023-11-23-16-23-57-678.png > Wrong style in flink ui > ---

[jira] [Commented] (FLINK-33626) Wrong style in flink ui

[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789020#comment-17789020 ] Wencong Liu commented on FLINK-33626: - This is a similar issue with [FLINK-33356] Th

[jira] [Comment Edited] (FLINK-33626) Wrong style in flink ui

[ https://issues.apache.org/jira/browse/FLINK-33626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17789020#comment-17789020 ] Wencong Liu edited comment on FLINK-33626 at 11/23/23 8:27 AM: ---

[jira] [Commented] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805352#comment-17805352 ] Wencong Liu commented on FLINK-33009: - I've opened a pull request and CI has passed.

[jira] [Commented] (FLINK-34237) MongoDB connector compile failed with Flink 1.19-SNAPSHOT

[ https://issues.apache.org/jira/browse/FLINK-34237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811101#comment-17811101 ] Wencong Liu commented on FLINK-34237: - Thanks for the reminder. I'll fix it as soon

[jira] [Commented] (FLINK-34246) Allow only archive failed job to history server

[ https://issues.apache.org/jira/browse/FLINK-34246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811468#comment-17811468 ] Wencong Liu commented on FLINK-34246: - Thanks [~qingwei91], for suggesting this. Are

[jira] [Reopened] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu reopened FLINK-32978: - > Deprecate RichFunction#open(Configuration parameters) > --

[jira] [Closed] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu closed FLINK-32978. --- Release Note: The RichFunction#open(Configuration parameters) method has been deprecated and will b

[jira] [Commented] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17812213#comment-17812213 ] Wencong Liu commented on FLINK-32978: - [~martijnvisser] Thanks for the reminding. I'

[jira] [Commented] (FLINK-34132) Batch WordCount job fails when run with AdaptiveBatch scheduler

[ https://issues.apache.org/jira/browse/FLINK-34132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813316#comment-17813316 ] Wencong Liu commented on FLINK-34132: - Thanks for the reminding. [~zhuzh] I will add

[jira] [Commented] (FLINK-33652) First Steps documentation is having empty page link

[ https://issues.apache.org/jira/browse/FLINK-33652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790075#comment-17790075 ] Wencong Liu commented on FLINK-33652: - Hello [~pranav.sharma], thanks for the carefu

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17792610#comment-17792610 ] Wencong Liu commented on FLINK-33502: - Thanks [~JunRuiLi] . I have investigated it a

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798413#comment-17798413 ] Wencong Liu commented on FLINK-33502: - Sorry for the late reply. I've just identifie

[jira] [Created] (FLINK-33905) FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

Wencong Liu created FLINK-33905: --- Summary: FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs Key: FLINK-33905 URL: https://issues.apache.org/jira/browse/FLINK-33905 Project: Flink

[jira] [Commented] (FLINK-33939) Make husky in runtime-web no longer affect git global hooks

[ https://issues.apache.org/jira/browse/FLINK-33939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800411#comment-17800411 ] Wencong Liu commented on FLINK-33939: - Thanks for raising this issue! 😄 I completely

[jira] [Created] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

Wencong Liu created FLINK-33949: --- Summary: METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible Key: FLINK-33949 URL: https://issues.apache.org/jira/browse/FLINK-33949 Proj

[jira] [Updated] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33949: Description: Currently  I'm trying to refactor some APIs annotated by @Public in [FLIP-382: Unify

[jira] [Updated] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33949: Description: Currently  I'm trying to refactor some APIs annotated by @Public in [FLIP-382: Unify

[jira] [Commented] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800696#comment-17800696 ] Wencong Liu commented on FLINK-33009: - Hi [~mapohl] , I've encountered the same issu

[jira] [Comment Edited] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800696#comment-17800696 ] Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:42 AM: ---

[jira] [Comment Edited] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800696#comment-17800696 ] Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:43 AM: ---

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800787#comment-17800787 ] Wencong Liu commented on FLINK-33949: - Thanks [~martijnvisser] for your comments. Th

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800802#comment-17800802 ] Wencong Liu commented on FLINK-33949: - For the users have built implementations them

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800913#comment-17800913 ] Wencong Liu commented on FLINK-33949: - Suppose we have two completely independent in

[jira] [Comment Edited] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17800913#comment-17800913 ] Wencong Liu edited comment on FLINK-33949 at 12/28/23 3:45 AM: ---

[jira] [Commented] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17801988#comment-17801988 ] Wencong Liu commented on FLINK-33949: - Thanks for the explanation from [~chesnay] .

[jira] [Closed] (FLINK-33949) METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary compatible

[ https://issues.apache.org/jira/browse/FLINK-33949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu closed FLINK-33949. --- Resolution: Not A Problem > METHOD_ABSTRACT_NOW_DEFAULT should be both source compatible and binary

[jira] [Commented] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804660#comment-17804660 ] Wencong Liu commented on FLINK-32978: - Thanks for proposing this issue 😄. I will inv

[jira] [Comment Edited] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17804660#comment-17804660 ] Wencong Liu edited comment on FLINK-32978 at 1/9/24 9:45 AM: -

[jira] [Commented] (FLINK-34718) KeyedPartitionWindowedStream and NonPartitionWindowedStream IllegalStateException in AZP

[ https://issues.apache.org/jira/browse/FLINK-34718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828011#comment-17828011 ] Wencong Liu commented on FLINK-34718: - Sure, I'll take a look now. [~mapohl]  > Key

[jira] [Commented] (FLINK-34718) KeyedPartitionWindowedStream and NonPartitionWindowedStream IllegalStateException in AZP

[ https://issues.apache.org/jira/browse/FLINK-34718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828019#comment-17828019 ] Wencong Liu commented on FLINK-34718: - The newly introduced DataStream operators are

[jira] [Updated] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser

[ https://issues.apache.org/jira/browse/FLINK-35221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-35221: Description: According to Hive user documentation[1], starting from version 0.13.0, Hive prohibit

[jira] [Created] (FLINK-35221) Support SQL 2011 reserved keywords as identifiers in Flink HiveParser

Wencong Liu created FLINK-35221: --- Summary: Support SQL 2011 reserved keywords as identifiers in Flink HiveParser Key: FLINK-35221 URL: https://issues.apache.org/jira/browse/FLINK-35221 Project: Flink

[jira] [Commented] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760830#comment-17760830 ] Wencong Liu commented on FLINK-33009: - Thanks [~mapohl] for the summary.  BTW, I fo

[jira] [Comment Edited] (FLINK-33009) tools/release/update_japicmp_configuration.sh should only enable binary compatibility checks in the release branch

[ https://issues.apache.org/jira/browse/FLINK-33009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760830#comment-17760830 ] Wencong Liu edited comment on FLINK-33009 at 8/31/23 9:49 AM:

[jira] [Created] (FLINK-33041) Add an introduction about how to migrate DataSet API to DataStream

Wencong Liu created FLINK-33041: --- Summary: Add an introduction about how to migrate DataSet API to DataStream Key: FLINK-33041 URL: https://issues.apache.org/jira/browse/FLINK-33041 Project: Flink

[jira] [Commented] (FLINK-33041) Add an introduction about how to migrate DataSet API to DataStream

[ https://issues.apache.org/jira/browse/FLINK-33041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762540#comment-17762540 ] Wencong Liu commented on FLINK-33041: - Thanks very much for your reminder [~echaucho

[jira] [Created] (FLINK-33144) Deprecate Iteration API in DataStream

Wencong Liu created FLINK-33144: --- Summary: Deprecate Iteration API in DataStream Key: FLINK-33144 URL: https://issues.apache.org/jira/browse/FLINK-33144 Project: Flink Issue Type: Technical Deb

[jira] [Updated] (FLINK-33144) Deprecate Iteration API in DataStream

[ https://issues.apache.org/jira/browse/FLINK-33144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33144: Description: FLIP-357 has decided to deprecate the Iteration API of DataStream and remove it compl

[jira] [Updated] (FLINK-33144) Deprecate Iteration API in DataStream

[ https://issues.apache.org/jira/browse/FLINK-33144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33144: Description: FLIP-357 has decided to deprecate the Iteration API of DataStream and remove it compl

[jira] [Updated] (FLINK-33144) Deprecate Iteration API in DataStream

[ https://issues.apache.org/jira/browse/FLINK-33144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-33144: Description: [FLIP-357: Deprecate Iteration API of DataStream - Apache Flink - Apache Software Fo

[jira] [Commented] (FLINK-30257) SqlClientITCase#testMatchRecognize failed

[ https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689133#comment-17689133 ] Wencong Liu commented on FLINK-30257: - cc [~martijnvisser]  > SqlClientITCase#testM

[jira] [Commented] (FLINK-31020) Read-only mode for Rest API

[ https://issues.apache.org/jira/browse/FLINK-31020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689172#comment-17689172 ] Wencong Liu commented on FLINK-31020: - Thanks [~omkardeshpande8] for the proposal! I

[jira] [Commented] (FLINK-31020) Read-only mode for Rest API

[ https://issues.apache.org/jira/browse/FLINK-31020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689173#comment-17689173 ] Wencong Liu commented on FLINK-31020: - cc [~xtsong]  > Read-only mode for Rest API

[jira] [Commented] (FLINK-31092) Hive ITCases fail with OutOfMemoryError

[ https://issues.apache.org/jira/browse/FLINK-31092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689193#comment-17689193 ] Wencong Liu commented on FLINK-31092: - Hi [~mapohl], is the heap dump generated befo

[jira] [Commented] (FLINK-31020) Read-only mode for Rest API

[ https://issues.apache.org/jira/browse/FLINK-31020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689458#comment-17689458 ] Wencong Liu commented on FLINK-31020: - Sorry [~chesnay] , my statement may not be ve

[jira] (FLINK-31020) Read-only mode for Rest API

[ https://issues.apache.org/jira/browse/FLINK-31020 ] Wencong Liu deleted comment on FLINK-31020: - was (Author: JIRAUSER281639): cc [~xtsong]  > Read-only mode for Rest API > --- > > Key: FLINK-31020 >

[jira] [Commented] (FLINK-31176) correct the description of sql gateway configuration

[ https://issues.apache.org/jira/browse/FLINK-31176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17691919#comment-17691919 ] Wencong Liu commented on FLINK-31176: - Thanks [~wangkang] ! I'll take a look. > cor

[jira] [Commented] (FLINK-31208) KafkaSourceReader overrides meaninglessly a method(pauseOrResumeSplits)

[ https://issues.apache.org/jira/browse/FLINK-31208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694026#comment-17694026 ] Wencong Liu commented on FLINK-31208: - It looks like some redundant code. cc [~renqs

[jira] [Commented] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level

[ https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694039#comment-17694039 ] Wencong Liu commented on FLINK-30829: - I think if the busy/idle/backpressure is disp

[jira] [Commented] (FLINK-31246) Remove PodTemplate description from the SpecChange message

[ https://issues.apache.org/jira/browse/FLINK-31246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17694419#comment-17694419 ] Wencong Liu commented on FLINK-31246: - Hello [~pvary], I'm quite interested in this

[jira] [Commented] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level

[ https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695072#comment-17695072 ] Wencong Liu commented on FLINK-30829: - For jobs with high parallelism, it will be ve

[jira] [Commented] (FLINK-30829) Make the backpressure tab could be sort by the backpressure level

[ https://issues.apache.org/jira/browse/FLINK-30829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695548#comment-17695548 ] Wencong Liu commented on FLINK-30829: - I think it's necessary to sort the three colu

[jira] [Commented] (FLINK-31298) ConnectionUtilsTest.testFindConnectingAddressWhenGetLocalHostThrows swallows IllegalArgumentException

[ https://issues.apache.org/jira/browse/FLINK-31298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17695974#comment-17695974 ] Wencong Liu commented on FLINK-31298: - Hello [~mapohl] , I'd like to take this ticke

[jira] [Commented] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent

[ https://issues.apache.org/jira/browse/FLINK-27051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696419#comment-17696419 ] Wencong Liu commented on FLINK-27051: - Hello [~mapohl] , I'm quite interested in the

[jira] [Commented] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent

[ https://issues.apache.org/jira/browse/FLINK-27051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696970#comment-17696970 ] Wencong Liu commented on FLINK-27051: - Thanks for the explanation [~mapohl] . I thin

[jira] [Commented] (FLINK-32502) Remove AbstractLeaderElectionService

[ https://issues.apache.org/jira/browse/FLINK-32502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17740367#comment-17740367 ] Wencong Liu commented on FLINK-32502: - Hello [~mapohl]  Are you suggesting merging t

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17741813#comment-17741813 ] Wencong Liu commented on FLINK-32523: - I think we should remove @Test(timeout = TEST

[jira] [Commented] (FLINK-32624) TieredStorageConsumerClientTest.testGetNextBufferFromRemoteTier failed on CI

[ https://issues.apache.org/jira/browse/FLINK-32624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744403#comment-17744403 ] Wencong Liu commented on FLINK-32624: - Sorry for the late reply, I'll take a look. [

[jira] [Commented] (FLINK-32624) TieredStorageConsumerClientTest.testGetNextBufferFromRemoteTier failed on CI

[ https://issues.apache.org/jira/browse/FLINK-32624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744409#comment-17744409 ] Wencong Liu commented on FLINK-32624: - Thanks [~lincoln.86xy] .  I've opened a hot f

[jira] [Commented] (FLINK-5336) Make Path immutable

[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744452#comment-17744452 ] Wencong Liu commented on FLINK-5336: Hi all, I have checked all the classes that util

[jira] [Comment Edited] (FLINK-5336) Make Path immutable

[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744452#comment-17744452 ] Wencong Liu edited comment on FLINK-5336 at 7/20/23 2:32 AM: -

[jira] [Comment Edited] (FLINK-5336) Make Path immutable

[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744452#comment-17744452 ] Wencong Liu edited comment on FLINK-5336 at 7/20/23 4:13 AM: -

[jira] [Commented] (FLINK-5336) Make Path immutable

[ https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744938#comment-17744938 ] Wencong Liu commented on FLINK-5336: Thanks [~qingyue] , I think the *FileSourceSplit

[jira] [Commented] (FLINK-32686) Performance regression on startScheduling.BATCH and startScheduling.STREAMING since 2023-07-24

[ https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747733#comment-17747733 ] Wencong Liu commented on FLINK-32686: - Thanks for reporting this. The second regress

[jira] [Comment Edited] (FLINK-32686) Performance regression on startScheduling.BATCH and startScheduling.STREAMING since 2023-07-24

[ https://issues.apache.org/jira/browse/FLINK-32686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17747733#comment-17747733 ] Wencong Liu edited comment on FLINK-32686 at 7/27/23 3:42 AM:

[jira] [Created] (FLINK-32708) Fix the write logic in remote tier of hybrid shuffle

Wencong Liu created FLINK-32708: --- Summary: Fix the write logic in remote tier of hybrid shuffle Key: FLINK-32708 URL: https://issues.apache.org/jira/browse/FLINK-32708 Project: Flink Issue Type

[jira] [Updated] (FLINK-32708) Fix the write logic in remote tier of Hybrid Shuffle

[ https://issues.apache.org/jira/browse/FLINK-32708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-32708: Summary: Fix the write logic in remote tier of Hybrid Shuffle (was: Fix the write logic in remote

[jira] [Commented] (FLINK-30257) SqlClientITCase#testMatchRecognize failed

[ https://issues.apache.org/jira/browse/FLINK-30257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17677587#comment-17677587 ] Wencong Liu commented on FLINK-30257: - Thanks [~martijnvisser], I've opened a pull r

[jira] [Commented] (FLINK-29125) Placeholder in Apache Flink Web Frontend to display some "tags" to distinguish between frontends of different clusters

[ https://issues.apache.org/jira/browse/FLINK-29125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678074#comment-17678074 ] Wencong Liu commented on FLINK-29125: - Thanks for the reply [~dkrovi] [~martijnvisse

[jira] [Commented] (FLINK-30699) Improve the efficiency of the getRandomString method in the StringUtils class

[ https://issues.apache.org/jira/browse/FLINK-30699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678078#comment-17678078 ] Wencong Liu commented on FLINK-30699: - Thanks for your proposal! [~TaoZex] . I'm a l

[jira] [Comment Edited] (FLINK-30699) Improve the efficiency of the getRandomString method in the StringUtils class

[ https://issues.apache.org/jira/browse/FLINK-30699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17678078#comment-17678078 ] Wencong Liu edited comment on FLINK-30699 at 1/18/23 6:14 AM:

[jira] [Commented] (FLINK-30774) flink-utils module

[ https://issues.apache.org/jira/browse/FLINK-30774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680085#comment-17680085 ] Wencong Liu commented on FLINK-30774: - Hello [~mapohl]. I think your proposal is rea

[jira] [Commented] (FLINK-30739) SqlGatewayRestEndpointStatementITCase failed with NullPointer

[ https://issues.apache.org/jira/browse/FLINK-30739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17680088#comment-17680088 ] Wencong Liu commented on FLINK-30739: - I seems like a existed similar issue. cc [~fs

[jira] [Commented] (FLINK-32065) Got NoSuchFileException when initialize source function.

[ https://issues.apache.org/jira/browse/FLINK-32065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17722638#comment-17722638 ] Wencong Liu commented on FLINK-32065: - Hello [~SpongebobZ] , do you clean the tmp di

[jira] (FLINK-32065) Got NoSuchFileException when initialize source function.

[ https://issues.apache.org/jira/browse/FLINK-32065 ] Wencong Liu deleted comment on FLINK-32065: - was (Author: JIRAUSER281639): Hello [~SpongebobZ] , do you clean the tmp dir before the error happens ? It seems that the file was deleted when i

[jira] [Commented] (FLINK-32112) Fixed State Backend sample config in zh-doc

[ https://issues.apache.org/jira/browse/FLINK-32112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17723330#comment-17723330 ] Wencong Liu commented on FLINK-32112: - Helllo [~xmzhou] , Thanks for your proposal.

  1   2   3   >