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

[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=17828019#comment-17828019 ] Wencong Liu commented on FLINK-34718: - The newly introduced DataStream operators are designed based

[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=17828011#comment-17828011 ] Wencong Liu commented on FLINK-34718: - Sure, I'll take a look now. [~mapohl]  >

[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

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

[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

[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=17818186#comment-17818186 ] Wencong Liu commented on FLINK-34448: - Maybe [~Yanfei Lei] could take a look . >

[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=17813316#comment-17813316 ] Wencong Liu commented on FLINK-34132: - Thanks for the reminding. [~zhuzh] I will address these

[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=17812213#comment-17812213 ] Wencong Liu commented on FLINK-32978: - [~martijnvisser] Thanks for the reminding. I've added the

[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

[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] [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=17811468#comment-17811468 ] Wencong Liu commented on FLINK-34246: - Thanks [~qingwei91], for suggesting this. Are you suggesting

[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=17811101#comment-17811101 ] Wencong Liu commented on FLINK-34237: - Thanks for the reminder. I'll fix it as soon as possible. >

[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=17805352#comment-17805352 ] Wencong Liu commented on FLINK-33009: - I've opened a pull request and CI has passed.  >

[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=17804660#comment-17804660 ] Wencong Liu edited comment on FLINK-32978 at 1/9/24 9:45 AM: - Thanks for

[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=17804660#comment-17804660 ] Wencong Liu commented on FLINK-32978: - Thanks for proposing this issue . I will investigate all

[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-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=17801988#comment-17801988 ] Wencong Liu commented on FLINK-33949: - Thanks for the explanation from [~chesnay] . Given that all

[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=17800913#comment-17800913 ] Wencong Liu edited comment on FLINK-33949 at 12/28/23 3:45 AM: --- Suppose we

[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=17800913#comment-17800913 ] Wencong Liu commented on FLINK-33949: - Suppose we have two completely independent interfaces, I and

[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=17800802#comment-17800802 ] Wencong Liu commented on FLINK-33949: - For the users have built implementations themselves, they

[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=17800787#comment-17800787 ] Wencong Liu commented on FLINK-33949: - Thanks [~martijnvisser] for your comments. The implementation

[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=17800696#comment-17800696 ] Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:43 AM: --- Hi

[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=17800696#comment-17800696 ] Wencong Liu edited comment on FLINK-33009 at 12/27/23 6:42 AM: --- Hi

[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=17800696#comment-17800696 ] Wencong Liu commented on FLINK-33009: - Hi [~mapohl] , I've encountered the same issue once more when

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

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

[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

[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=17800411#comment-17800411 ] Wencong Liu commented on FLINK-33939: - Thanks for raising this issue!  I completely agree with your

[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-33502) HybridShuffleITCase caused a fatal error

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

[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=17792610#comment-17792610 ] Wencong Liu commented on FLINK-33502: - Thanks [~JunRuiLi] . I have investigated it and found that

[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=17790075#comment-17790075 ] Wencong Liu commented on FLINK-33652: - Hello [~pranav.sharma], thanks for the careful investigation.

[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=17789020#comment-17789020 ] Wencong Liu edited comment on FLINK-33626 at 11/23/23 8:27 AM: --- This is a

[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=17789020#comment-17789020 ] Wencong Liu commented on FLINK-33626: - This is a similar issue with [FLINK-33356] The navigation bar

[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] [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=17788998#comment-17788998 ] Wencong Liu edited comment on FLINK-33502 at 11/23/23 6:49 AM: --- Thank

[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=17788998#comment-17788998 ] Wencong Liu commented on FLINK-33502: - Thank [~mapohl]  for your help. The fix should be merged

[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=17787828#comment-17787828 ] Wencong Liu commented on FLINK-33502: - Thank you for your detailed reply. I am currently trying to

[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=17787224#comment-17787224 ] Wencong Liu commented on FLINK-33502: - Thank you for your reminder [~mapohl] . I would like to ask

[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=17784350#comment-17784350 ] Wencong Liu commented on FLINK-33323: - Thanks for your reminder! [~mapohl] . Could you please help

[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=17782384#comment-17782384 ] Wencong Liu commented on FLINK-33445: - Thanks [~liyubin117] ! Assigned to you. Please go ahead. >

[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

[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

[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: Description: The FLIINK-33041 about adding an introduction about how to migrate DataSet API to

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

[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=17781629#comment-17781629 ] Wencong Liu commented on FLINK-33356: - This is because of a recent failure in the documentation

[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=17779330#comment-17779330 ] Wencong Liu edited comment on FLINK-33356 at 10/25/23 5:58 AM: --- Hello

[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=17779330#comment-17779330 ] Wencong Liu commented on FLINK-33356: - Hello [~JunRuiLi] , I found this case is due to the commit

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

[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

[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

[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

[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=17762540#comment-17762540 ] Wencong Liu commented on FLINK-33041: - Thanks very much for your reminder [~echauchot] . I have

[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] [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=17760830#comment-17760830 ] Wencong Liu edited comment on FLINK-33009 at 8/31/23 9:49 AM: -- Thanks

[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=17760830#comment-17760830 ] Wencong Liu commented on FLINK-33009: - Thanks [~mapohl] for the summary.  BTW, I found this issue

[jira] [Updated] (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 updated FLINK-32978: Fix Version/s: 1.19.0 > Deprecate RichFunction#open(Configuration parameters) >

[jira] [Created] (FLINK-32979) Deprecate WindowAssigner#getDefaultTrigger(StreamExecutionEnvironment env)

Wencong Liu created FLINK-32979: --- Summary: Deprecate WindowAssigner#getDefaultTrigger(StreamExecutionEnvironment env) Key: FLINK-32979 URL: https://issues.apache.org/jira/browse/FLINK-32979 Project:

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

Wencong Liu created FLINK-32978: --- Summary: Deprecate RichFunction#open(Configuration parameters) Key: FLINK-32978 URL: https://issues.apache.org/jira/browse/FLINK-32978 Project: Flink Issue

[jira] [Created] (FLINK-32977) Deprecate IOReadableWritable serialization in Path

Wencong Liu created FLINK-32977: --- Summary: Deprecate IOReadableWritable serialization in Path Key: FLINK-32977 URL: https://issues.apache.org/jira/browse/FLINK-32977 Project: Flink Issue Type:

[jira] [Commented] (FLINK-32742) Remove flink-examples-batch module

[ https://issues.apache.org/jira/browse/FLINK-32742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751865#comment-17751865 ] Wencong Liu commented on FLINK-32742: - Good idea [~jiabao.sun]. Maybe you could find all classes

[jira] [Commented] (FLINK-32742) Remove flink-examples-batch module

[ https://issues.apache.org/jira/browse/FLINK-32742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751855#comment-17751855 ] Wencong Liu commented on FLINK-32742: - Hi [~jiabao.sun], currently flink-examples-batch module

[jira] [Created] (FLINK-32770) Fix the inaccurate backlog number of Hybrid Shuffle

Wencong Liu created FLINK-32770: --- Summary: Fix the inaccurate backlog number of Hybrid Shuffle Key: FLINK-32770 URL: https://issues.apache.org/jira/browse/FLINK-32770 Project: Flink Issue

[jira] [Updated] (FLINK-32742) Remove flink-examples-batch module

[ https://issues.apache.org/jira/browse/FLINK-32742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-32742: Description: All DataSet APIs will be deprecated in [FLINK-32558], and the examples in the

[jira] [Created] (FLINK-32742) Remove flink-examples-batch module

Wencong Liu created FLINK-32742: --- Summary: Remove flink-examples-batch module Key: FLINK-32742 URL: https://issues.apache.org/jira/browse/FLINK-32742 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-32741) Remove DataSet related descriptions in doc

Wencong Liu created FLINK-32741: --- Summary: Remove DataSet related descriptions in doc Key: FLINK-32741 URL: https://issues.apache.org/jira/browse/FLINK-32741 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

[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

[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=17747733#comment-17747733 ] Wencong Liu edited comment on FLINK-32686 at 7/27/23 3:42 AM: -- Thanks for

[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=17747733#comment-17747733 ] Wencong Liu commented on FLINK-32686: - Thanks for reporting this. The second regression since 07.24

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

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

[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=17744452#comment-17744452 ] Wencong Liu edited comment on FLINK-5336 at 7/20/23 4:13 AM: - Hi all, I have

[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=17744452#comment-17744452 ] Wencong Liu edited comment on FLINK-5336 at 7/20/23 2:32 AM: - Hi all, I have

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

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

[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=17744409#comment-17744409 ] Wencong Liu commented on FLINK-32624: - Thanks [~lincoln.86xy] .  I've opened a hot fix. [[hotfix]

[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=17744403#comment-17744403 ] Wencong Liu commented on FLINK-32624: - Sorry for the late reply, I'll take a look. [~lincoln.86xy] 

[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=17741813#comment-17741813 ] Wencong Liu commented on FLINK-32523: - I think we should remove @Test(timeout = TEST_TIMEOUT) in

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

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

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731830#comment-17731830 ] Wencong Liu commented on FLINK-32319: - If this exception occurs, it indicates that the upstream

[jira] [Commented] (FLINK-32319) flink can't the partition of network after restart

[ https://issues.apache.org/jira/browse/FLINK-32319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17731822#comment-17731822 ] Wencong Liu commented on FLINK-32319: - Hi [~1026688210] , maybe you could try this config

[jira] [Commented] (FLINK-32127) Source busy time is inaccurate in many cases

[ https://issues.apache.org/jira/browse/FLINK-32127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724083#comment-17724083 ] Wencong Liu commented on FLINK-32127: - Hi [~Zhanghao Chen] , Thanks for the proposal! I guess the

[jira] [Updated] (FLINK-32121) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-32121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-32121: Environment: (was: !temp2.jpg!) > Avro Confluent Schema Registry nightly end-to-end test

[jira] [Created] (FLINK-32121) Avro Confluent Schema Registry nightly end-to-end test failed due to timeout

Wencong Liu created FLINK-32121: --- Summary: Avro Confluent Schema Registry nightly end-to-end test failed due to timeout Key: FLINK-32121 URL: https://issues.apache.org/jira/browse/FLINK-32121 Project:

[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=17723330#comment-17723330 ] Wencong Liu commented on FLINK-32112: - Helllo [~xmzhou] , Thanks for your proposal. Currently, the

[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

[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=17722638#comment-17722638 ] Wencong Liu commented on FLINK-32065: - Hello [~SpongebobZ] , do you clean the tmp dir before the

[jira] [Updated] (FLINK-32066) Flink CI service on Azure stops responding to pull requests

[ https://issues.apache.org/jira/browse/FLINK-32066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-32066: Summary: Flink CI service on Azure stops responding to pull requests (was: Flink Ci service on

[jira] [Created] (FLINK-32066) Flink Ci service on Azure stops responding to pull requests

Wencong Liu created FLINK-32066: --- Summary: Flink Ci service on Azure stops responding to pull requests Key: FLINK-32066 URL: https://issues.apache.org/jira/browse/FLINK-32066 Project: Flink

[jira] [Commented] (FLINK-29618) YARNSessionFIFOSecuredITCase.testDetachedMode timed out in Azure CI

[ https://issues.apache.org/jira/browse/FLINK-29618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17721713#comment-17721713 ] Wencong Liu commented on FLINK-29618: - Thanks for the reply [~mapohl] . I'd like to remove the

[jira] [Commented] (FLINK-27204) FileSystemJobResultStore should operator on the ioExecutor

[ https://issues.apache.org/jira/browse/FLINK-27204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719870#comment-17719870 ] Wencong Liu commented on FLINK-27204: - Could you please take a look at this pull request when you

[jira] [Comment Edited] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715402#comment-17715402 ] Wencong Liu edited comment on FLINK-31131 at 4/23/23 8:36 AM: -- OK.

[jira] [Commented] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715402#comment-17715402 ] Wencong Liu commented on FLINK-31131: - OK. [~fanrui]  > The INITIALIZING of ExecutionState is

[jira] [Commented] (FLINK-31881) The Chinese documentation page of Flink official CEP is experiencing confusion.

[ https://issues.apache.org/jira/browse/FLINK-31881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715363#comment-17715363 ] Wencong Liu commented on FLINK-31881: - Hello [~zhaoshuo], I'd like to fix errors in the markdown

[jira] [Commented] (FLINK-31131) The INITIALIZING of ExecutionState is missed in the state_machine doc

[ https://issues.apache.org/jira/browse/FLINK-31131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17714516#comment-17714516 ] Wencong Liu commented on FLINK-31131: - [~fanrui]  Sure, I'll be happy to finish it. > The

[jira] [Created] (FLINK-31841) Redundant local variables in AllWindowedStream#reduce

Wencong Liu created FLINK-31841: --- Summary: Redundant local variables in AllWindowedStream#reduce Key: FLINK-31841 URL: https://issues.apache.org/jira/browse/FLINK-31841 Project: Flink Issue

  1   2   3   >