[jira] [Created] (FLINK-35417) JobManager and TaskManager support merging and run in a single process

2024-05-21 Thread melin (Jira)
melin created FLINK-35417: - Summary: JobManager and TaskManager support merging and run in a single process Key: FLINK-35417 URL: https://issues.apache.org/jira/browse/FLINK-35417 Project: Flink

Re: [PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
snuyanzin commented on code in PR #101: URL: https://github.com/apache/flink-connector-elasticsearch/pull/101#discussion_r1609293105 ## tools/maven/checkstyle.xml: ## @@ -224,10 +224,6 @@ This file is based on the checkstyle file of Apache Beam.

[jira] [Updated] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile

2024-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35416: --- Labels: pull-request-available (was: ) > Weekly CI for ElasticSearch connector failed to

[PR] [FLINK-35416][Connector/Elasticsearch] Remove the dependency on flink-shaded [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa opened a new pull request, #101: URL: https://github.com/apache/flink-connector-elasticsearch/pull/101 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-05-21 Thread via GitHub
snuyanzin commented on PR #24526: URL: https://github.com/apache/flink/pull/24526#issuecomment-2123898530 >@snuyanzin @MartijnVisser Why do we necessarily have to align our semantics with Snowflake? as it was mentioned above the main reason is that multi-set semantics (Snowflake)

Re: [PR] chore: Update pekko version [flink]

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

[PR] chore: Update pekko version [flink]

2024-05-21 Thread via GitHub
He-Pin opened a new pull request, #24823: URL: https://github.com/apache/flink/pull/24823 Motivation: Test Pekko 1.1.0-M1 Modification: The new pekko 1.1.0 is using Netty 4 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Comment Edited] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API

2024-05-21 Thread Simon Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847765#comment-17847765 ] Simon Lee edited comment on FLINK-35334 at 5/22/24 5:04 AM: Hi [~TsReaper] ,

Re: [PR] [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese [flink]

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

Re: [PR] [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese [flink]

2024-05-21 Thread via GitHub
drymatini commented on PR #24822: URL: https://github.com/apache/flink/pull/24822#issuecomment-2123859262 Hi @wuchong , I have finished the translation of the page.Could you please verify my pull request? -- This is an automated message from the Apache Git Service. To respond to the

[PR] [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese [flink]

2024-05-21 Thread via GitHub
drymatini opened a new pull request, #24822: URL: https://github.com/apache/flink/pull/24822 ## What is the purpose of the change "Profiler "page was released in English and it should be translated into Chineses ## Brief change log translate

Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]

2024-05-21 Thread via GitHub
ldadima commented on code in PR #24784: URL: https://github.com/apache/flink/pull/24784#discussion_r1609248919 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCustomRescaleITCase.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1609245158 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkWriter.java: ## @@ -0,0 +1,272 @@ +/* + *

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1609243592 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkBuilder.java: ## @@ -0,0 +1,161 @@ +/* + *

Re: [PR] [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese [flink]

2024-05-21 Thread via GitHub
drymatini closed pull request #24793: [FLINK-35353][docs-zh]Translate "Profiler" page into Chinese URL: https://github.com/apache/flink/pull/24793 -- 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

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1609241620 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkWriter.java: ## @@ -0,0 +1,272 @@ +/* + *

[jira] [Created] (FLINK-35416) Weekly CI for ElasticSearch connector failed to compile

2024-05-21 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35416: -- Summary: Weekly CI for ElasticSearch connector failed to compile Key: FLINK-35416 URL: https://issues.apache.org/jira/browse/FLINK-35416 Project: Flink Issue

Re: [PR] [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa closed pull request #21: [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter URL: https://github.com/apache/flink-connector-elasticsearch/pull/21 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa commented on PR #21: URL: https://github.com/apache/flink-connector-elasticsearch/pull/21#issuecomment-2123839960 I think we can open a new PR to deal with this, because it has been stale for too long. -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [FLINK-28109][connector/elasticsearch] Delete useful code in the row emitter [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa commented on PR #21: URL: https://github.com/apache/flink-connector-elasticsearch/pull/21#issuecomment-2123838824 Would you minding rebasing this on the latest main branch, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-28428][connectors/elasticsearch][docs][docs-zh] Fix example and Chinese translations [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa commented on PR #23: URL: https://github.com/apache/flink-connector-elasticsearch/pull/23#issuecomment-2123837897 I think we can close this first, because it has been stale for too long. Feel free to rebase/update and reopen this. -- This is an automated message from the Apache

Re: [PR] [FLINK-28428][connectors/elasticsearch][docs][docs-zh] Fix example and Chinese translations [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa closed pull request #23: [FLINK-28428][connectors/elasticsearch][docs][docs-zh] Fix example and Chinese translations URL: https://github.com/apache/flink-connector-elasticsearch/pull/23 -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
dependabot[bot] commented on PR #95: URL: https://github.com/apache/flink-connector-elasticsearch/pull/95#issuecomment-2123836152 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you'd rather skip all updates until the next major

Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa commented on PR #95: URL: https://github.com/apache/flink-connector-elasticsearch/pull/95#issuecomment-2123836129 We should discuss it before we upgrade, close for now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
reswqa closed pull request #95: Bump org.elasticsearch:elasticsearch from 7.10.2 to 7.17.19 in /flink-connector-elasticsearch-base URL: https://github.com/apache/flink-connector-elasticsearch/pull/95 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-35287. -- Resolution: Fixed > Builder builds NetworkConfig for Elasticsearch connector 8 >

[jira] [Commented] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848440#comment-17848440 ] Weijie Guo commented on FLINK-35287: main via 0b6d9f823d9831816a81d02c0c1f367746363688. > Builder

[jira] [Updated] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35287: --- Fix Version/s: elasticsearch-3.1.0 > Builder builds NetworkConfig for Elasticsearch connector 8 >

[jira] [Assigned] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

2024-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35287: -- Assignee: Mingliang Liu > Builder builds NetworkConfig for Elasticsearch connector 8 >

Re: [PR] [FLINK-35287] Builder builds NetworkConfig for Elasticsearch connector 8 [flink-connector-elasticsearch]

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

[jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19

2024-05-21 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848438#comment-17848438 ] Hongshun Wang commented on FLINK-35385: --- We can ensure multi-version compatibility for the

[jira] [Closed] (FLINK-34549) FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

2024-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-34549. -- Fix Version/s: 1.20.0 Resolution: Fixed > FLIP-410: Config, Context and Processing Timer

[jira] [Commented] (FLINK-34549) FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

2024-05-21 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848437#comment-17848437 ] Weijie Guo commented on FLINK-34549: master(1.20) via e502d2371ffea52ebfa6b8a1b9d2b4a23bc9bbaa. >

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

2024-05-21 Thread via GitHub
reswqa merged PR #24541: URL: https://github.com/apache/flink/pull/24541 -- 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:

[jira] [Updated] (FLINK-33461) Support streaming related semantics for the new JDBC source

2024-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33461: --- Labels: pull-request-available (was: ) > Support streaming related semantics for the new

Re: [PR] [FLINK-33461][Connector/JDBC] Support streaming related semantics for the new JDBC source [flink-connector-jdbc]

2024-05-21 Thread via GitHub
RocMarshal commented on PR #119: URL: https://github.com/apache/flink-connector-jdbc/pull/119#issuecomment-2123819801 Hi, @eskabetxe @leonardBang Could you help have a look if you had the free time ? Thank you. -- This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

2024-05-21 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848430#comment-17848430 ] Rui Fan commented on FLINK-35293: - [~xiasun] Thanks for the update! :) > FLIP-445: Support dynamic

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

2024-05-21 Thread via GitHub
Sxnan commented on PR #24541: URL: https://github.com/apache/flink/pull/24541#issuecomment-2123797964 @reswqa Thanks for the update! LGTM. -- 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

[jira] [Commented] (FLINK-35293) FLIP-445: Support dynamic parallelism inference for HiveSource

2024-05-21 Thread xingbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848426#comment-17848426 ] xingbe commented on FLINK-35293: [~fanrui] Sorry for my late reply. I have documented FLIP-445 in the

[jira] [Commented] (FLINK-35360) [Feature] Submit Flink CDC pipeline job yarn Application mode

2024-05-21 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848423#comment-17848423 ] ouyangwulin commented on FLINK-35360: - With many enterprises still running on yarn, this

Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]

2024-05-21 Thread via GitHub
jectpro7 commented on code in PR #24810: URL: https://github.com/apache/flink/pull/24810#discussion_r1609184018 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/SumAggregator.java: ## @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-32223][runtime][security] Add Hive delegation token support [flink]

2024-05-21 Thread via GitHub
wForget commented on PR #23127: URL: https://github.com/apache/flink/pull/23127#issuecomment-2123747309 I have a little confusion, why is it named with hiveserver2? It seems unrelated to hiveserver2. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-35337) Keep up with the latest version of tikv client

2024-05-21 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ouyangwulin closed FLINK-35337. --- Release Note: tikv version not supported Resolution: Won't Fix > Keep up with the latest

[jira] [Assigned] (FLINK-35415) CDC Fails to create sink with Flink 1.19

2024-05-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-35415: -- Assignee: yux > CDC Fails to create sink with Flink 1.19 >

Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-05-21 Thread via GitHub
liuyongvs commented on PR #24526: URL: https://github.com/apache/flink/pull/24526#issuecomment-2123732921 @snuyanzin @MartijnVisser Why do we necessarily have to align our semantics with Snowflake? i found spark/presto/doris/max_compute all follow the semantics without duplicate.

[jira] [Commented] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

2024-05-21 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848416#comment-17848416 ] Rui Fan commented on FLINK-35215: - Merged to master via: * 46db92641602313c4f5c1390807222c344880e2d *

[jira] [Updated] (FLINK-35215) The performance of serializerKryo and serializerKryoWithoutRegistration are regressed

2024-05-21 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-35215: Fix Version/s: 1.20.0 > The performance of serializerKryo and serializerKryoWithoutRegistration are >

Re: [PR] [FLINK-35347][table] Introduce inmemory scheduler service [flink]

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

Re: [PR] [FLINK-35215][core] Fix the bug when Kryo serialize length is 0 [flink]

2024-05-21 Thread via GitHub
1996fanrui merged PR #24717: URL: https://github.com/apache/flink/pull/24717 -- 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:

[jira] [Updated] (FLINK-35347) Implement InMemory workflow scheduler service and plugin to support materialized table

2024-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35347: --- Labels: pull-request-available (was: ) > Implement InMemory workflow scheduler service and

[PR] [FLINK-35347][table] Introduce inmemory scheduler service [flink]

2024-05-21 Thread via GitHub
lsyldliu opened a new pull request, #24821: URL: https://github.com/apache/flink/pull/24821 ## 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

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

2024-05-21 Thread via GitHub
reswqa commented on PR #24541: URL: https://github.com/apache/flink/pull/24541#issuecomment-2123714167 Thanks @Sxnan for the review! I have updated this PR according to your comments, PTAL again. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-35415) CDC Fails to create sink with Flink 1.19

2024-05-21 Thread yux (Jira)
yux created FLINK-35415: --- Summary: CDC Fails to create sink with Flink 1.19 Key: FLINK-35415 URL: https://issues.apache.org/jira/browse/FLINK-35415 Project: Flink Issue Type: Bug Components:

Re: [PR] [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0 [flink-cdc]

2024-05-21 Thread via GitHub
beryllw commented on code in PR #3335: URL: https://github.com/apache/flink-cdc/pull/3335#discussion_r1609145095 ## pom.xml: ## @@ -421,6 +421,7 @@ limitations under the License. **/.*/** **/target/** +

Re: [PR] [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0 [flink-cdc]

2024-05-21 Thread via GitHub
beryllw commented on PR #3335: URL: https://github.com/apache/flink-cdc/pull/3335#issuecomment-2123704754 > Does this error only affect local testing and does not affect running with jar? If it does not affect the operation after packaging, it can be ignored. OK, just affect local

[jira] [Commented] (FLINK-35385) upgrader flink dependency version to 1.19

2024-05-21 Thread yux (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848411#comment-17848411 ] yux commented on FLINK-35385: - Seems https://github.com/apache/flink-cdc/issues/3327 was caused by this

[jira] [Updated] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API

2024-05-21 Thread Simon Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Lee updated FLINK-35334: -- Affects Version/s: 1.18.1 1.19.0 > Code generation: init method exceeds 64 KB

Re: [PR] [FLINK-35287] Builder builds NetworkConfig for Elasticsearch connector 8 [flink-connector-elasticsearch]

2024-05-21 Thread via GitHub
liuml07 commented on PR #100: URL: https://github.com/apache/flink-connector-elasticsearch/pull/100#issuecomment-2123537876 @reswqa @MartijnVisser Could you help review? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1608980647 ## flink-connector-aws/flink-connector-sqs/src/test/java/org.apache.flink/connector.sqs/sink/SqsSinkITCase.java: ## @@ -0,0 +1,121 @@ +/* + *

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1608974641 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkWriter.java: ## @@ -0,0 +1,272 @@ +/* + *

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1608973555 ## flink-connector-aws/flink-connector-sqs/src/main/java/org.apache.flink.connector.sqs/sink/SqsSinkWriter.java: ## @@ -0,0 +1,272 @@ +/* + *

Re: [PR] [FLINK-35305]Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#issuecomment-2123460881 > Thanks for the efforts. Could we remove the ticket link from the PR title, it should be automatically linked using "Autolink" > > We need to add documentation

Re: [PR] [FLINK-35305](https://issues.apache.org/jira/browse/FLINK-35305)Amazon SQS Sink Connector [flink-connector-aws]

2024-05-21 Thread via GitHub
19priyadhingra commented on code in PR #141: URL: https://github.com/apache/flink-connector-aws/pull/141#discussion_r1608959583 ## flink-connector-aws/flink-connector-sqs/archunit-violations/stored.rules: ## @@ -0,0 +1,4 @@ +# +#Tue Feb 22 12:19:26 CET 2022 +Tests\ inheriting\

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

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

Re: [PR] [FLINK-33212][runtime] add job status changed listener for lineage [flink]

2024-05-21 Thread via GitHub
JingGe commented on PR #24754: URL: https://github.com/apache/flink/pull/24754#issuecomment-2122930606 @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-32706][table] Add built-in SPLIT_STRING function [flink]

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

[jira] [Commented] (FLINK-35388) Flink 1.18.1 get stuck after creating highly available job result storage directory

2024-05-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-35388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848259#comment-17848259 ] Pedro Mázala commented on FLINK-35388: -- I found this

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

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

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

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

[jira] [Resolved] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-35383. - Resolution: Fixed > Update compatibility matrix to include 1.19 release >

[jira] [Commented] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848246#comment-17848246 ] Hong Liang Teoh commented on FLINK-35383: - merged commit

[jira] [Commented] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848247#comment-17848247 ] Hong Liang Teoh commented on FLINK-35383: - merged commit

Re: [PR] [FLINK-35383][docs] Update compatibility matrix for 1.19 release [flink]

2024-05-21 Thread via GitHub
hlteoh37 merged PR #24803: URL: https://github.com/apache/flink/pull/24803 -- 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:

Re: [PR] [FLINK-35383][docs] Update compatibility matrix for 1.19 release [flink]

2024-05-21 Thread via GitHub
hlteoh37 merged PR #24804: URL: https://github.com/apache/flink/pull/24804 -- 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:

[jira] [Created] (FLINK-35414) Cancel jobs through rest api for last-state upgrades

2024-05-21 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-35414: -- Summary: Cancel jobs through rest api for last-state upgrades Key: FLINK-35414 URL: https://issues.apache.org/jira/browse/FLINK-35414 Project: Flink Issue Type:

[jira] [Commented] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

2024-05-21 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848233#comment-17848233 ] Ryan Skraba commented on FLINK-34513: - * 1.20 Java 8 / Test (module: table)

Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]

2024-05-21 Thread via GitHub
jectpro7 commented on code in PR #24810: URL: https://github.com/apache/flink/pull/24810#discussion_r1608402571 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/SumAggregator.java: ## @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [FLINK-35354] Support host mapping in Flink tikv cdc [flink-cdc]

2024-05-21 Thread via GitHub
Mrart commented on code in PR #3336: URL: https://github.com/apache/flink-cdc/pull/3336#discussion_r1608399656 ## flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TDBSourceOptions.java: ## @@ -82,10 +90,13

[jira] [Commented] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

2024-05-21 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848220#comment-17848220 ] Ryan Skraba commented on FLINK-35382: - Thanks for the fix!  I'm just noting this build failure from

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-21 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848217#comment-17848217 ] Ryan Skraba commented on FLINK-35342: - * 1.20 AdaptiveScheduler / Test (module: table)

[jira] [Commented] (FLINK-35380) ResumeCheckpointManuallyITCase hanging on tests

2024-05-21 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848218#comment-17848218 ] Ryan Skraba commented on FLINK-35380: - * 1.20 Java 11 / Test (module: tests)

[jira] [Commented] (FLINK-35002) GitHub action request timeout to ArtifactService

2024-05-21 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848216#comment-17848216 ] Ryan Skraba commented on FLINK-35002: - * 1.18 Java 8 / Compile

[jira] [Commented] (FLINK-34282) Create a release branch

2024-05-21 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848206#comment-17848206 ] lincoln lee commented on FLINK-34282: - One more item needed: Update upgrade compatibility table

[jira] [Created] (FLINK-35413) VertexFinishedStateCheckerTest causes exit 239

2024-05-21 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35413: --- Summary: VertexFinishedStateCheckerTest causes exit 239 Key: FLINK-35413 URL: https://issues.apache.org/jira/browse/FLINK-35413 Project: Flink Issue Type: Bug

Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to [flink]

2024-05-21 Thread via GitHub
davidradl commented on PR #24741: URL: https://github.com/apache/flink/pull/24741#issuecomment-2122617491 @reswqa I am not seeing the pr build running for this - so I can't see if it is clean -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to [flink]

2024-05-21 Thread via GitHub
davidradl commented on PR #24741: URL: https://github.com/apache/flink/pull/24741#issuecomment-2122610190 @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

Re: [PR] [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0 [flink-cdc]

2024-05-21 Thread via GitHub
lvyanquan commented on code in PR #3335: URL: https://github.com/apache/flink-cdc/pull/3335#discussion_r1608276042 ## pom.xml: ## @@ -421,6 +421,7 @@ limitations under the License. **/.*/** **/target/**

Re: [PR] [FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0 [flink-cdc]

2024-05-21 Thread via GitHub
lvyanquan commented on PR #3335: URL: https://github.com/apache/flink-cdc/pull/3335#issuecomment-2122565714 > PS: An error will be reported during local testing with a lower version of jdk (like jdk 1.8.0). Does it need to be fixed? > > ``` > [ERROR] Error: VM option 'UseG1GC' is

Re: [PR] [FLINK-33130]reuse source and sink operator io metrics for task [flink]

2024-05-21 Thread via GitHub
littleeleventhwolf commented on PR #23454: URL: https://github.com/apache/flink/pull/23454#issuecomment-2122552532 I experiment with a simple read-write job using the content of this PR, but I notice that the `Bytes Sent` and `Records Sent` metrics on the sink are doubled.

Re: [PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]

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

Re: [PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]

2024-05-21 Thread via GitHub
morazow commented on PR #24820: URL: https://github.com/apache/flink/pull/24820#issuecomment-2122530959 Uses changes from https://github.com/apache/flink/pull/24776, will rebase once that PR is merged -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-20402) Migrate test_tpch.sh

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

[PR] [FLINK-20402][e2e] Migrate test_tpch.sh [flink]

2024-05-21 Thread via GitHub
morazow opened a new pull request, #24820: URL: https://github.com/apache/flink/pull/24820 ## What is the purpose of the change Migrate `test_tpch.sh` bash based end-to-end tests to docker based FlinkContainers framework. ## Brief change log * Add Java ITCase using

Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to [flink]

2024-05-21 Thread via GitHub
davidradl commented on PR #24741: URL: https://github.com/apache/flink/pull/24741#issuecomment-2122517342 @reswqa I will fo the same for the [1.19 backport ](https://github.com/apache/flink/pull/24742) -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to [flink]

2024-05-21 Thread via GitHub
davidradl commented on PR #24741: URL: https://github.com/apache/flink/pull/24741#issuecomment-2122514623 @reswqa I have backported the test code as requested. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-05-21 Thread via GitHub
snuyanzin commented on PR #24526: URL: https://github.com/apache/flink/pull/24526#issuecomment-2122481259 Based on what I mentioned above how about following multi-set semantics like Snowflake by default then it will allow to cover more cases (with and without duplicates)?

Re: [PR] [FLINK-31664] Implement ARRAY_INTERSECT function [flink]

2024-05-21 Thread via GitHub
MartijnVisser commented on PR #24526: URL: https://github.com/apache/flink/pull/24526#issuecomment-2122443374 > I failed to find standard approach for collections like arrays (I mean in SQL Standard). Same. I don't think it's documented anywhere. So how do we come to a conclusion

[PR] [docs] Polish quickstart guide & migrate maven links from ververica to apache [flink-cdc]

2024-05-21 Thread via GitHub
yuxiqian opened a new pull request, #3343: URL: https://github.com/apache/flink-cdc/pull/3343 This PR: * Adds guide to provide excluded DB drivers in quickstart docs * Updates outdated maven jar links & move to `org.apache.flink` group ID -- This is an automated message from the

[jira] [Assigned] (FLINK-20402) Migrate test_tpch.sh

2024-05-21 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-20402: - Assignee: Muhammet Orazov > Migrate test_tpch.sh > > >

[jira] [Commented] (FLINK-35408) Add 30 min tolerance value when validating the time-zone setting

2024-05-21 Thread david radley (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848161#comment-17848161 ] david radley commented on FLINK-35408: -- some feedback: * I wonder why you need a 30 minute

  1   2   >