[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814227#comment-17814227 ] Matthias Pohl commented on FLINK-34357: --- {{Kerberized YARN per-job on Docker test

[jira] [Commented] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814225#comment-17814225 ] Matthias Pohl commented on FLINK-34357: --- https://github.com/apache/flink/actions/r

[jira] [Created] (FLINK-34359) "Kerberized YARN per-job on Docker test (default input)" failed due to IllegalStateException

2024-02-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34359: - Summary: "Kerberized YARN per-job on Docker test (default input)" failed due to IllegalStateException Key: FLINK-34359 URL: https://issues.apache.org/jira/browse/FLINK-34359

[jira] [Created] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34358: -- Summary: flink-connector-jdbc nightly fails with "Expecting code to raise a throwable" Key: FLINK-34358 URL: https://issues.apache.org/jira/browse/FLINK-34358 Pro

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814212#comment-17814212 ] Matthias Pohl commented on FLINK-22765: --- https://github.com/apache/flink/actions/r

[jira] [Commented] (FLINK-34099) CheckpointIntervalDuringBacklogITCase.testNoCheckpointDuringBacklog is unstable on AZP

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814210#comment-17814210 ] Matthias Pohl commented on FLINK-34099: --- https://github.com/apache/flink/actions/r

[jira] [Created] (FLINK-34357) IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail

2024-02-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34357: - Summary: IllegalAnnotationsException causes "PyFlink YARN per-job on Docker test" e2e test to fail Key: FLINK-34357 URL: https://issues.apache.org/jira/browse/FLINK-34357

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814205#comment-17814205 ] Matthias Pohl commented on FLINK-28440: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814203#comment-17814203 ] Matthias Pohl commented on FLINK-34202: --- 1.18: https://dev.azure.com/apache-flink

[jira] [Closed] (FLINK-34292) Release Testing Instructions: Verify FLINK-30613 Improve resolving schema compatibility

2024-02-04 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu closed FLINK-34292. Resolution: Fixed Closed Since it doesn't beak the change of public API. This introduces a new de

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814201#comment-17814201 ] Matthias Pohl commented on FLINK-34007: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-34273) git fetch fails

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814199#comment-17814199 ] Matthias Pohl commented on FLINK-34273: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable

2024-02-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814197#comment-17814197 ] Matthias Pohl commented on FLINK-22765: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-17593) Support arbitrary recovery mechanism for PartFileWriter

2024-02-04 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814195#comment-17814195 ] xiaogang zhou commented on FLINK-17593: --- [~maguowei] Hi , for filesystem which doe

[jira] [Comment Edited] (FLINK-34355) Release Testing: Verify FLINK-34054 Support named parameters for functions and procedures

2024-02-04 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814193#comment-17814193 ] Shuai Xu edited comment on FLINK-34355 at 2/5/24 7:19 AM: -- Hi,

[jira] [Commented] (FLINK-34355) Release Testing: Verify FLINK-34054 Support named parameters for functions and procedures

2024-02-04 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814193#comment-17814193 ] Shuai Xu commented on FLINK-34355: -- Hi, I'd like to take this verification. > Release

[jira] [Commented] (FLINK-34304) Release Testing Instructions: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-02-04 Thread Shuai Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814192#comment-17814192 ] Shuai Xu commented on FLINK-34304: -- This test is opened in another issue FLINK-34349 an

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814187#comment-17814187 ] lincoln lee commented on FLINK-33265: - [~Zhanghao Chen] Assigned to him. [~sudewei.

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
1996fanrui commented on PR #24212: URL: https://github.com/apache/flink/pull/24212#issuecomment-1926354179 Thank you @fengjiajie for the great work. I have merged all PRs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[jira] [Assigned] (FLINK-33265) Support source parallelism setting for Kafka connector

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-33265: --- Assignee: SuDewei > Support source parallelism setting for Kafka connector > --

[jira] [Comment Edited] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

2024-02-04 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814046#comment-17814046 ] Rui Fan edited comment on FLINK-33981 at 2/5/24 7:10 AM: - Hi [~f

[jira] [Resolved] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

2024-02-04 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33981. - Resolution: Fixed > File Descriptor References Not Released After Job Execution in MiniCluster > Mode >

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
1996fanrui merged PR #24262: URL: https://github.com/apache/flink/pull/24262 -- 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.ap

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
1996fanrui merged PR #24261: URL: https://github.com/apache/flink/pull/24261 -- 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.ap

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
fengjiajie commented on PR #24212: URL: https://github.com/apache/flink/pull/24212#issuecomment-1926335570 > Thanks @fengjiajie for the fix! > > I see other callers of `Files.list` has already used the `try-with-resource`, and the comment also mentions it. So LGTM. @1996fanrui

Re: [PR] [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file [flink]

2024-02-04 Thread via GitHub
JunRuiLee commented on code in PR #24266: URL: https://github.com/apache/flink/pull/24266#discussion_r1477726463 ## docs/content.zh/docs/deployment/resource-providers/standalone/docker.md: ## @@ -534,7 +534,7 @@ To provide a custom location for the Flink configuration files, yo

[jira] [Closed] (FLINK-33240) Generate docs for deprecated options as well

2024-02-04 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen closed FLINK-33240. - Fix Version/s: (was: 1.19.0) Resolution: Duplicate > Generate docs for deprecated opt

[jira] [Commented] (FLINK-33240) Generate docs for deprecated options as well

2024-02-04 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814182#comment-17814182 ] Zhanghao Chen commented on FLINK-33240: --- Closing it for duplication. The effort is

[jira] [Commented] (FLINK-33265) Support source parallelism setting for Kafka connector

2024-02-04 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814181#comment-17814181 ] Zhanghao Chen commented on FLINK-33265: --- Hi [~lincoln.86xy], SuDewei will be doing

[jira] [Commented] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

2024-02-04 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814180#comment-17814180 ] Feng Jiajie commented on FLINK-33981: - Hi [~fanrui] , thanks for the review, I have

[jira] [Updated] (FLINK-33981) File Descriptor References Not Released After Job Execution in MiniCluster Mode

2024-02-04 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33981: Fix Version/s: 1.19.0 1.17.3 1.18.2 > File Descriptor Refere

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
TimFruit commented on PR #24262: URL: https://github.com/apache/flink/pull/24262#issuecomment-1926295937 ![image](https://github.com/apache/flink/assets/23203575/9531b846-d2c3-4736-8d63-2625f309cb81) it could be solved by adding the class to the project -- This is an automated mess

Re: [PR] [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file [flink]

2024-02-04 Thread via GitHub
1996fanrui commented on code in PR #24266: URL: https://github.com/apache/flink/pull/24266#discussion_r1477680165 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -288,11 +288,11 @@ RocksDB State Backend 会将 [这里定义]({{< ref "docs/deployment/config" >}} 有两种方法可以将 `Rock

Re: [PR] [FLINK-34256][doc] Add a documentation section for minibatch join [flink]

2024-02-04 Thread via GitHub
xishuaidelin commented on code in PR #24240: URL: https://github.com/apache/flink/pull/24240#discussion_r1477696768 ## docs/content/docs/dev/table/tuning.md: ## @@ -266,5 +266,23 @@ GROUP BY day Flink SQL optimizer can recognize the different filter arguments on the same disti

Re: [PR] [FLINK-34247][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file [flink]

2024-02-04 Thread via GitHub
flinkbot commented on PR #24266: URL: https://github.com/apache/flink/pull/24266#issuecomment-1926262061 ## CI report: * 6def6ebc69b0b6568eec6897327e5d8aaa667110 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-32747][doc] Fix the wrong zh link for flink-configuration-file and repeated flink configuration file [flink]

2024-02-04 Thread via GitHub
1996fanrui commented on code in PR #24266: URL: https://github.com/apache/flink/pull/24266#discussion_r1477680165 ## docs/content.zh/docs/ops/state/state_backends.md: ## @@ -288,11 +288,11 @@ RocksDB State Backend 会将 [这里定义]({{< ref "docs/deployment/config" >}} 有两种方法可以将 `Rock

[jira] [Closed] (FLINK-34303) Release Testing Instructions: Verify FLINK-34054 Support named parameters for functions and procedures

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34303. --- Resolution: Fixed [~hackergin]Thanks for updating the test instructions! I've created a new jira to

[jira] [Commented] (FLINK-34348) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814157#comment-17814157 ] lincoln lee commented on FLINK-34348: - [~hackergin] Thank you for volunteering! Assi

[jira] [Assigned] (FLINK-34349) Release Testing: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34349: --- Assignee: xuyang > Release Testing: Verify FLINK-34219 Introduce a new join operator to sup

[jira] [Commented] (FLINK-34349) Release Testing: Verify FLINK-34219 Introduce a new join operator to support minibatch

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814158#comment-17814158 ] lincoln lee commented on FLINK-34349: - [~xuyangzhong] Thank you for volunteering! As

[jira] [Assigned] (FLINK-34348) Release Testing: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34348: --- Assignee: Feng Jin > Release Testing: Verify FLINK-20281 Window aggregation supports change

[jira] [Updated] (FLINK-34356) Release Testin: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34356: Description: This issue aims to verify FLIP-379. New Source can implement the interface DynamicPa

[jira] [Closed] (FLINK-34287) Release Testing Instructions: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34287. --- Resolution: Fixed > Release Testing Instructions: Verify FLINK-33768 Support dynamic source > para

[jira] [Created] (FLINK-34356) Release Testin: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
lincoln lee created FLINK-34356: --- Summary: Release Testin: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs Key: FLINK-34356 URL: https://issues.apache.org/jira/browse/FLINK-34356

[jira] [Assigned] (FLINK-34356) Release Testin: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34356: --- Assignee: (was: xingbe) > Release Testin: Verify FLINK-33768 Support dynamic source pa

[jira] [Comment Edited] (FLINK-34287) Release Testing Instructions: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814155#comment-17814155 ] lincoln lee edited comment on FLINK-34287 at 2/5/24 5:12 AM: -

[jira] [Updated] (FLINK-34355) Release Testing: Verify FLINK-34054 Support named parameters for functions and procedures

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34355: Description: Test suggestion: 1. Implement a test UDF or Procedure and support Named Parameters.

[jira] [Assigned] (FLINK-34355) Release Testing: Verify FLINK-34054 Support named parameters for functions and procedures

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34355: --- Assignee: (was: Feng Jin) > Release Testing: Verify FLINK-34054 Support named parameter

[jira] [Created] (FLINK-34355) Release Testing: Verify FLINK-34054 Support named parameters for functions and procedures

2024-02-04 Thread lincoln lee (Jira)
lincoln lee created FLINK-34355: --- Summary: Release Testing: Verify FLINK-34054 Support named parameters for functions and procedures Key: FLINK-34355 URL: https://issues.apache.org/jira/browse/FLINK-34355

[jira] [Closed] (FLINK-34301) Release Testing Instructions: Verify FLINK-20281 Window aggregation supports changelog stream input

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34301. --- Resolution: Fixed > Release Testing Instructions: Verify FLINK-20281 Window aggregation supports >

[jira] [Closed] (FLINK-34300) Release Testing Instructions: Verify FLINK-24024 Support session Window TVF

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34300. --- Resolution: Fixed > Release Testing Instructions: Verify FLINK-24024 Support session Window TVF > --

[jira] [Commented] (FLINK-34287) Release Testing Instructions: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814155#comment-17814155 ] lincoln lee commented on FLINK-34287: - [~xiasun] Thanks for updating the test instru

[jira] [Updated] (FLINK-34287) Release Testing Instructions: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34287: Attachment: screenshot-1.png > Release Testing Instructions: Verify FLINK-33768 Support dynamic s

[jira] [Commented] (FLINK-34287) Release Testing Instructions: Verify FLINK-33768 Support dynamic source parallelism inference for batch jobs

2024-02-04 Thread xingbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814154#comment-17814154 ] xingbe commented on FLINK-34287: This issue aims to verify [FLIP-379|https://cwiki.apac

Re: [PR] [FLINK-34256][doc] Add a documentation section for minibatch join [flink]

2024-02-04 Thread via GitHub
xishuaidelin commented on code in PR #24240: URL: https://github.com/apache/flink/pull/24240#discussion_r1477643284 ## docs/content/docs/dev/table/tuning.md: ## @@ -266,5 +266,23 @@ GROUP BY day Flink SQL optimizer can recognize the different filter arguments on the same disti

Re: [PR] [FLINK-34256][doc] Add a documentation section for minibatch join [flink]

2024-02-04 Thread via GitHub
xishuaidelin commented on code in PR #24240: URL: https://github.com/apache/flink/pull/24240#discussion_r1477643118 ## docs/content/docs/dev/table/tuning.md: ## @@ -266,5 +266,23 @@ GROUP BY day Flink SQL optimizer can recognize the different filter arguments on the same disti

Re: [PR] [FLINK-34256][doc] Add a documentation section for minibatch join [flink]

2024-02-04 Thread via GitHub
xishuaidelin commented on code in PR #24240: URL: https://github.com/apache/flink/pull/24240#discussion_r1477642832 ## docs/content.zh/docs/dev/table/tuning.md: ## @@ -259,5 +259,23 @@ GROUP BY day Flink SQL 优化器可以识别相同的 distinct key 上的不同过滤器参数。例如,在上面的示例中,三个 COUNT DISTINCT 都在 `

[jira] [Commented] (FLINK-34334) Add sub-task level RocksDB file count metric

2024-02-04 Thread Jufang He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814152#comment-17814152 ] Jufang He commented on FLINK-34334: --- [~masteryhx] could you take a look at this?  > A

[jira] [Commented] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

2024-02-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814151#comment-17814151 ] dalongliu commented on FLINK-34353: --- Merged in master branch: de2d175decce8defeb7931f4

[jira] [Closed] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

2024-02-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-34353. - Resolution: Fixed > A strange exception will be thrown if minibatch size is not set while using > mini-

Re: [PR] [FLINK-34353][table-planenr] Fix unclear exception without setting minibatch size when using minibatch join or agg [flink]

2024-02-04 Thread via GitHub
lsyldliu closed pull request #24264: [FLINK-34353][table-planenr] Fix unclear exception without setting minibatch size when using minibatch join or agg URL: https://github.com/apache/flink/pull/24264 -- This is an automated message from the Apache Git Service. To respond to the message, pleas

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
TimFruit commented on PR #24262: URL: https://github.com/apache/flink/pull/24262#issuecomment-1926173570 when to publish this fixed version, this really bothers me when i try to use flink 1.17 -- This is an automated message from the Apache Git Service. To respond to the message, please l

Re: [PR] [FLINK-33739][doc] Document FLIP-364: Improve the exponential-delay restart-strategy [flink]

2024-02-04 Thread via GitHub
zhuzhurk commented on code in PR #24263: URL: https://github.com/apache/flink/pull/24263#discussion_r1477630748 ## docs/content.zh/docs/ops/state/task_failure_recovery.md: ## @@ -294,7 +328,22 @@ env = StreamExecutionEnvironment.get_execution_environment(config) 使用群集定义的重启策略。

Re: [PR] [FLINK-34250] add config docs for formats [flink]

2024-02-04 Thread via GitHub
flinkbot commented on PR #24265: URL: https://github.com/apache/flink/pull/24265#issuecomment-1926153473 ## CI report: * 25be9a6db42e66d3add94cd08e6409b8b93c6f9a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-33734) Merge unaligned checkpoint state handle

2024-02-04 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813874#comment-17813874 ] Rui Fan edited comment on FLINK-33734 at 2/5/24 2:58 AM: - Thanks

[jira] [Updated] (FLINK-34250) Add formats options to docs

2024-02-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34250: --- Labels: pull-request-available (was: ) > Add formats options to docs >

[PR] [FLINK-34250] add config docs for formats [flink]

2024-02-04 Thread via GitHub
HuangZhenQiu opened a new pull request, #24265: URL: https://github.com/apache/flink/pull/24265 ## What is the purpose of the change Generate the doc sections for Flink format options. ## Brief change log 1. Add format packages ConfigurationOptionLocator 2. Generated html

Re: [PR] [FLINK-33981][runtime] Fix not closing DirectoryStream after listing local state files [flink]

2024-02-04 Thread via GitHub
fengjiajie commented on PR #24261: URL: https://github.com/apache/flink/pull/24261#issuecomment-1926120194 @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] [Closed] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration

2024-02-04 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li closed FLINK-33297. - Resolution: Fixed > FLIP-366: Support standard YAML for FLINK configuration > --

[jira] [Updated] (FLINK-33297) FLIP-366: Support standard YAML for FLINK configuration

2024-02-04 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-33297: -- Release Note: Starting with Flink-1.19, Flink has officially introduced full support for the standard

[jira] [Commented] (FLINK-34229) Duplicate entry in InnerClasses attribute in class file FusionStreamOperator

2024-02-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814144#comment-17814144 ] dalongliu commented on FLINK-34229: --- Merged in master branch: a603f2bb8536fa75453694a7

[jira] [Commented] (FLINK-34229) Duplicate entry in InnerClasses attribute in class file FusionStreamOperator

2024-02-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814143#comment-17814143 ] dalongliu commented on FLINK-34229: --- [~xiasun] This fix has been merged in master bran

[jira] [Closed] (FLINK-34247) Document FLIP-366: Support standard YAML for FLINK configuration

2024-02-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34247. --- Assignee: Junrui Li Resolution: Done master/release-1.19: 5b61baadd02ccdfa702834e2e63aeb8d1d9e1250 04d

Re: [PR] [FLINK-34247][doc] Document FLIP-366: Support standard YAML for FLINK configuration [flink]

2024-02-04 Thread via GitHub
zhuzhurk closed pull request #24251: [FLINK-34247][doc] Document FLIP-366: Support standard YAML for FLINK configuration URL: https://github.com/apache/flink/pull/24251 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-34323) Session window tvf failed when using named params

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-34323. - > Session window tvf failed when using named params > - > >

[jira] [Resolved] (FLINK-34323) Session window tvf failed when using named params

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan resolved FLINK-34323. --- Resolution: Fixed > Session window tvf failed when using named params >

[jira] [Commented] (FLINK-34323) Session window tvf failed when using named params

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814141#comment-17814141 ] Jane Chan commented on FLINK-34323: --- Fixed in master 6be30b167990c22765c244a703ab0424e

[jira] [Assigned] (FLINK-34323) Session window tvf failed when using named params

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan reassigned FLINK-34323: - Assignee: xuyang > Session window tvf failed when using named params >

Re: [PR] [FLINK-34323][table-planner] Fix param name in session window tvf when using named params [flink]

2024-02-04 Thread via GitHub
LadyForest merged PR #24243: URL: https://github.com/apache/flink/pull/24243 -- 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.ap

[jira] [Closed] (FLINK-34229) Duplicate entry in InnerClasses attribute in class file FusionStreamOperator

2024-02-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu closed FLINK-34229. - Fix Version/s: 1.19.0 Assignee: Dan Zou Resolution: Fixed > Duplicate entry in InnerClas

Re: [PR] [FLINK-34229][table] Set CodeGeneratorContext of outer class as ancestor context when generate inner classes to avoid naming conflicts [flink]

2024-02-04 Thread via GitHub
lsyldliu closed pull request #24228: [FLINK-34229][table] Set CodeGeneratorContext of outer class as ancestor context when generate inner classes to avoid naming conflicts URL: https://github.com/apache/flink/pull/24228 -- This is an automated message from the Apache Git Service. To respond

Re: [PR] [FLINK-34229][table] Set CodeGeneratorContext of outer class as ancestor context when generate inner classes to avoid naming conflicts [flink]

2024-02-04 Thread via GitHub
zoudan commented on code in PR #24228: URL: https://github.com/apache/flink/pull/24228#discussion_r1477566503 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/sort/SortCodeGenerator.scala: ## @@ -41,12 +41,22 @@ import scala.collection.mut

[jira] [Assigned] (FLINK-34353) A strange exception will be thrown if minibatch size is not set while using mini-batch join

2024-02-04 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-34353: - Assignee: xuyang > A strange exception will be thrown if minibatch size is not set while using

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-02-04 Thread via GitHub
snuyanzin commented on PR #24156: URL: https://github.com/apache/flink/pull/24156#issuecomment-1925915797 Yes, it's not marked as deprecated however for new functions it's better to follow new stack which is a result of FLIP-32 and FLIP-65. -- This is an automated message from the Ap

[jira] [Commented] (FLINK-33790) Upsert statement filter unique key field colume in mysql dielact

2024-02-04 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814125#comment-17814125 ] Jeyhun Karimov commented on FLINK-33790: Hi [~lijingwei.5018] thanks for reporti

[jira] [Commented] (FLINK-34035) when flinksql with group by partition field, some errors occured in jobmanager.log

2024-02-04 Thread Vallari Rastogi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814124#comment-17814124 ] Vallari Rastogi commented on FLINK-34035: - Hi [~hansonhe] . Are you working on

[jira] [Commented] (FLINK-34175) When meeting WindowedSliceAssigner, slice window agg registers an wrong timestamp timer

2024-02-04 Thread Vallari Rastogi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814123#comment-17814123 ] Vallari Rastogi commented on FLINK-34175: - Hi [~xuyangzhong]  Are you working o

Re: [PR] [FLINK-33396][table-planner] Fix table alias not be cleared in subquery [flink]

2024-02-04 Thread via GitHub
jeyhunkarimov commented on code in PR #24239: URL: https://github.com/apache/flink/pull/24239#discussion_r1477427252 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/RelTreeWriterImpl.scala: ## @@ -286,4 +297,45 @@ class RelTreeWriterIm

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-02-04 Thread via GitHub
jeyhunkarimov commented on PR #24156: URL: https://github.com/apache/flink/pull/24156#issuecomment-1925892580 Thanks @snuyanzin for the review. I will check the tests and add more [failing] tests.About the implementation doesn't follow new stack implementation, I havent noticed that my imp

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-02-04 Thread via GitHub
jeyhunkarimov commented on code in PR #24156: URL: https://github.com/apache/flink/pull/24156#discussion_r1477413831 ## docs/data/sql_functions.yml: ## @@ -377,6 +377,12 @@ string: - sql: SUBSTR(string, integer1[, integer2]) table: STRING.substr(INTEGER1[, INTEGER2])

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-02-04 Thread via GitHub
jeyhunkarimov commented on code in PR #24156: URL: https://github.com/apache/flink/pull/24156#discussion_r1477414392 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java: ## @@ -1174,6 +1174,148 @@ public static String t

Re: [PR] [FLINK-34111][table] Add JSON_QUOTE and JSON_UNQUOTE function [flink]

2024-02-04 Thread via GitHub
jeyhunkarimov commented on code in PR #24156: URL: https://github.com/apache/flink/pull/24156#discussion_r1477413831 ## docs/data/sql_functions.yml: ## @@ -377,6 +377,12 @@ string: - sql: SUBSTR(string, integer1[, integer2]) table: STRING.substr(INTEGER1[, INTEGER2])

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-04 Thread via GitHub
Zakelly commented on PR #24181: URL: https://github.com/apache/flink/pull/24181#issuecomment-1925818223 @fredia Thanks for your suggestions! I have addressed them, please take another look! Many thanks! -- This is an automated message from the Apache Git Service. To respond to the message

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-04 Thread via GitHub
Zakelly commented on code in PR #24181: URL: https://github.com/apache/flink/pull/24181#discussion_r1477353920 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/WithinCheckpointFileMergingSnapshotManager.java: ## @@ -50,6 +50,43 @@ public WithinCheck

[jira] [Resolved] (FLINK-34313) Update doc about session window tvf

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan resolved FLINK-34313. --- Resolution: Fixed > Update doc about session window tvf > --- > >

[jira] [Closed] (FLINK-34313) Update doc about session window tvf

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan closed FLINK-34313. - > Update doc about session window tvf > --- > > Key: FLINK-3

[jira] [Assigned] (FLINK-34313) Update doc about session window tvf

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan reassigned FLINK-34313: - Assignee: xuyang > Update doc about session window tvf > --- >

[jira] [Commented] (FLINK-34313) Update doc about session window tvf

2024-02-04 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814106#comment-17814106 ] Jane Chan commented on FLINK-34313: --- Fixed in master eff073ff1199acf0f26a0f04ede7d6928

Re: [PR] [FLINK-34313][doc] Update doc about session window tvf [flink]

2024-02-04 Thread via GitHub
LadyForest merged PR #24250: URL: https://github.com/apache/flink/pull/24250 -- 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.ap

[jira] [Closed] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-02-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan closed FLINK-34148. --- Resolution: Resolved > Potential regression (Jan. 13): stringWrite with Java8 >

  1   2   >