Re: [PR] [FLINK-32513][core] Add predecessor caching [flink]

2024-03-20 Thread via GitHub
zhuzhurk commented on code in PR #24475: URL: https://github.com/apache/flink/pull/24475#discussion_r1533318682 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/transformations/GetTransitivePredecessorsTest.java: ## @@ -0,0 +1,147 @@ +/* + * Licensed to the A

[jira] [Commented] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Chloe He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829398#comment-17829398 ] Chloe He commented on FLINK-34898: -- [~liyubin117] Yes this does work for me, but this g

[jira] [Created] (FLINK-34901) Improve the performance of the update Postgres database

2024-03-20 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-34901: --- Summary: Improve the performance of the update Postgres database Key: FLINK-34901 URL: https://issues.apache.org/jira/browse/FLINK-34901 Project: Flink Issue T

Re: [PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-03-20 Thread via GitHub
czy006 commented on code in PR #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1533316957 ## flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/utils/HikariJDBCUtil.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to t

Re: [PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-03-20 Thread via GitHub
czy006 commented on code in PR #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785#discussion_r1533316345 ## flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/utils/HikariJDBCUtil.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to t

[jira] [Commented] (FLINK-34725) Dockerfiles for release publishing has incorrect config.yaml path

2024-03-20 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829394#comment-17829394 ] lincoln lee commented on FLINK-34725: - Thanks for fixing this! > Dockerfiles for re

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-20 Thread via GitHub
lincoln-lil commented on PR #24517: URL: https://github.com/apache/flink/pull/24517#issuecomment-2011312055 @masteryhx thank you! Another input: there was no snapshot file generated for this case related data directory in previous releases, so I'm a bit skeptical that it's due to other

[jira] [Closed] (FLINK-34725) Dockerfiles for release publishing has incorrect config.yaml path

2024-03-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-34725. --- Resolution: Fixed master: 3f4a80989fe7243983926f09fac2283f6fa63693 release-1.19: f53c5628e43777b4b924ec81224

Re: [PR] [FLINK-34725][dist] Fix wrong config file dir when `config-parser-utils.sh` script attempt to retrieve the Java Home. [flink]

2024-03-20 Thread via GitHub
zhuzhurk closed pull request #24527: [FLINK-34725][dist] Fix wrong config file dir when `config-parser-utils.sh` script attempt to retrieve the Java Home. URL: https://github.com/apache/flink/pull/24527 -- This is an automated message from the Apache Git Service. To respond to the message, pl

[jira] [Assigned] (FLINK-34731) Remove SpeculativeScheduler and incorporate its features into AdaptiveBatchScheduler

2024-03-20 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-34731: --- Assignee: Junrui Li > Remove SpeculativeScheduler and incorporate its features into > AdaptiveBatc

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-20 Thread via GitHub
masteryhx commented on code in PR #24381: URL: https://github.com/apache/flink/pull/24381#discussion_r1533247878 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java: ## @@ -177,20 +177,44 @@ public boolean isCheckpointingEnabled

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-20 Thread via GitHub
Zakelly commented on code in PR #24381: URL: https://github.com/apache/flink/pull/24381#discussion_r1533244572 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java: ## @@ -177,20 +177,44 @@ public boolean isCheckpointingEnabled()

[jira] [Resolved] (FLINK-34647) Path normalization is allocation intensive

2024-03-20 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34647. -- Fix Version/s: 1.20.0 Assignee: David Schlosnagle Resolution: Fixed Merged 321

Re: [PR] [FLINK-34647][core] Optimize Path normalization [flink]

2024-03-20 Thread via GitHub
masteryhx closed pull request #24473: [FLINK-34647][core] Optimize Path normalization URL: https://github.com/apache/flink/pull/24473 -- 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

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-20 Thread via GitHub
masteryhx commented on code in PR #24381: URL: https://github.com/apache/flink/pull/24381#discussion_r1533238343 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java: ## @@ -177,20 +177,44 @@ public boolean isCheckpointingEnabled

[jira] [Comment Edited] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

2024-03-20 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829374#comment-17829374 ] Jacky Lau edited comment on FLINK-34702 at 3/21/24 4:32 AM:

[jira] [Comment Edited] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

2024-03-20 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829374#comment-17829374 ] Jacky Lau edited comment on FLINK-34702 at 3/21/24 4:31 AM:

[jira] [Commented] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

2024-03-20 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829374#comment-17829374 ] Jacky Lau commented on FLINK-34702: --- When opting for Solution 3, it was found to be un

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-20 Thread via GitHub
masteryhx commented on PR #24517: URL: https://github.com/apache/flink/pull/24517#issuecomment-2011189235 > @masteryhx I've tried manually regenerate the specified test `mvn clean package -Pgenerate-migration-test-data -Dgenerate.classes=StatefulJobSnapshotMigrationITCase -Dgenerate.version

[jira] [Commented] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829371#comment-17829371 ] Yubin Li commented on FLINK-34898: -- I use the latest version to run the syntax and work

[jira] [Updated] (FLINK-34900) Check compatibility for classes in flink-core-api that skip japicmp

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34900: --- Description: As we said in FLINK-34899, some classes are temporarily ignored by japicmp. Before the

[jira] [Updated] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-34898: - Attachment: image-2024-03-21-12-00-00-183.png > Cannot create named STRUCT with a single field > ---

[jira] [Assigned] (FLINK-34899) Include all classes in flink-core-api that skip the japicmp check back

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-34899: -- Assignee: Weijie Guo > Include all classes in flink-core-api that skip the japicmp check back

[jira] [Created] (FLINK-34900) Check compatibility for classes in flink-core-api that skip japicmp

2024-03-20 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-34900: -- Summary: Check compatibility for classes in flink-core-api that skip japicmp Key: FLINK-34900 URL: https://issues.apache.org/jira/browse/FLINK-34900 Project: Flink

[jira] [Closed] (FLINK-26088) Add Elasticsearch 8.0 support

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-26088. -- Fix Version/s: elasticsearch-3.1.0 Resolution: Done main via 963c5058c9821682d76d9033a3417dfdb5

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-03-20 Thread via GitHub
boring-cyborg[bot] commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-2011167239 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-03-20 Thread via GitHub
reswqa merged PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53 -- 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-unsubs

[jira] [Updated] (FLINK-34899) Include all classes in flink-core-api that skip the japicmp check back

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34899: --- Description: We have moved some classes from flink-core to flink-core-api without changing the pack

[jira] [Updated] (FLINK-34899) Include all classes in flink-core-api that skip the japicmp check back

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34899: --- Summary: Include all classes in flink-core-api that skip the japicmp check back (was: Remove all cl

[jira] [Updated] (FLINK-34899) Remove all classes that skip the japicmp check for flink-core-api

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34899: --- Description: We have moved some classes from flink-core to flink-core-api without changing the pack

[jira] [Updated] (FLINK-34899) Remove all classes that skip the japicmp check for flink-core-api

2024-03-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-34899: --- Description: We have moved some classes from flink-core to flink-core-api without changing the pack

[jira] [Created] (FLINK-34899) Remove all classes that skip the japicmp check for flink-core-api

2024-03-20 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-34899: -- Summary: Remove all classes that skip the japicmp check for flink-core-api Key: FLINK-34899 URL: https://issues.apache.org/jira/browse/FLINK-34899 Project: Flink

Re: [PR] [FLINK-34668][checkpoint] Report state handle of file merging directory to JM [flink]

2024-03-20 Thread via GitHub
Zakelly commented on code in PR #24513: URL: https://github.com/apache/flink/pull/24513#discussion_r1533201932 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/filemerging/SegmentFileStateHandle.java: ## @@ -62,19 +77,58 @@ public class SegmentFileStateHandle implem

Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_optoins [flink-cdc]

2024-03-20 Thread via GitHub
SML0127 commented on PR #3148: URL: https://github.com/apache/flink-cdc/pull/3148#issuecomment-2011101317 @ruanhang1993 PTAL -- 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] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Chloe He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898 ] Chloe He deleted comment on FLINK-34898: -- was (Author: JIRAUSER304541): I also can't wrap this in an ARRAY like so {code:java} SELECT * FROM (VALUES ARRAY[CAST((1, 2) as ROW)] ); {code} Th

[jira] [Commented] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Chloe He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829349#comment-17829349 ] Chloe He commented on FLINK-34898: -- I also can't wrap this in an ARRAY like so {code:ja

Re: [PR] [FLINK-34526][runtime] Actively disconnect the TM in RM to reduce restart time [flink]

2024-03-20 Thread via GitHub
qinf commented on PR #24539: URL: https://github.com/apache/flink/pull/24539#issuecomment-2011045063 @1996fanrui @RocMarshal Could you help review this PR in your free time? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] Flink 34770 [flink-cdc]

2024-03-20 Thread via GitHub
lvyanquan closed pull request #3183: Flink 34770 URL: https://github.com/apache/flink-cdc/pull/3183 -- 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: issu

[jira] [Updated] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Chloe He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chloe He updated FLINK-34898: - Description: I'm trying to create named structs using Flink SQL and I found a previous ticket https://i

[jira] [Created] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Chloe He (Jira)
Chloe He created FLINK-34898: Summary: Cannot create named STRUCT with a single field Key: FLINK-34898 URL: https://issues.apache.org/jira/browse/FLINK-34898 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-34898) Cannot create named STRUCT with a single field

2024-03-20 Thread Chloe He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chloe He updated FLINK-34898: - Description: I'm trying to create named structs using Flink SQL and I found a previous ticket https://i

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

2024-03-20 Thread via GitHub
liuyongvs commented on PR #23171: URL: https://github.com/apache/flink/pull/23171#issuecomment-2011038228 hi @dawidwys will you help review this https://github.com/apache/flink/pull/24526 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-34732][cdc][ci] Add document dead link check for Flink CDC Documentation [flink-cdc]

2024-03-20 Thread via GitHub
GOODBOY008 commented on PR #3168: URL: https://github.com/apache/flink-cdc/pull/3168#issuecomment-2011028273 @PatrickRen Rebased to master , PTAL -- 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 t

[jira] [Commented] (FLINK-33220) PyFlink support for Datagen connector

2024-03-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829346#comment-17829346 ] Dian Fu commented on FLINK-33220: - [~liu.chong]  I missed this ticket. Feel free to subm

[jira] [Comment Edited] (FLINK-33220) PyFlink support for Datagen connector

2024-03-20 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829346#comment-17829346 ] Dian Fu edited comment on FLINK-33220 at 3/21/24 1:24 AM: -- [~li

Re: [PR] [Improve][pipeline]Support set checkpoint. [flink-cdc]

2024-03-20 Thread via GitHub
lightzhao commented on PR #3101: URL: https://github.com/apache/flink-cdc/pull/3101#issuecomment-2011007376 @leonardBang PTAL. -- 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] [Bug][pipeline]Set default values for the parallelism. [flink-cdc]

2024-03-20 Thread via GitHub
lightzhao commented on PR #3100: URL: https://github.com/apache/flink-cdc/pull/3100#issuecomment-2011007083 @leonardBang PTAL. -- 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-34701) Publish the Dockerfiles for the new release

2024-03-20 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34701. --- Resolution: Fixed > Publish the Dockerfiles for the new release > --

[jira] [Commented] (FLINK-34701) Publish the Dockerfiles for the new release

2024-03-20 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829340#comment-17829340 ] lincoln lee commented on FLINK-34701: - merged in [{{official-images}}|https://githu

Re: [PR] [FLINK-34892][ci] Fix python test failure due to config file change [flink-connector-aws]

2024-03-20 Thread via GitHub
dannycranmer commented on PR #133: URL: https://github.com/apache/flink-connector-aws/pull/133#issuecomment-2010729129 Thanks @z3d1k. Waiting for actions to complete before merge -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

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

2024-03-20 Thread via GitHub
hanyuzheng7 commented on code in PR #24365: URL: https://github.com/apache/flink/pull/24365#discussion_r1532815010 ## flink-python/pyflink/table/expression.py: ## @@ -1609,6 +1609,17 @@ def array_min(self) -> 'Expression': """ return _unary_op("arrayMin")(self)

Re: [PR] [FLINK-27146] [Filesystem] Migrate to Junit5 [flink]

2024-03-20 Thread via GitHub
kottmann commented on PR #22789: URL: https://github.com/apache/flink/pull/22789#issuecomment-2010479115 @ferenc-csaky Thank you for your insightful feedback and for directing me towards the assertj decision. I updated my branch by rebasing it onto master and incorporating the changes rela

Re: [PR] [FLINK-26570][statefun] Remote module configuration interpolation [flink-statefun]

2024-03-20 Thread via GitHub
nicklester commented on PR #309: URL: https://github.com/apache/flink-statefun/pull/309#issuecomment-2010471575 I still see value in this PR. When deploying into a managed environment such as Kinesis Data Analytics on AWS it is not possible to use something like 'jar -uf' to modify the jar

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

2024-03-20 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829246#comment-17829246 ] Galen Warren commented on FLINK-34696: -- I'm not aware of any special considerations

[jira] [Commented] (FLINK-34706) Promote release 1.19

2024-03-20 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829244#comment-17829244 ] lincoln lee commented on FLINK-34706: - # (/) Website pull request to [list the rele

Re: [PR] [FLINK-34706][docs] Add 1.19 to PreviousDocs list. [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24548: URL: https://github.com/apache/flink/pull/24548#issuecomment-2010028945 ## CI report: * d73fe76e42235b2ddc1937b70c1f1b4eaf5aa38c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34706][docs] Deprecates 1.17 docs. [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24547: URL: https://github.com/apache/flink/pull/24547#issuecomment-2010015809 ## CI report: * aea991f5e66edb1f26c7ef16e71c564083b58a73 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

2024-03-20 Thread Simon-Shlomo Poil (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829228#comment-17829228 ] Simon-Shlomo Poil edited comment on FLINK-34696 at 3/20/24 4:22 PM: --

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

2024-03-20 Thread Simon-Shlomo Poil (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829228#comment-17829228 ] Simon-Shlomo Poil commented on FLINK-34696: --- I checked using the CLI gcloud s

[jira] [Closed] (FLINK-34713) Updates the docs stable version

2024-03-20 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34713. --- Resolution: Fixed Already fixed by 3d67a2b9b208ed662f81c1ef43d76d10a82a7d88 on release-1.19 branch

Re: [PR] [FLINK-34712][release] Generate reference data for state migration tests based on release-1.19.0 [flink]

2024-03-20 Thread via GitHub
lincoln-lil commented on PR #24517: URL: https://github.com/apache/flink/pull/24517#issuecomment-2009918611 @masteryhx I've tried manually regenerate the specified test `mvn clean package -Pgenerate-migration-test-data -Dgenerate.classes=StatefulJobSnapshotMigrationITCase -Dgenerate.ver

Re: [PR] [FLINK-34893] Bump checkstyle to 9.3 [flink]

2024-03-20 Thread via GitHub
snuyanzin commented on code in PR #24540: URL: https://github.com/apache/flink/pull/24540#discussion_r1532320054 ## tools/maven/checkstyle.xml: ## @@ -238,16 +238,9 @@ This file is based on the checkstyle file of Apache Beam. Review Comment:

Re: [PR] [FLINK-34897][test] Enables JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip again. [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24546: URL: https://github.com/apache/flink/pull/24546#issuecomment-2009806089 ## CI report: * 234bd00f873cb44f04131539ecae98ef7d2d9b9d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34897) JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip needs to be enabled again

2024-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34897: --- Labels: pull-request-available (was: ) > JobMasterServiceLeadershipRunnerTest#testJobMaster

[PR] [FLINK-34897][test] Enables JobMasterServiceLeadershipRunnerTest#test… [flink]

2024-03-20 Thread via GitHub
XComp opened a new pull request, #24546: URL: https://github.com/apache/flink/pull/24546 … ## 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

[jira] [Created] (FLINK-34897) JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip needs to be enabled again

2024-03-20 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34897: - Summary: JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip needs to be enabled again Key: FLINK-34897 URL: https:

[jira] [Assigned] (FLINK-34897) JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLeadershipRunnerCloseWhenElectionServiceGrantLeaderShip needs to be enabled again

2024-03-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34897: - Assignee: Matthias Pohl > JobMasterServiceLeadershipRunnerTest#testJobMasterServiceLead

Re: [PR] [FLINK-34893] Bump checkstyle to 9.3 [flink]

2024-03-20 Thread via GitHub
RyanSkraba commented on code in PR #24540: URL: https://github.com/apache/flink/pull/24540#discussion_r1532074768 ## tools/maven/checkstyle.xml: ## @@ -238,16 +238,9 @@ This file is based on the checkstyle file of Apache Beam. -

Re: [PR] [FLINK-34893] Bump checkstyle to 9.3 [flink]

2024-03-20 Thread via GitHub
RyanSkraba commented on code in PR #24540: URL: https://github.com/apache/flink/pull/24540#discussion_r1532031293 ## tools/maven/checkstyle.xml: ## @@ -238,16 +238,9 @@ This file is based on the checkstyle file of Apache Beam. Review Comment:

[jira] [Closed] (FLINK-34745) Parsing temporal table join throws cryptic exceptions

2024-03-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-34745. Resolution: Fixed Fixed in 4142c4386a92f1ec5016583f4832f8869782765e > Parsing temporal ta

Re: [PR] [FLINK-34745] Improve validations for a period in Time Travel [flink]

2024-03-20 Thread via GitHub
dawidwys merged PR #24534: URL: https://github.com/apache/flink/pull/24534 -- 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.apac

Re: [PR] [FLINK-34896][table] Migrate CorrelateSortToRankRule to java [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24545: URL: https://github.com/apache/flink/pull/24545#issuecomment-2009564801 ## CI report: * 83bedd5de8ddc74d3095feb937b1728b611db4a1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34896) Migrate CorrelateSortToRankRule

2024-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34896: --- Labels: pull-request-available (was: ) > Migrate CorrelateSortToRankRule >

[PR] [FLINK-34896][table] Migrate CorrelateSortToRankRule to java [flink]

2024-03-20 Thread via GitHub
snuyanzin opened a new pull request, #24545: URL: https://github.com/apache/flink/pull/24545 ## What is the purpose of the change A bit reasoning for the change >The reason is that since 1.28.0 ( [CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core t

[jira] [Created] (FLINK-34896) Mi

2024-03-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34896: --- Summary: Mi Key: FLINK-34896 URL: https://issues.apache.org/jira/browse/FLINK-34896 Project: Flink Issue Type: Sub-task Reporter: Sergey Nu

[jira] [Assigned] (FLINK-34896) Migrate CorrelateSortToRankRule

2024-03-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-34896: --- Assignee: Sergey Nuyanzin > Migrate CorrelateSortToRankRule > -

[jira] [Updated] (FLINK-34896) Migrate CorrelateSortToRankRule

2024-03-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-34896: Summary: Migrate CorrelateSortToRankRule (was: Mi) > Migrate CorrelateSortToRankRule > --

Re: [PR] [FLINK-34239][core] Add copy() method for SerializerConfig [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24544: URL: https://github.com/apache/flink/pull/24544#issuecomment-2009531400 ## CI report: * 3d3ca469055b60fe00261751c3cb86c988c7c7bf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

2024-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34239: --- Labels: pull-request-available (was: ) > Introduce a deep copy method of SerializerConfig f

[PR] [FLINK-34239][core] Add copy() method for SerializerConfig [flink]

2024-03-20 Thread via GitHub
kumar-mallikarjuna opened a new pull request, #24544: URL: https://github.com/apache/flink/pull/24544 ## What is the purpose of the change `org.apache.flink.table.catalog.DataTypeFactoryImpl#createSerializerConfig` is currently manually making a copy of a `SerializerConfig` ob

Re: [PR] [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24543: URL: https://github.com/apache/flink/pull/24543#issuecomment-2009485635 ## CI report: * 7dc3990422cb330fb1aa8fcdd50872f74dcb283e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2024-03-20 Thread via GitHub
mtfelisb commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-2009477539 > Thanks @mtfelisb, looks good to me. Could you please rebase and squash all commits? Thank you for the review, @reswqa! Just did it :) -- This is an automat

[PR] [FLINK-34895][table] Migrate FlinkRewriteSubQueryRule to java [flink]

2024-03-20 Thread via GitHub
snuyanzin opened a new pull request, #24543: URL: https://github.com/apache/flink/pull/24543 ## What is the purpose of the change A bit reasoning for the change >The reason is that since 1.28.0 ( [CALCITE-4787](https://issues.apache.org/jira/browse/CALCITE-4787) - Move core t

[jira] [Created] (FLINK-34895) Migrate FlinkRewriteSubQueryRule

2024-03-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34895: --- Summary: Migrate FlinkRewriteSubQueryRule Key: FLINK-34895 URL: https://issues.apache.org/jira/browse/FLINK-34895 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-34895) Migrate FlinkRewriteSubQueryRule

2024-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34895: --- Labels: pull-request-available (was: ) > Migrate FlinkRewriteSubQueryRule > ---

[PR] [FLINK-34549][API] Introduce config, context and processingTimerService for DataStream API V2 [flink]

2024-03-20 Thread via GitHub
reswqa opened a new pull request, #24541: URL: https://github.com/apache/flink/pull/24541 ## What is the purpose of the change *Implementation of FLIP-410. This PR will Introduce config, context and processingTimerService for DataStream API V2.* ## Brief change log

[jira] [Updated] (FLINK-34894) Migrate JoinDependentConditionDerivationRule

2024-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34894: --- Labels: pull-request-available (was: ) > Migrate JoinDependentConditionDerivationRule > ---

[jira] [Updated] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-03-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34672: -- Affects Version/s: 1.19.0 1.17.2 1.20.0 > HA dea

Re: [PR] [FLINK-34894][table] Migrate JoinDependentConditionDerivationRule to java [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24542: URL: https://github.com/apache/flink/pull/24542#issuecomment-2009455915 ## CI report: * 564b0ac7360a5212a2a22bce9968c2dbe71bcc1b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34549][API] Introduce config, context and processingTimerService for DataStream API V2 [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24541: URL: https://github.com/apache/flink/pull/24541#issuecomment-2009426855 ## CI report: * 08547b7fa9baa619ec7b62bc893ccc6abcc86bb3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-20 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828930#comment-17828930 ] Ryan Skraba commented on FLINK-34643: - * [https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-34770) Unify download links of legacy connector to fat jar

2024-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34770: --- Labels: pull-request-available (was: ) > Unify download links of legacy connector to fat ja

[PR] [FLINK-34893] Bump checkstyle to 9.3 [flink]

2024-03-20 Thread via GitHub
snuyanzin opened a new pull request, #24540: URL: https://github.com/apache/flink/pull/24540 ## What is the purpose of the change The issue with current checkstyle is that there is checkstyle IntellijIdea plugin And recently it dropped checkstyle 8 support [1] At

Re: [PR] Backport translated Chinese docs in master to release-3.0 branch [flink-cdc]

2024-03-20 Thread via GitHub
leonardBang merged PR #3179: URL: https://github.com/apache/flink-cdc/pull/3179 -- 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

[jira] [Created] (FLINK-34893) Bump Checkstyle to 9+

2024-03-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34893: --- Summary: Bump Checkstyle to 9+ Key: FLINK-34893 URL: https://issues.apache.org/jira/browse/FLINK-34893 Project: Flink Issue Type: Bug Compone

[jira] [Created] (FLINK-34894) Migrate JoinDependentConditionDerivationRule

2024-03-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34894: --- Summary: Migrate JoinDependentConditionDerivationRule Key: FLINK-34894 URL: https://issues.apache.org/jira/browse/FLINK-34894 Project: Flink Issue Type

Re: [PR] [FLINK-34892][ci] Fix python test failure due to config file change [flink-connector-aws]

2024-03-20 Thread via GitHub
z3d1k commented on code in PR #133: URL: https://github.com/apache/flink-connector-aws/pull/133#discussion_r1531899935 ## flink-python/dev/integration_test.sh: ## @@ -41,10 +41,5 @@ FLINK_PYTHON_DIR=$(dirname "$CURRENT_DIR") # set the FLINK_TEST_LIB_DIR to "/flink-connector-a

[PR] [FLINK-34892][ci] Fix python test failure due to config file change [flink-connector-aws]

2024-03-20 Thread via GitHub
z3d1k opened a new pull request, #133: URL: https://github.com/apache/flink-connector-aws/pull/133 ## Purpose of the change Removing `pyflink_gateway_server.py` override after Flink 1.19.0 release to support configuration file change. Override was initially introduced [here](https

Re: [PR] [FLINK-34526][runtime] Actively disconnect the TM in RM to reduce restart time [flink]

2024-03-20 Thread via GitHub
flinkbot commented on PR #24539: URL: https://github.com/apache/flink/pull/24539#issuecomment-2009214558 ## CI report: * f4747e921f746298229adde25eefcb9f2b8e0cf4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2024-03-20 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17828931#comment-17828931 ] Ryan Skraba commented on FLINK-34718: - * [https://dev.azure.com/apache-flink/apache

  1   2   3   4   5   6   >