[jira] [Closed] (FLINK-30132) Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists

2023-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30132. - Resolution: Duplicate Closing FLINK-30132 in favor of FLINK-33641 because there's more discussio

[jira] [Commented] (FLINK-33414) MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails due to unexpected TimeoutException

2023-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790953#comment-17790953 ] Matthias Pohl commented on FLINK-33414: --- https://github.com/XComp/flink/actions/ru

[jira] [Commented] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

2023-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790951#comment-17790951 ] Matthias Pohl commented on FLINK-32006: --- FLINK-27075-related: https://github.com/

[jira] [Created] (FLINK-33690) build_wheels_on_macos sometimes fails with read timed out on AZP

2023-11-28 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33690: --- Summary: build_wheels_on_macos sometimes fails with read timed out on AZP Key: FLINK-33690 URL: https://issues.apache.org/jira/browse/FLINK-33690 Project: Flink

[jira] [Updated] (FLINK-33641) JUnit5 fails to delete a directory on AZP for various table-planner tests

2023-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33641: Summary: JUnit5 fails to delete a directory on AZP for various table-planner tests (was:

Re: [PR] [FLINK-33689][table-runtime] Fix JsonObjectAggFunction can't retract records when enabling LocalGlobal. [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23827: URL: https://github.com/apache/flink/pull/23827#issuecomment-1831347603 ## CI report: * 14941540a4d1c8b4e6b278bc0f30dd14f3d27515 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33689) JsonObjectAggFunction can't retract previous data which is invalid when enabling local global agg

2023-11-28 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuai Xu updated FLINK-33689: - Summary: JsonObjectAggFunction can't retract previous data which is invalid when enabling local global a

[jira] [Updated] (FLINK-33689) JsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

2023-11-28 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuai Xu updated FLINK-33689: - Summary: JsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

[jira] [Updated] (FLINK-33689) jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

2023-11-28 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuai Xu updated FLINK-33689: - Description: Run the test as following and enable LocalGlobal and minibatch  in sql/AggregateITCase . 

[jira] [Updated] (FLINK-33689) jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

2023-11-28 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuai Xu updated FLINK-33689: - Description: Run the test as following and enable LocalGlobal in sql/AggregateITCase .  {code:java} def

[jira] [Commented] (FLINK-33641) RankITCase.testMultipleUnaryTopNAfterAgg fails on AZP

2023-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790938#comment-17790938 ] Sergey Nuyanzin commented on FLINK-33641: - same case with another test https://

[jira] [Updated] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-28 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-33668: -- Description: With FLINK-30469  and FLINK-31643, we have decoupled the shuffle network memory and the

[jira] [Commented] (FLINK-30719) flink-runtime-web failed due to a corrupted nodejs dependency

2023-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790937#comment-17790937 ] Sergey Nuyanzin commented on FLINK-30719: - https://dev.azure.com/apache-flink/ap

[jira] [Updated] (FLINK-33689) jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

2023-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33689: --- Labels: pull-request-available (was: ) > jsonObjectAggFunction can't retract previous data

[PR] [FLINK-33689][table-runtime] Fix JsonObjectAggFunction can't retract records when enabling LocalGlobal. [flink]

2023-11-28 Thread via GitHub
xishuaidelin opened a new pull request, #23827: URL: https://github.com/apache/flink/pull/23827 ## What is the purpose of the change * This pull request fix JsonObjectAggFunction which can't retract records when enabling LocalGlobal. The retract function in JsonObjectA

[jira] [Resolved] (FLINK-33664) Setup cron build for java 21

2023-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33664. - Resolution: Fixed > Setup cron build for java 21 > > >

[jira] [Created] (FLINK-33689) jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg

2023-11-28 Thread Shuai Xu (Jira)
Shuai Xu created FLINK-33689: Summary: jsonObjectAggFunction can't retract previous data which is invalid when enable local global agg Key: FLINK-33689 URL: https://issues.apache.org/jira/browse/FLINK-33689

[jira] [Closed] (FLINK-33664) Setup cron build for java 21

2023-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33664. --- > Setup cron build for java 21 > > > Key: FLINK-336

[jira] [Commented] (FLINK-33664) Setup cron build for java 21

2023-11-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790934#comment-17790934 ] Sergey Nuyanzin commented on FLINK-33664: - Merged to master as [76f754833298beb

[jira] [Updated] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-28 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-33668: -- Description: With FLINK-30469  and FLINK-31643, we have decoupled the shuffle network memory and the

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices when creating RestClusterClient

2023-11-28 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Parent: FLINK-33683 Issue Type: Sub-task (was: Improvement) > Reuse ClientHighAvailabil

[jira] [Updated] (FLINK-32756) Reuse ClientHighAvailabilityServices when creating RestClusterClient

2023-11-28 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-32756: - Parent: (was: FLINK-25318) Issue Type: Improvement (was: Sub-task) > Reuse ClientHi

[jira] [Created] (FLINK-33688) Reuse Channels in RestClient to save connection establish time

2023-11-28 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33688: Summary: Reuse Channels in RestClient to save connection establish time Key: FLINK-33688 URL: https://issues.apache.org/jira/browse/FLINK-33688 Project: Flink

[jira] [Created] (FLINK-33687) Reuse RestClusterClient in StandaloneClusterDescriptor to avoid frequent thread create/destroy

2023-11-28 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33687: Summary: Reuse RestClusterClient in StandaloneClusterDescriptor to avoid frequent thread create/destroy Key: FLINK-33687 URL: https://issues.apache.org/jira/browse/FLINK-33687

Re: [PR] FLINK-33600][table] print the query time cost for batch query in cli [flink]

2023-11-28 Thread via GitHub
JingGe commented on PR #23809: URL: https://github.com/apache/flink/pull/23809#issuecomment-1831318436 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. T

[jira] [Commented] (FLINK-26013) Develop ArchUnit test (infra) for Flink core and runtime test code

2023-11-28 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790930#comment-17790930 ] Jing Ge commented on FLINK-26013: - flink-core: master: 05960a7ccf2a6900e87159a6925595b9

[jira] [Created] (FLINK-33686) Reuse StandaloneClusterDescriptor in RemoteExecutor when executing jobs on the same cluster

2023-11-28 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33686: Summary: Reuse StandaloneClusterDescriptor in RemoteExecutor when executing jobs on the same cluster Key: FLINK-33686 URL: https://issues.apache.org/jira/browse/FLINK-33686

[jira] [Created] (FLINK-33685) StandaloneClusterId need to distinguish different remote clusters

2023-11-28 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33685: Summary: StandaloneClusterId need to distinguish different remote clusters Key: FLINK-33685 URL: https://issues.apache.org/jira/browse/FLINK-33685 Project: Flink

[jira] [Created] (FLINK-33684) Improve the retry strategy in CollectResultFetcher

2023-11-28 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33684: Summary: Improve the retry strategy in CollectResultFetcher Key: FLINK-33684 URL: https://issues.apache.org/jira/browse/FLINK-33684 Project: Flink Issue Type

Re: [PR] [hotfix][core][test] fix ArchUnit typo in pom [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23826: URL: https://github.com/apache/flink/pull/23826#issuecomment-1831307968 ## CI report: * e01506ef2edf4b73bf86440f77512f50239fa0d5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-33683) Improve the performance of submitting jobs and fetching results to a running flink cluster

2023-11-28 Thread xiangyu feng (Jira)
xiangyu feng created FLINK-33683: Summary: Improve the performance of submitting jobs and fetching results to a running flink cluster Key: FLINK-33683 URL: https://issues.apache.org/jira/browse/FLINK-33683

Re: [PR] Adding AWS Connectors v4.2.0 [flink-web]

2023-11-28 Thread via GitHub
leonardBang commented on code in PR #693: URL: https://github.com/apache/flink-web/pull/693#discussion_r1408813637 ## docs/data/release_archive.yml: ## @@ -522,6 +522,11 @@ release_archive: version: 3.0.1 release_date: 2023-10-30 filename: "kafka" +- nam

[PR] [hotfix][core][test] fix ArchUnit typo in pom [flink]

2023-11-28 Thread via GitHub
JingGe opened a new pull request, #23826: URL: https://github.com/apache/flink/pull/23826 ## What is the purpose of the change fix ArchUnit typo in pom of flink-core ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or

Re: [PR] fix typo in the pom files of flink-format modules for archunit [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23825: URL: https://github.com/apache/flink/pull/23825#issuecomment-1831303244 ## CI report: * 1f485ba5993aa6ddcac9bc5f06f1c5cd2bc9a47b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] fix typo in the pom files of flink-format modules for archunit [flink]

2023-11-28 Thread via GitHub
JingGe opened a new pull request, #23825: URL: https://github.com/apache/flink/pull/23825 ## What is the purpose of the change fix typo in the pom files for ArchUnit ## Verifying this change This change is a trivial typo fix without any test coverage. ## Does this

Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-11-28 Thread via GitHub
jeyhunkarimov commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1408807116 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlShowDatabasesConverter.java: ## @@ -0,0 +1,58 @@ +/* + *

Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-11-28 Thread via GitHub
jeyhunkarimov commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1408795264 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowDatabases.java: ## @@ -29,14 +31,55 @@ import java.util.Collections; import

Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-11-28 Thread via GitHub
jeyhunkarimov commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1408794421 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowDatabasesOperation.java: ## @@ -20,26 +20,108 @@ import org.apache.flin

Re: [PR] [FLINK-31481][table] Support enhanced show databases syntax [flink]

2023-11-28 Thread via GitHub
jeyhunkarimov commented on code in PR #23612: URL: https://github.com/apache/flink/pull/23612#discussion_r1408794805 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowDatabasesOperation.java: ## @@ -20,26 +20,108 @@ import org.apache.flin

[jira] [Resolved] (FLINK-33637) [JUnit5 Migration] Introduce ArchTest rules to ban Junit 4 for table-planner

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-33637. Fix Version/s: 1.19.0 Resolution: Implemented Implemented in master: b9f3b957cc136a65c55b0b

[jira] [Assigned] (FLINK-33637) [JUnit5 Migration] Introduce ArchTest rules to ban Junit 4 for table-planner

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-33637: -- Assignee: Jiabao Sun > [JUnit5 Migration] Introduce ArchTest rules to ban Junit 4 for table-p

Re: [PR] [FLINK-32986][test] Fix createTemporaryFunction type inference error [flink]

2023-11-28 Thread via GitHub
jeyhunkarimov commented on PR #23586: URL: https://github.com/apache/flink/pull/23586#issuecomment-1831282659 > @jeyhunkarimov Thanks for contributing to Flink! Can you sort out the conflict that has happened? > > @lincoln-lil may be the best person to review this PR. @jnh5y Th

Re: [PR] [hotfix][docs] Update minor version for 1.17.2 release [flink]

2023-11-28 Thread via GitHub
Myasuka merged PR #23824: URL: https://github.com/apache/flink/pull/23824 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

Re: [PR] [hotfix][docs] Update minor version for 1.17.2 release [flink]

2023-11-28 Thread via GitHub
yuchen-ecnu commented on PR #23824: URL: https://github.com/apache/flink/pull/23824#issuecomment-1831281798 @Myasuka Could you helps to merge this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-28 Thread via GitHub
leonardBang merged PR #23791: URL: https://github.com/apache/flink/pull/23791 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.a

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-28 Thread via GitHub
Jiabao-Sun commented on PR #23791: URL: https://github.com/apache/flink/pull/23791#issuecomment-1831280708 squash is fine, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific com

[PR] [hotfix][docs] Update minor version for 1.17.2 release [flink]

2023-11-28 Thread via GitHub
yuchen-ecnu opened a new pull request, #23824: URL: https://github.com/apache/flink/pull/23824 ## What is the purpose of the change Update flink doc version for 1.17.2 release ## Brief change log - change flink doc version ## Verifying this change Th

Re: [PR] [FLINK-33398][runtime] Support switching from batch to stream mode for one input stream operator [flink]

2023-11-28 Thread via GitHub
xintongsong commented on code in PR #23521: URL: https://github.com/apache/flink/pull/23521#discussion_r1406042500 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/RecordAttributes.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Soft

[jira] [Comment Edited] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790844#comment-17790844 ] dalongliu edited comment on FLINK-33668 at 11/29/23 5:58 AM: -

Re: [PR] [FLINK-33682][metrics] Reuse source operator input records/bytes metrics for SourceOperatorStreamTask [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23823: URL: https://github.com/apache/flink/pull/23823#issuecomment-1831269268 ## CI report: * fef2fd9e9a9803f547c9c3c5a374d8b2e186b6d8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33682) Reuse source operator input records/bytes metrics for SourceOperatorStreamTask

2023-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33682: --- Labels: pull-request-available (was: ) > Reuse source operator input records/bytes metrics

[PR] [FLINK-33682][metrics] Reuse source operator input records/bytes metrics for SourceOperatorStreamTask [flink]

2023-11-28 Thread via GitHub
X-czh opened a new pull request, #23823: URL: https://github.com/apache/flink/pull/23823 ## What is the purpose of the change Integrate standard source I/O metrics into SourceOperatorStreamTask, so that users can see source numRecordsIn & numBytesIn on the job overview page of

[jira] [Assigned] (FLINK-33682) Reuse source operator input records/bytes metrics for SourceOperatorStreamTask

2023-11-28 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33682: - Assignee: Zhanghao Chen > Reuse source operator input records/bytes metrics for SourceOperatorS

[jira] [Updated] (FLINK-33680) Failed to build document with docker

2023-11-28 Thread wangshiheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangshiheng updated FLINK-33680: Summary: Failed to build document with docker (was: Failed to build document with docke) > Faile

[jira] [Updated] (FLINK-33680) Failed to build document with docke

2023-11-28 Thread wangshiheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangshiheng updated FLINK-33680: Description: Follow the documentation, the documentation comes from  [https://github.com/apache/fl

[jira] [Updated] (FLINK-33680) Failed to build document with docke

2023-11-28 Thread wangshiheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangshiheng updated FLINK-33680: Description: Follow the documentation, the documentation comes from  [https://github.com/apache/fl

[jira] [Created] (FLINK-33682) Reuse source operator input records/bytes metrics for SourceOperatorStreamTask

2023-11-28 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33682: - Summary: Reuse source operator input records/bytes metrics for SourceOperatorStreamTask Key: FLINK-33682 URL: https://issues.apache.org/jira/browse/FLINK-33682 Proj

[jira] [Created] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

2023-11-28 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33681: - Summary: Display source/sink numRecordsIn/Out & numBytesIn/Out on UI Key: FLINK-33681 URL: https://issues.apache.org/jira/browse/FLINK-33681 Project: Flink

[jira] [Created] (FLINK-33680) Failed to build document with docke

2023-11-28 Thread wangshiheng (Jira)
wangshiheng created FLINK-33680: --- Summary: Failed to build document with docke Key: FLINK-33680 URL: https://issues.apache.org/jira/browse/FLINK-33680 Project: Flink Issue Type: Bug C

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-28 Thread via GitHub
JingGe commented on PR #23791: URL: https://github.com/apache/flink/pull/23791#issuecomment-1831248182 > Thanks @JingGe for the review. I did not explicitly run the ArchUnit test in other modules. The violations reduction of the ArchUnit test of other modules in this PR is due to the repai

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-28 Thread via GitHub
Jiabao-Sun commented on PR #23791: URL: https://github.com/apache/flink/pull/23791#issuecomment-1831231617 > Thanks @Jiabao-Sun for the update. There are some ArchUnit violations in other modules. Did you run the ArchUnit test in those modules explicitly? Thanks @JingGe for the review

[jira] [Commented] (FLINK-33670) Public operators cannot be reused in multi sinks

2023-11-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790898#comment-17790898 ] Benchao Li commented on FLINK-33670: I would take this as a CTE(common table express

Re: [PR] FLINK-33600][table] print the query time cost for batch query in cli [flink]

2023-11-28 Thread via GitHub
JingGe commented on code in PR #23809: URL: https://github.com/apache/flink/pull/23809#discussion_r1408745083 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/print/TableauStyle.java: ## @@ -117,6 +122,10 @@ public final class TableauStyle implements

Re: [PR] FLINK-33600][table] print the query time cost for batch query in cli [flink]

2023-11-28 Thread via GitHub
JingGe commented on code in PR #23809: URL: https://github.com/apache/flink/pull/23809#discussion_r1408742394 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/print/TableauStyle.java: ## @@ -92,12 +95,14 @@ public final class TableauStyle implements P

Re: [PR] [FLINK-33637][table-planner][JUnit5 Migration] Introduce ArchTest to ban Junit 4 for module table-planner [flink]

2023-11-28 Thread via GitHub
JingGe commented on PR #23791: URL: https://github.com/apache/flink/pull/23791#issuecomment-1831209459 Thanks @Jiabao-Sun for the update. There are some ArchUnit violations in other modules. Did you run the ArchUnit test in those modules explicitly? -- This is an automated message from th

Re: [PR] [FLINK-26010] Develop archunit test for filesystem test code [flink]

2023-11-28 Thread via GitHub
JingGe merged PR #23798: URL: https://github.com/apache/flink/pull/23798 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Commented] (FLINK-33674) In the wmassigners module, words are misspelled

2023-11-28 Thread wangshiheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790889#comment-17790889 ] wangshiheng commented on FLINK-33674: - Thank you very much, the documentation on the

Re: [PR] Add release 1.17.2 [flink-web]

2023-11-28 Thread via GitHub
Myasuka merged PR #696: URL: https://github.com/apache/flink-web/pull/696 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apach

[jira] [Created] (FLINK-33679) RestoreMode uses NO_CLAIM as default instead of LEGACY

2023-11-28 Thread junzhong qin (Jira)
junzhong qin created FLINK-33679: Summary: RestoreMode uses NO_CLAIM as default instead of LEGACY Key: FLINK-33679 URL: https://issues.apache.org/jira/browse/FLINK-33679 Project: Flink Issue

[jira] [Updated] (FLINK-33395) The join hint doesn't work when appears in subquery

2023-11-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-33395: - Fix Version/s: 1.17.3 (was: 1.17.2) > The join hint doesn't work when appears in

[jira] [Created] (FLINK-33678) Remove configuration getters/setters that return/set complex Java objects

2023-11-28 Thread Junrui Li (Jira)
Junrui Li created FLINK-33678: - Summary: Remove configuration getters/setters that return/set complex Java objects Key: FLINK-33678 URL: https://issues.apache.org/jira/browse/FLINK-33678 Project: Flink

Re: [PR] [FLINK-26694][table] Support lookup join via a multi-level inheritance of TableFunction [flink]

2023-11-28 Thread via GitHub
YesOrNo828 commented on PR #23684: URL: https://github.com/apache/flink/pull/23684#issuecomment-1831101003 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[jira] [Commented] (FLINK-33644) FLIP-393: Make QueryOperations SQL serializable

2023-11-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790865#comment-17790865 ] Shengkai Fang commented on FLINK-33644: --- Hi [~dwysakowicz]. I am confused that how

[jira] [Commented] (FLINK-32756) Reuse ClientHighAvailabilityServices when creating RestClusterClient

2023-11-28 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790862#comment-17790862 ] Yangze Guo commented on FLINK-32756: [~xiangyu0xf] Done, go ahead! > Reuse ClientHi

[jira] [Assigned] (FLINK-32756) Reuse ClientHighAvailabilityServices when creating RestClusterClient

2023-11-28 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32756: -- Assignee: xiangyu feng > Reuse ClientHighAvailabilityServices when creating RestClusterClient

[jira] [Created] (FLINK-33677) Remove flink-conf.yaml from flink dist

2023-11-28 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-33677: --- Summary: Remove flink-conf.yaml from flink dist Key: FLINK-33677 URL: https://issues.apache.org/jira/browse/FLINK-33677 Project: Flink Issue Type: Sub-task C

[jira] [Updated] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-28 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-33668: -- Description: With FLINK-30469  and FLINK-31643, we have decoupled the shuffle network memory and the

[jira] [Commented] (FLINK-33638) Support variable-length data generation for variable-length data types

2023-11-28 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790860#comment-17790860 ] Yubin Li commented on FLINK-33638: -- [~lincoln] I have finished the feature according to

[jira] [Closed] (FLINK-32269) CreateTableAsITCase.testCreateTableAsInStatementSet fails on AZP

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-32269. -- Fix Version/s: 1.18.1 1.17.3 Resolution: Fixed Fixed in master(1.19): 63996

[jira] (FLINK-32269) CreateTableAsITCase.testCreateTableAsInStatementSet fails on AZP

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32269 ] Leonard Xu deleted comment on FLINK-32269: was (Author: leonard xu): Fixed in master(1.19): 63996b5c7fe15d792e6a74d5323b008b9a762b52 > CreateTableAsITCase.testCreateTableAsInStatementSet fai

[jira] [Resolved] (FLINK-31033) UsingRemoteJarITCase.testUdfInRemoteJar failed with assertion

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-31033. Fix Version/s: 1.18.1 1.17.3 Resolution: Fixed Fixed in master(1.19): 6

[jira] [Reopened] (FLINK-32269) CreateTableAsITCase.testCreateTableAsInStatementSet fails on AZP

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reopened FLINK-32269: > CreateTableAsITCase.testCreateTableAsInStatementSet fails on AZP > -

[jira] [Resolved] (FLINK-31141) CreateTableAsITCase.testCreateTableAs fails

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-31141. Fix Version/s: 1.18.1 1.17.3 Resolution: Fixed Fixed in master(1.19): 6

[jira] [Resolved] (FLINK-31339) PlannerScalaFreeITCase.testImperativeUdaf

2023-11-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-31339. Fix Version/s: 1.18.1 1.17.3 Resolution: Fixed Fixed in master(1.19): 6

Re: [PR] [BP-1.17][FLINK-31339][table][tests] Comparing with materialized result when mini-batch enabled to fix unstable sql e2e tests [flink]

2023-11-28 Thread via GitHub
leonardBang merged PR #23817: URL: https://github.com/apache/flink/pull/23817 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.a

[jira] [Commented] (FLINK-33668) Decoupling Shuffle network memory and job topology

2023-11-28 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17790844#comment-17790844 ] dalongliu commented on FLINK-33668: --- Big +1, there also has  a depulicated issue: htt

Re: [PR] [BP-1.18][FLINK-31339][table][tests] Comparing with materialized result when mini-batch enabled to fix unstable sql e2e tests [flink]

2023-11-28 Thread via GitHub
leonardBang merged PR #23816: URL: https://github.com/apache/flink/pull/23816 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.a

Re: [PR] [FLINK-32986][test] Fix createTemporaryFunction type inference error [flink]

2023-11-28 Thread via GitHub
jeyhunkarimov commented on PR #23586: URL: https://github.com/apache/flink/pull/23586#issuecomment-1830956237 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comm

Re: [PR] [FLINK-33422] Move Calc restore tests [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23822: URL: https://github.com/apache/flink/pull/23822#issuecomment-1830929772 ## CI report: * 5f43ab687076b036a9f25d90aab8a9faae19cc5a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-33422] Move Calc restore tests [flink]

2023-11-28 Thread via GitHub
bvarghese1 opened a new pull request, #23822: URL: https://github.com/apache/flink/pull/23822 ## What is the purpose of the change Move Calc restore tests to the right package `org.apache.flink.table.planner.plan.nodes.exec.stream` Related PR - https://github.com/apache/fli

[jira] [Created] (FLINK-33676) Implement restore tests for WindowAggregate node

2023-11-28 Thread Jim Hughes (Jira)
Jim Hughes created FLINK-33676: -- Summary: Implement restore tests for WindowAggregate node Key: FLINK-33676 URL: https://issues.apache.org/jira/browse/FLINK-33676 Project: Flink Issue Type: Sub-

[PR] Add flink-shaded 18.0 release [flink-web]

2023-11-28 Thread via GitHub
snuyanzin opened a new pull request, #701: URL: https://github.com/apache/flink-web/pull/701 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-

Re: [PR] [FLINK-33667] Implement restore tests for MatchRecognize node [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23821: URL: https://github.com/apache/flink/pull/23821#issuecomment-1830664311 ## CI report: * 76d0fd68b9dd0891f54737580e72b46300169350 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33667) Implement restore tests for MatchRecognize node

2023-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33667: --- Labels: pull-request-available (was: ) > Implement restore tests for MatchRecognize node >

[PR] [FLINK-33667] Implement restore tests for MatchRecognize node [flink]

2023-11-28 Thread via GitHub
jnh5y opened a new pull request, #23821: URL: https://github.com/apache/flink/pull/23821 ## What is the purpose of the change Implement restore tests for MatchRecognize node ## Verifying this change This change added tests and can be verified as follows: * Added re

Re: [PR] [FLINK-33433][rest] Introduce async-profiler to support profiling Job… [flink]

2023-11-28 Thread via GitHub
flinkbot commented on PR #23820: URL: https://github.com/apache/flink/pull/23820#issuecomment-1830313536 ## CI report: * 48b2e2941d84938b7fecc74df5b110fe853835c4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33433) Support invoke async-profiler on Jobmanager through REST API

2023-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33433: --- Labels: pull-request-available (was: ) > Support invoke async-profiler on Jobmanager throug

[PR] [FLINK-33433][rest] Introduce async-profiler to support profiling Job… [flink]

2023-11-28 Thread via GitHub
yuchen-ecnu opened a new pull request, #23820: URL: https://github.com/apache/flink/pull/23820 …Manager via REST API ## What is the purpose of the change This is a subtask of [FLIP-375](https://cwiki.apache.org/confluence/x/64lEE), which introduces the async-profiler for profi

Re: [PR] [hotfix] improve comments in archunit.properties in common modules [flink]

2023-11-28 Thread via GitHub
echauchot commented on PR #23723: URL: https://github.com/apache/flink/pull/23723#issuecomment-1830073846 @zentol considering this PR is only comments in archunit conf, and it is the same content that [you already reviewed](https://github.com/apache/flink-connector-shared-utils/pull/23#pull

[jira] [Created] (FLINK-33675) Serialize ValueLiteralExpressions into SQL

2023-11-28 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33675: Summary: Serialize ValueLiteralExpressions into SQL Key: FLINK-33675 URL: https://issues.apache.org/jira/browse/FLINK-33675 Project: Flink Issue Type

  1   2   >