[jira] [Comment Edited] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819508#comment-17819508 ] Matthias Pohl edited comment on FLINK-29114 at 2/22/24 7:42 AM: --

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

2024-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819508#comment-17819508 ] Matthias Pohl commented on FLINK-29114: --- * https://github.com/apache/flink/action

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

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

[jira] [Created] (FLINK-34495) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34495: - Summary: Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failure Key: FLINK-34495 URL: https://issues.apache.org/jira/browse/FLINK-34495 Project:

[jira] [Commented] (FLINK-34424) BoundedBlockingSubpartitionWriteReadTest#testRead10ConsumersConcurrent times out

2024-02-21 Thread Yunfeng Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819495#comment-17819495 ] Yunfeng Zhou commented on FLINK-34424: -- Hi [~mapohl]  and [~pnowojski], [~tanyuxin]

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2024-02-21 Thread via GitHub
snuyanzin commented on PR #23960: URL: https://github.com/apache/flink/pull/23960#issuecomment-1958812264 @GOODBOY008 can you please double check that the amount of tests before this PR and after is still same? -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]

2024-02-21 Thread via GitHub
flinkbot commented on PR #24366: URL: https://github.com/apache/flink/pull/24366#issuecomment-1958766054 ## CI report: * 8ce3e530ab2aef4d06a98f3c0cfa55a49796deee UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2024-02-21 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819478#comment-17819478 ] Jinzhong Li commented on FLINK-18255: - [~yunta]  [~Yanfei Lei]    I have drafted a f

[jira] [Resolved] (FLINK-34458) Rename options for Generalized incremental checkpoints (changelog)

2024-02-21 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34458. -- Resolution: Fixed merged e7e973e2 into master. > Rename options for Generalized incremental c

Re: [PR] [FLINK-34458][checkpointing] Rename options for Generalized incremental checkpoints (changelog) [flink]

2024-02-21 Thread via GitHub
masteryhx closed pull request #24324: [FLINK-34458][checkpointing] Rename options for Generalized incremental checkpoints (changelog) URL: https://github.com/apache/flink/pull/24324 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]

2024-02-21 Thread via GitHub
zhengzhili333 opened a new pull request, #24366: URL: https://github.com/apache/flink/pull/24366 ## What is the purpose of the change *Currently, submitting a job starts with storing the JobGraph (in HA setups) in the JobGraphStore. This includes writing the file to S3 (or some other

[jira] [Resolved] (FLINK-29802) ChangelogStateBackend supports native savepoint

2024-02-21 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-29802. -- Fix Version/s: 1.20.0 (was: 1.19.0) Resolution: Fixed merged b62

Re: [PR] [FLINK-29802][state] Changelog supports native savepoint [flink]

2024-02-21 Thread via GitHub
masteryhx closed pull request #22744: [FLINK-29802][state] Changelog supports native savepoint URL: https://github.com/apache/flink/pull/22744 -- 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 spe

[jira] [Updated] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: This issue aims to verify [FLIP-398|https://cwiki.apache.org/confluence/display/

[jira] [Updated] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: This issue aims to verify [FLIP-398|https://cwiki.apache.org/confluence/display/

[jira] [Updated] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: This issue aims to verify [FLIP-398|[https://cwiki.apache.org/confluence/display

[jira] [Updated] (FLINK-34354) Release Testing: Verify FLINK-34037 Improve Serialization Configuration and Usage in Flink

2024-02-21 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-34354: -- Description: This issue aims to verify [FLIP-398|https://cwiki.apache.org/confluence/display/

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-02-21 Thread via GitHub
wanglijie95 commented on PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1958712785 @eskabetxe FYI, the failed tests should have been fixed in FLINK-34358 -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
mohitjain2504 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1498640212 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SplitFunction.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
mohitjain2504 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1498639719 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SplitFunction.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
mohitjain2504 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1498639316 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SplitFunction.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
mohitjain2504 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1498635291 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SplitFunction.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the A

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
mohitjain2504 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1498635291 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/SplitFunction.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the A

[jira] [Created] (FLINK-34494) Migrate ReplaceIntersectWithSemiJoinRule

2024-02-21 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34494: - Summary: Migrate ReplaceIntersectWithSemiJoinRule Key: FLINK-34494 URL: https://issues.apache.org/jira/browse/FLINK-34494 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34493) Migrate ReplaceMinusWithAntiJoinRule

2024-02-21 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34493: - Summary: Migrate ReplaceMinusWithAntiJoinRule Key: FLINK-34493 URL: https://issues.apache.org/jira/browse/FLINK-34493 Project: Flink Issue Type: Sub-task

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
flinkbot commented on PR #24365: URL: https://github.com/apache/flink/pull/24365#issuecomment-1958613193 ## CI report: * 67fb0726819a76eb0121a51bd3f2b2ded14c45bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
hanyuzheng7 opened a new pull request, #24365: URL: https://github.com/apache/flink/pull/24365 ## What is the purpose of the change This is an implementation of SPLIT ## Brief change log Splits a string into an array of substrings based on a delimiter. If the delimiter is no

Re: [PR] [FLINK-32706][table] Add built-in SPLIT_STRING function [flink]

2024-02-21 Thread via GitHub
hanyuzheng7 closed pull request #23108: [FLINK-32706][table] Add built-in SPLIT_STRING function URL: https://github.com/apache/flink/pull/23108 -- 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 sp

Re: [PR] [FLINK-33817][flink-protobuf] Set ReadDefaultValues=False by default in proto3 for performance improvement [flink]

2024-02-21 Thread via GitHub
libenchao commented on code in PR #24035: URL: https://github.com/apache/flink/pull/24035#discussion_r1498571218 ## docs/content/docs/connectors/table/formats/protobuf.md: ## @@ -149,9 +149,12 @@ Format Options false Boolean - This option only work

Re: [PR] [FLINK-29122][core] Improve robustness of FileUtils.expandDirectory() [flink]

2024-02-21 Thread via GitHub
anupamaggarwal closed pull request #24307: [FLINK-29122][core] Improve robustness of FileUtils.expandDirectory() URL: https://github.com/apache/flink/pull/24307 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

Re: [PR] [FLINK-34492][table] fix javadoc of comments. [flink]

2024-02-21 Thread via GitHub
flinkbot commented on PR #24364: URL: https://github.com/apache/flink/pull/24364#issuecomment-1958589343 ## CI report: * 591213a1a83e4fa146e8e449229962ebd4879e6b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34492) fix scala style comment link when migrate scala to java

2024-02-21 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jacky Lau updated FLINK-34492: -- Description:   scala [[org.apache.calcite.rel.rules.CalcMergeRule]] java  {@link org.apache.calcite.

[jira] [Updated] (FLINK-34492) fix scala style comment link when migrate scala to java

2024-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34492: --- Labels: pull-request-available (was: ) > fix scala style comment link when migrate scala to

[PR] [FLINK-34492][table] fix javadoc of comments. [flink]

2024-02-21 Thread via GitHub
liuyongvs opened a new pull request, #24364: URL: https://github.com/apache/flink/pull/24364 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Created] (FLINK-34492) fix scala style comment link when migrate scala to java

2024-02-21 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-34492: - Summary: fix scala style comment link when migrate scala to java Key: FLINK-34492 URL: https://issues.apache.org/jira/browse/FLINK-34492 Project: Flink Issue Type:

Re: [PR] [FLINK-29802][state] Changelog supports native savepoint [flink]

2024-02-21 Thread via GitHub
masteryhx commented on PR #22744: URL: https://github.com/apache/flink/pull/22744#issuecomment-1958565787 @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.

Re: [PR] [FLINK-34458][checkpointing] Rename options for Generalized incremental checkpoints (changelog) [flink]

2024-02-21 Thread via GitHub
Zakelly commented on PR #24324: URL: https://github.com/apache/flink/pull/24324#issuecomment-1958564217 @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] [Resolved] (FLINK-34457) Rename options for latency tracking

2024-02-21 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34457. -- Resolution: Fixed merged 6be297d1 into master. > Rename options for latency tracking > --

Re: [PR] [FLINK-34457][state] Rename options for latency tracking [flink]

2024-02-21 Thread via GitHub
masteryhx closed pull request #24323: [FLINK-34457][state] Rename options for latency tracking URL: https://github.com/apache/flink/pull/24323 -- 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 spe

[jira] [Closed] (FLINK-34383) Modify the comment with incorrect syntax

2024-02-21 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34383. --- Resolution: Won't Fix > Modify the comment with incorrect syntax >

Re: [PR] [FLINK-34383][Documentation] Modify the comment with incorrect syntax [flink]

2024-02-21 Thread via GitHub
zhuzhurk closed pull request #24273: [FLINK-34383][Documentation] Modify the comment with incorrect syntax URL: https://github.com/apache/flink/pull/24273 -- 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 g

Re: [PR] [FLINK-25537] [JUnit5 Migration] Module: flink-core package api-common [flink]

2024-02-21 Thread via GitHub
1996fanrui commented on code in PR #23960: URL: https://github.com/apache/flink/pull/23960#discussion_r1498532976 ## flink-core/src/test/java/org/apache/flink/api/common/state/StateDescriptorTest.java: ## @@ -247,22 +239,21 @@ public void go() { for (CheckedThread t : t

Re: [PR] [FLINK-34481][table] Migrate SetOpRewriteUtil to java [flink]

2024-02-21 Thread via GitHub
liuyongvs commented on code in PR #24358: URL: https://github.com/apache/flink/pull/24358#discussion_r1498518405 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/SetOpRewriteUtil.java: ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

2024-02-21 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819443#comment-17819443 ] Rui Fan commented on FLINK-34471: - Assuming ALL_TO_ALL in the first version is fine for

Re: [PR] [FLINK-29802][state] Changelog supports native savepoint [flink]

2024-02-21 Thread via GitHub
masteryhx commented on PR #22744: URL: https://github.com/apache/flink/pull/22744#issuecomment-1958500605 @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] [Updated] (FLINK-34491) Move from experimental support to production support for Java 17

2024-02-21 Thread Dhruv Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruv Patel updated FLINK-34491: Description: This task is to move away from experimental support for Java 17 to production support

[jira] [Updated] (FLINK-34491) Move from experimental support to production support for Java 17

2024-02-21 Thread Dhruv Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruv Patel updated FLINK-34491: Description: This task is to move away from experimental support for Java 17 to production suppor

[jira] [Updated] (FLINK-34491) Move from experimental support to production support for Java 17

2024-02-21 Thread Dhruv Patel (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruv Patel updated FLINK-34491: Description: This task is to move away from experimental support for Java 17 to production support

[jira] [Assigned] (FLINK-34265) Add the doc of named parameters

2024-02-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34265: --- Assignee: Feng Jin > Add the doc of named parameters > --- > >

[jira] [Created] (FLINK-34491) Move from experimental support to production support for Java 17

2024-02-21 Thread Dhruv Patel (Jira)
Dhruv Patel created FLINK-34491: --- Summary: Move from experimental support to production support for Java 17 Key: FLINK-34491 URL: https://issues.apache.org/jira/browse/FLINK-34491 Project: Flink

[jira] [Comment Edited] (FLINK-33728) Do not rewatch when KubernetesResourceManagerDriver watch fail

2024-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819433#comment-17819433 ] Xintong Song edited comment on FLINK-33728 at 2/22/24 1:21 AM: ---

[jira] [Closed] (FLINK-33728) Do not rewatch when KubernetesResourceManagerDriver watch fail

2024-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-33728. Fix Version/s: 1.19.0 Resolution: Done master (1.19): e7e31a99d6f93d4dadda21fbd1ebee079fe24

[jira] [Updated] (FLINK-33728) Do not rewatch when KubernetesResourceManagerDriver watch fail

2024-02-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-33728: - Fix Version/s: 1.20.0 (was: 1.19.0) > Do not rewatch when KubernetesResou

Re: [PR] [FLINK-33728] Do not rewatch when KubernetesResourceManagerDriver wat… [flink]

2024-02-21 Thread via GitHub
xintongsong closed pull request #24163: [FLINK-33728] Do not rewatch when KubernetesResourceManagerDriver wat… URL: https://github.com/apache/flink/pull/24163 -- 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

Re: [PR] [FLINK-33817][flink-protobuf] Set ReadDefaultValues=False by default in proto3 for performance improvement [flink]

2024-02-21 Thread via GitHub
sharath1709 commented on code in PR #24035: URL: https://github.com/apache/flink/pull/24035#discussion_r1498451041 ## docs/content/docs/connectors/table/formats/protobuf.md: ## @@ -149,9 +149,12 @@ Format Options false Boolean - This option only wo

Re: [PR] [FLINK-33817][flink-protobuf] Set ReadDefaultValues=False by default in proto3 for performance improvement [flink]

2024-02-21 Thread via GitHub
sharath1709 commented on code in PR #24035: URL: https://github.com/apache/flink/pull/24035#discussion_r1498449123 ## docs/content/docs/connectors/table/formats/protobuf.md: ## @@ -149,9 +149,12 @@ Format Options false Boolean - This option only wo

Re: [PR] Bump org.postgresql:postgresql from 42.5.4 to 42.6.1 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator]

2024-02-21 Thread via GitHub
dependabot[bot] commented on PR #779: URL: https://github.com/apache/flink-kubernetes-operator/pull/779#issuecomment-1958364283 Superseded by #780. -- 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 t

Re: [PR] Bump org.postgresql:postgresql from 42.5.4 to 42.6.1 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator]

2024-02-21 Thread via GitHub
dependabot[bot] closed pull request #779: Bump org.postgresql:postgresql from 42.5.4 to 42.6.1 in /flink-autoscaler-plugin-jdbc URL: https://github.com/apache/flink-kubernetes-operator/pull/779 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[PR] Bump org.postgresql:postgresql from 42.5.4 to 42.5.5 in /flink-autoscaler-plugin-jdbc [flink-kubernetes-operator]

2024-02-21 Thread via GitHub
dependabot[bot] opened a new pull request, #780: URL: https://github.com/apache/flink-kubernetes-operator/pull/780 Bumps [org.postgresql:postgresql](https://github.com/pgjdbc/pgjdbc) from 42.5.4 to 42.5.5. Changelog Sourced from https://github.com/pgjdbc/pgjdbc/blob/master/CHANGELO

[jira] [Comment Edited] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach

2024-02-21 Thread Alex Hoffer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819410#comment-17819410 ] Alex Hoffer edited comment on FLINK-34451 at 2/21/24 11:11 PM: ---

[jira] [Comment Edited] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach

2024-02-21 Thread Alex Hoffer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819410#comment-17819410 ] Alex Hoffer edited comment on FLINK-34451 at 2/21/24 11:10 PM: ---

[jira] [Comment Edited] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach

2024-02-21 Thread Alex Hoffer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819410#comment-17819410 ] Alex Hoffer edited comment on FLINK-34451 at 2/21/24 11:10 PM: ---

[jira] [Commented] (FLINK-34451) [Kubernetes Operator] Job with restarting TaskManagers uses wrong/misleading fallback approach

2024-02-21 Thread Alex Hoffer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819410#comment-17819410 ] Alex Hoffer commented on FLINK-34451: -   # Here is my FlinkDeployment: {code:java

[jira] [Updated] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

2024-02-21 Thread Eddie Ramirez (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eddie Ramirez updated FLINK-34490: -- Description: When using AWS credential chaining, `{{{}flink-connector-kinesis{}}}` does not c

Re: [PR] [FLINK-33517] Implement restore tests for Values node [flink]

2024-02-21 Thread via GitHub
bvarghese1 commented on PR #24114: URL: https://github.com/apache/flink/pull/24114#issuecomment-1958172227 > lgtm % CI failure Fixed. CI has passed. -- 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

[jira] [Updated] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

2024-02-21 Thread Eddie Ramirez (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eddie Ramirez updated FLINK-34490: -- Description: When using AWS credential chaining, `{{{}flink-connector-kinesis{}}}` does not c

[jira] [Created] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

2024-02-21 Thread Eddie Ramirez (Jira)
Eddie Ramirez created FLINK-34490: - Summary: flink-connector-kinesis not correctly supporting credential chaining Key: FLINK-34490 URL: https://issues.apache.org/jira/browse/FLINK-34490 Project: Flink

Re: [PR] [FLINK-34469][table] Implement TableDistribution toString [flink]

2024-02-21 Thread via GitHub
JingGe commented on code in PR #24338: URL: https://github.com/apache/flink/pull/24338#discussion_r1498379848 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableDistribution.java: ## @@ -142,4 +142,9 @@ && getBucketCount().get() != 0) {

Re: [PR] [FLINK-34469][table] Implement TableDistribution toString [flink]

2024-02-21 Thread via GitHub
JingGe commented on code in PR #24338: URL: https://github.com/apache/flink/pull/24338#discussion_r1498379848 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableDistribution.java: ## @@ -142,4 +142,9 @@ && getBucketCount().get() != 0) {

Re: [PR] [FLINK-34481][table] Migrate SetOpRewriteUtil to java [flink]

2024-02-21 Thread via GitHub
JingGe commented on code in PR #24358: URL: https://github.com/apache/flink/pull/24358#discussion_r1498366852 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/SetOpRewriteUtil.java: ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache Sof

Re: [PR] [FLINK-34477][table] Support capture groups in REGEXP_REPLACE [flink]

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

[jira] [Updated] (FLINK-34477) support capture groups in REGEXP_REPLACE

2024-02-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34477: --- Labels: pull-request-available (was: ) > support capture groups in REGEXP_REPLACE > ---

[PR] [FLINK-34477][table] Support capture groups in REGEXP_REPLACE [flink]

2024-02-21 Thread via GitHub
jeyhunkarimov opened a new pull request, #24363: URL: https://github.com/apache/flink/pull/24363 ## What is the purpose of the change Support capture groups in REGEXP_REPLACE ## Brief change log - Added support for capture groups by skipping the dollar sign - Adjus

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

2024-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819362#comment-17819362 ] Sergey Nuyanzin commented on FLINK-34148: - Seems I didn't get your initial quest

[jira] [Commented] (FLINK-34399) Release Testing: Verify FLINK-33644 Make QueryOperations SQL serializable

2024-02-21 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819354#comment-17819354 ] Ferenc Csaky commented on FLINK-34399: -- Executed the following test scenarios: # S

Re: [PR] [FLINK-31664][table]Add ARRAY_INTERSECT function [flink]

2024-02-21 Thread via GitHub
hanyuzheng7 commented on PR #23171: URL: https://github.com/apache/flink/pull/23171#issuecomment-1957585378 @dawidwys @liuyongvs Ok -- 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 co

Re: [PR] [FLINK-31663][table] Add ARRAY_EXCEPT function [flink]

2024-02-21 Thread via GitHub
bvarghese1 closed pull request #22588: [FLINK-31663][table] Add ARRAY_EXCEPT function URL: https://github.com/apache/flink/pull/22588 -- 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

[jira] [Comment Edited] (FLINK-34489) New File Sink end-to-end test timed out

2024-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819313#comment-17819313 ] Matthias Pohl edited comment on FLINK-34489 at 2/21/24 4:22 PM: --

[jira] [Commented] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

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

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

2024-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819316#comment-17819316 ] Matthias Pohl commented on FLINK-34202: --- The following CI failures didn't include

[jira] [Commented] (FLINK-29114) TableSourceITCase#testTableHintWithLogicalTableScanReuse sometimes fails with result mismatch

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

[jira] [Commented] (FLINK-34489) New File Sink end-to-end test timed out

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

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

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

[jira] [Commented] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

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

[jira] [Created] (FLINK-34489) New File Sink end-to-end test timed out

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34489: - Summary: New File Sink end-to-end test timed out Key: FLINK-34489 URL: https://issues.apache.org/jira/browse/FLINK-34489 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

2024-02-21 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819306#comment-17819306 ] Maximilian Michels commented on FLINK-34471: I think in addition to the fine

[jira] [Updated] (FLINK-34471) Tune network memory as part of Autoscaler Memory Tuning

2024-02-21 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-34471: --- Summary: Tune network memory as part of Autoscaler Memory Tuning (was: Tune the net

[jira] [Updated] (FLINK-34471) Tune the network memory in Autoscaler

2024-02-21 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-34471: --- Summary: Tune the network memory in Autoscaler (was: Tune the network memroy in Aut

Re: [PR] [FLINK-34152] Tune all directly observable memory types [flink-kubernetes-operator]

2024-02-21 Thread via GitHub
mxm commented on PR #778: URL: https://github.com/apache/flink-kubernetes-operator/pull/778#issuecomment-1957044189 @1996fanrui I've addressed your comments. Please have another look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-34363] Set artifact version to $project_version if $FLINK_VERSION is not set [flink-connector-shared-utils]

2024-02-21 Thread via GitHub
zentol commented on code in PR #38: URL: https://github.com/apache/flink-connector-shared-utils/pull/38#discussion_r1497786866 ## _utils.sh: ## @@ -68,4 +68,15 @@ function set_pom_version { new_version=$1 ${MVN} org.codehaus.mojo:versions-maven-plugin:2.8.1:set -DnewVe

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

2024-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34202. --- Fix Version/s: 1.19.0 1.17.3 1.18.2 Resolution:

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

2024-02-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819278#comment-17819278 ] Matthias Pohl commented on FLINK-34202: --- Thanks Lorenzo for looking into it. I gue

[jira] [Created] (FLINK-34488) Integrate snapshot deployment into GHA nightly workflow

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34488: - Summary: Integrate snapshot deployment into GHA nightly workflow Key: FLINK-34488 URL: https://issues.apache.org/jira/browse/FLINK-34488 Project: Flink Iss

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

2024-02-21 Thread Lorenzo Affetti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819273#comment-17819273 ] Lorenzo Affetti edited comment on FLINK-34202 at 2/21/24 2:18 PM:

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

2024-02-21 Thread Lorenzo Affetti (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819273#comment-17819273 ] Lorenzo Affetti commented on FLINK-34202: - [~mapohl] thanks for pointing that ou

[jira] [Created] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

2024-02-21 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34487: - Summary: Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow Key: FLINK-34487 URL: https://issues.apache.org/jira/browse/FLINK-34487 P

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

2024-02-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819269#comment-17819269 ] Robert Metzger commented on FLINK-34148: Thanks, but how does the broken shading

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

2024-02-21 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819267#comment-17819267 ] Sergey Nuyanzin commented on FLINK-34148: - [~rmetzger] yes, there is FLINK-34234

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

2024-02-21 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819265#comment-17819265 ] Robert Metzger commented on FLINK-34148: Thanks for addressing this issue. Maybe

Re: [PR] [FLINK-34331][ci] Adds reusable workflow that is used to load the runner configuration based on the projects owner [flink]

2024-02-21 Thread via GitHub
flinkbot commented on PR #24362: URL: https://github.com/apache/flink/pull/24362#issuecomment-1956693550 ## CI report: * 75374e85405a03ac08ae1d9cdd227b52d3e0f9ec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   3   >