[jira] [Updated] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35145: -- Description: Currently, cluster termination may be blocked forever as there's no timeout for

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

2024-04-17 Thread Aleksandr Pilipenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838216#comment-17838216 ] Aleksandr Pilipenko commented on FLINK-35115: - Investigating further > Kinesis connector

[jira] [Updated] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-35145: -- Description: Currently, cluster termination may be blocked forever as there's no timeout for

[jira] [Commented] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838219#comment-17838219 ] Zhanghao Chen commented on FLINK-35145: --- [~fangyong] [~huweihua] WDYT about this? > Add timeout

[jira] [Created] (FLINK-35145) Add timeout for cluster termination

2024-04-17 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-35145: - Summary: Add timeout for cluster termination Key: FLINK-35145 URL: https://issues.apache.org/jira/browse/FLINK-35145 Project: Flink Issue Type:

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568937355 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568925383 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568925383 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

Re: [PR] [FLINK-35045][state] Introduce ForStFlinkFileSystem to support reading and writing with ByteBuffer [flink]

2024-04-17 Thread via GitHub
masteryhx commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1568923544 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java: ## @@ -0,0 +1,195 @@ +/* + *

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

2024-04-17 Thread Aleksandr Pilipenko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838206#comment-17838206 ] Aleksandr Pilipenko commented on FLINK-35115: - [~vadim.vararu] thank you for information.

[jira] [Comment Edited] (FLINK-35124) Connector Release Fails to run Checkstyle

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838203#comment-17838203 ] Danny Cranmer edited comment on FLINK-35124 at 4/17/24 1:57 PM: ok cool.

[jira] [Assigned] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19

2024-04-17 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-35134: --- Assignee: Hong Liang Teoh > Release flink-connector-elasticsearch vX.X.X for Flink

[jira] [Commented] (FLINK-35124) Connector Release Fails to run Checkstyle

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838203#comment-17838203 ] Danny Cranmer commented on FLINK-35124: --- ok cool. This sounds like a better fix. Btw I was

Re: [PR] [FLINK-35135][Connectors/Google Cloud PubSub] Drop support for Flink 1.17 [flink-connector-gcp-pubsub]

2024-04-17 Thread via GitHub
hlteoh37 commented on code in PR #25: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/25#discussion_r1568885448 ## .github/workflows/push_pr.yml: ## @@ -28,11 +28,9 @@ jobs: compile_and_test: strategy: matrix: - flink: [ 1.17-SNAPSHOT ] -

Re: [PR] [FLINK-35135][Connectors/Google Cloud PubSub] Drop support for Flink 1.17 [flink-connector-gcp-pubsub]

2024-04-17 Thread via GitHub
hlteoh37 commented on code in PR #25: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/25#discussion_r1568885448 ## .github/workflows/push_pr.yml: ## @@ -28,11 +28,9 @@ jobs: compile_and_test: strategy: matrix: - flink: [ 1.17-SNAPSHOT ] -

[jira] [Commented] (FLINK-35124) Connector Release Fails to run Checkstyle

2024-04-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838198#comment-17838198 ] Etienne Chauchot commented on FLINK-35124: -- Fount it ! The suppression.xml issue you mentioned

[jira] [Comment Edited] (FLINK-35124) Connector Release Fails to run Checkstyle

2024-04-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838195#comment-17838195 ] Etienne Chauchot edited comment on FLINK-35124 at 4/17/24 1:42 PM: --- To

[jira] [Commented] (FLINK-35124) Connector Release Fails to run Checkstyle

2024-04-17 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838195#comment-17838195 ] Etienne Chauchot commented on FLINK-35124: -- To be more precise, I meant: before function

[PR] [FLINK-35136] Bump connector version to 4.0, adapt CI workflows [flink-connector-hbase]

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

[jira] [Assigned] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33018: - Assignee: Ryan Skraba > GCP Pubsub >

[jira] [Updated] (FLINK-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

2024-04-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35136: --- Labels: pull-request-available (was: ) > Release flink-connector-hbase v4.0.0 for Flink

[jira] [Updated] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

2024-04-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35135: --- Labels: pull-request-available (was: ) > Release flink-connector-gcp-pubsub v3.1.0 for

[jira] [Commented] (FLINK-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838182#comment-17838182 ] Danny Cranmer commented on FLINK-35136: --- Thanks for picking this up [~ferenc-csaky] . I see that

[jira] [Updated] (FLINK-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35136: -- Fix Version/s: hbase-4.0.0 > Release flink-connector-hbase v4.0.0 for Flink 1.19 >

[PR] [FLINK-35135][Connectors/Google Cloud PubSub] Drop support for Flink 1.17 [flink-connector-gcp-pubsub]

2024-04-17 Thread via GitHub
dannycranmer opened a new pull request, #25: URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/25 Drop 1.17 runs from CI and bump default Flink version in pom -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35135: -- Fix Version/s: gcp-pubsub-3.1.0 > Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19 >

[jira] [Updated] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35135: -- Summary: Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19 (was: Release

[jira] [Updated] (FLINK-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35136: -- Summary: Release flink-connector-hbase v4.0.0 for Flink 1.19 (was: Release

[jira] [Commented] (FLINK-35124) Connector Release Fails to run Checkstyle

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838185#comment-17838185 ] Danny Cranmer commented on FLINK-35124: --- Thanks [~echauchot]. I believe it is possible to have

[jira] [Assigned] (FLINK-35135) Release flink-connector-gcp-pubsub vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35135: - Assignee: Danny Cranmer > Release flink-connector-gcp-pubsub vX.X.X for Flink 1.19 >

[jira] [Updated] (FLINK-35137) Release flink-connector-jdbc v3.2.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35137: -- Summary: Release flink-connector-jdbc v3.2.0 for Flink 1.19 (was: Release

[jira] [Commented] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838181#comment-17838181 ] Danny Cranmer commented on FLINK-35137: ---

[jira] [Assigned] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35136: - Assignee: Ferenc Csaky > Release flink-connector-hbase vX.X.X for Flink 1.19 >

Re: [PR] [FLINK-32877][Filesystem][Rebased] Add HTTP options to java-storage client [flink]

2024-04-17 Thread via GitHub
JTaky commented on PR #24673: URL: https://github.com/apache/flink/pull/24673#issuecomment-2061224047 @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-35116] Bump operator sdk version to 4.8.3 [flink-kubernetes-operator]

2024-04-17 Thread via GitHub
csviri commented on PR #816: URL: https://github.com/apache/flink-kubernetes-operator/pull/816#issuecomment-2061189575 > Together with the version bump, this workaround can also be removed I believe:

Re: [PR] [FLINK-35028][runtime] Timer firing under async execution model [flink]

2024-04-17 Thread via GitHub
fredia commented on code in PR #24672: URL: https://github.com/apache/flink/pull/24672#discussion_r1568752322 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/InternalTimerServiceAsyncImplTest.java: ## @@ -0,0 +1,219 @@ +/* + * Licensed to the

Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]

2024-04-17 Thread via GitHub
GOODBOY008 commented on code in PR #732: URL: https://github.com/apache/flink-web/pull/732#discussion_r1568758762 ## .github/workflows/docs.yml: ## @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

Re: [PR] [FLINK-35028][runtime] Timer firing under async execution model [flink]

2024-04-17 Thread via GitHub
fredia commented on code in PR #24672: URL: https://github.com/apache/flink/pull/24672#discussion_r1568731699 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java: ## @@ -117,6 +120,7 @@ public class

Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]

2024-04-17 Thread via GitHub
GOODBOY008 commented on code in PR #732: URL: https://github.com/apache/flink-web/pull/732#discussion_r1568682051 ## .github/workflows/docs.yml: ## @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

[jira] [Commented] (FLINK-34583) Bug for dynamic table option hints with multiple CTEs

2024-04-17 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838130#comment-17838130 ] xuyang commented on FLINK-34583: Hi, [~xccui] can you provide more details about this bug? I try to run

Re: [PR] [FLINK-34908][pipeline-connector][doris] Fix Mysql pipeline to doris will lost precision for timestamp [flink-cdc]

2024-04-17 Thread via GitHub
gong commented on PR #3207: URL: https://github.com/apache/flink-cdc/pull/3207#issuecomment-2061042815 @PatrickRen Hello, Please help to rerun CI. CI fail is not relation with the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]

2024-04-17 Thread via GitHub
MartijnVisser commented on code in PR #732: URL: https://github.com/apache/flink-web/pull/732#discussion_r1568720908 ## .github/workflows/docs.yml: ## @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See

Re: [PR] [FLINK-35120][doris] Add Doris integration test cases [flink-cdc]

2024-04-17 Thread via GitHub
leonardBang commented on PR #3227: URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2061013529 The CI failed, could you take a look ? @yuxiqian -- 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-34444] Initial implementation of JM operator metric rest api [flink]

2024-04-17 Thread via GitHub
afedulov commented on code in PR #24564: URL: https://github.com/apache/flink/pull/24564#discussion_r1568653505 ## docs/static/generated/rest_v1_dispatcher.yml: ## @@ -1089,6 +1089,37 @@ paths: application/json: schema: $ref:

[jira] [Created] (FLINK-35144) Support multi source sync for FlinkCDC

2024-04-17 Thread Congxian Qiu (Jira)
Congxian Qiu created FLINK-35144: Summary: Support multi source sync for FlinkCDC Key: FLINK-35144 URL: https://issues.apache.org/jira/browse/FLINK-35144 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35144) Support various sources sync for FlinkCDC in one pipeline

2024-04-17 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-35144: - Summary: Support various sources sync for FlinkCDC in one pipeline (was: Support various

Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]

2024-04-17 Thread via GitHub
GOODBOY008 commented on code in PR #732: URL: https://github.com/apache/flink-web/pull/732#discussion_r1568682051 ## .github/workflows/docs.yml: ## @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

Re: [PR] [FLINK-35120][doris] Add Doris integration test cases [flink-cdc]

2024-04-17 Thread via GitHub
yuxiqian commented on PR #3227: URL: https://github.com/apache/flink-cdc/pull/3227#issuecomment-2061021229 @leonardBang Seems it's `flink-cdc-pipeline-connector-values` test that keeps failing recently. Will investigate this. -- This is an automated message from the Apache Git Service.

Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]

2024-04-17 Thread via GitHub
fredia commented on PR #24667: URL: https://github.com/apache/flink/pull/24667#issuecomment-2060999083 @yunfengzhou-hub @Zakelly Thanks for the detailed review, I have rebased this PR and addressed some comments, PTAL if you are free. -- This is an automated message from the Apache Git

Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]

2024-04-17 Thread via GitHub
fredia commented on code in PR #24667: URL: https://github.com/apache/flink/pull/24667#discussion_r1568659638 ## flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java: ## @@ -181,4 +182,73 @@ public class ExecutionOptions {

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

2024-04-17 Thread Vadim Vararu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838121#comment-17838121 ] Vadim Vararu commented on FLINK-35115: -- [~a.pilipenko] Yes, I can reproduce this consistently.  

[jira] [Resolved] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

2024-04-17 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35025. - Resolution: Fixed > Wire AsyncExecutionController to AbstractStreamOperator >

Re: [PR] [FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added [flink-cdc]

2024-04-17 Thread via GitHub
yuxiqian commented on code in PR #3230: URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1568608219 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java: ## @@ -159,7

Re: [PR] [FLINK-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]

2024-04-17 Thread via GitHub
GOODBOY008 commented on code in PR #732: URL: https://github.com/apache/flink-web/pull/732#discussion_r1568682051 ## .github/workflows/docs.yml: ## @@ -0,0 +1,68 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

Re: [PR] [FLINK-34444] Initial implementation of JM operator metric rest api [flink]

2024-04-17 Thread via GitHub
afedulov commented on code in PR #24564: URL: https://github.com/apache/flink/pull/24564#discussion_r1568653505 ## docs/static/generated/rest_v1_dispatcher.yml: ## @@ -1089,6 +1089,37 @@ paths: application/json: schema: $ref:

Re: [PR] [FLINK-34615]Split `ExternalizedCheckpointCleanup` out of `Checkpoint… [flink]

2024-04-17 Thread via GitHub
spoon-lz commented on code in PR #24461: URL: https://github.com/apache/flink/pull/24461#discussion_r1568676454 ## flink-python/docs/reference/pyflink.datastream/checkpoint.rst: ## @@ -81,7 +81,7 @@ The default limit of concurrently happening checkpoints: one.

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-17 Thread via GitHub
masteryhx commented on PR #24651: URL: https://github.com/apache/flink/pull/24651#issuecomment-2060873955 Rebased again. -- 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

[jira] [Commented] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

2024-04-17 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838077#comment-17838077 ] Jiabao Sun commented on FLINK-35139: mongodb main: 660ffe4f33f3ce60da139159741644f48295652d >

[jira] [Commented] (FLINK-34936) Register reused state handles to FileMergingSnapshotManager

2024-04-17 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838092#comment-17838092 ] Zakelly Lan commented on FLINK-34936: - Merged into master via 31ea1a93 > Register reused state

Re: [PR] [FLINK-35028][runtime] Timer firing under async execution model [flink]

2024-04-17 Thread via GitHub
Zakelly commented on code in PR #24672: URL: https://github.com/apache/flink/pull/24672#discussion_r1568659887 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java: ## @@ -51,6 +52,21 @@ InternalTimerService

Re: [PR] [FLINK-35026][runtime][config] Introduce async execution configurations [flink]

2024-04-17 Thread via GitHub
fredia commented on code in PR #24667: URL: https://github.com/apache/flink/pull/24667#discussion_r1568656329 ## flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java: ## @@ -181,4 +182,73 @@ public class ExecutionOptions {

[jira] [Updated] (FLINK-35139) Release flink-connector-mongodb v1.2.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35139: -- Summary: Release flink-connector-mongodb v1.2.0 for Flink 1.19 (was: Release

[jira] [Commented] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19

2024-04-17 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838101#comment-17838101 ] Ferenc Csaky commented on FLINK-35136: -- Currently we have a v3.0.0 HBase connector release, that

[jira] [Updated] (FLINK-34214) FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34214: -- Fix Version/s: mongodb-1.3.0 (was: mongodb-1.2.0) > FLIP-377: Support

[jira] [Updated] (FLINK-35144) Support various source sync for FlinkCDC in one pipeline

2024-04-17 Thread Congxian Qiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu updated FLINK-35144: - Summary: Support various source sync for FlinkCDC in one pipeline (was: Support multi source

[jira] [Created] (FLINK-35143) Expose newly added tables capture in mysql pipeline connector

2024-04-17 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-35143: - Summary: Expose newly added tables capture in mysql pipeline connector Key: FLINK-35143 URL: https://issues.apache.org/jira/browse/FLINK-35143 Project: Flink

[jira] [Updated] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35137: -- Component/s: Connectors / JDBC > Release flink-connector-jdbc vX.X.X for Flink 1.19 >

[jira] [Commented] (FLINK-35025) Wire AsyncExecutionController to AbstractStreamOperator

2024-04-17 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838093#comment-17838093 ] Zakelly Lan commented on FLINK-35025: - Merged into master via c7be45d0...fe8dde4e > Wire

[jira] [Created] (FLINK-35142) Release flink-connector-rabbitmq vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35142: - Summary: Release flink-connector-rabbitmq vX.X.X for Flink 1.19 Key: FLINK-35142 URL: https://issues.apache.org/jira/browse/FLINK-35142 Project: Flink

[jira] [Resolved] (FLINK-34936) Register reused state handles to FileMergingSnapshotManager

2024-04-17 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-34936. - Resolution: Fixed > Register reused state handles to FileMergingSnapshotManager >

Re: [PR] [FLINK-35130][runtime] Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance [flink]

2024-04-17 Thread via GitHub
flinkbot commented on PR #24674: URL: https://github.com/apache/flink/pull/24674#issuecomment-2060781312 ## CI report: * 70df259709d9640d587eef6c257d9c812b8dfb38 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35139][Connectors/MongoDB] Drop support for Flink 1.17 [flink-connector-mongodb]

2024-04-17 Thread via GitHub
Jiabao-Sun merged PR #35: URL: https://github.com/apache/flink-connector-mongodb/pull/35 -- 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-35132) Release flink-connector-aws v4.3.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35132: -- Summary: Release flink-connector-aws v4.3.0 for Flink 1.19 (was: Release flink-connector-aws

Re: [PR] [FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added [flink-cdc]

2024-04-17 Thread via GitHub
loserwang1024 commented on code in PR #3230: URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1568614060 ## flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java: ## @@

[jira] [Commented] (FLINK-35139) Release flink-connector-mongodb v1.2.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838086#comment-17838086 ] Danny Cranmer commented on FLINK-35139: ---

[PR] Adding MongoDB Connector v1.2.0 [flink-web]

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

[jira] [Created] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35137: - Summary: Release flink-connector-jdbc vX.X.X for Flink 1.19 Key: FLINK-35137 URL: https://issues.apache.org/jira/browse/FLINK-35137 Project: Flink Issue

[PR] Adding JDBC Connector v3.2.0 [flink-web]

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

Re: [PR] [FLINK-35139][Connectors/MongoDB] Drop support for Flink 1.17 [flink-connector-mongodb]

2024-04-17 Thread via GitHub
boring-cyborg[bot] commented on PR #35: URL: https://github.com/apache/flink-connector-mongodb/pull/35#issuecomment-2060869153 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 log

[jira] [Updated] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35134: -- Summary: Release flink-connector-elasticsearch vX.X.X for Flink 1.19 (was: Release

[jira] [Updated] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30371: -- Fix Version/s: jdbc-3.3.0 (was: jdbc-3.2.0) > JdbcOutputFormat is at

[jira] [Updated] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35137: -- Fix Version/s: jdbc-3.2.0 > Release flink-connector-jdbc vX.X.X for Flink 1.19 >

[jira] [Updated] (FLINK-35130) Simplify AvailabilityNotifierImpl to support speculative scheduler and improve performance

2024-04-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35130: --- Labels: pull-request-available (was: ) > Simplify AvailabilityNotifierImpl to support

Re: [PR] [FLINK-34936][Checkpointing] Register reused shared state handle to FileMergingSnapshotManager [flink]

2024-04-17 Thread via GitHub
fredia merged PR #24644: URL: https://github.com/apache/flink/pull/24644 -- 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] [Assigned] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35137: - Assignee: Danny Cranmer > Release flink-connector-jdbc vX.X.X for Flink 1.19 >

[jira] [Assigned] (FLINK-35131) Support and Release Connectors for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35131: - Assignee: Danny Cranmer > Support and Release Connectors for Flink 1.19 >

Re: [PR] [FLINK-35025][Runtime/State] Abstract stream operators for async state processing [flink]

2024-04-17 Thread via GitHub
fredia merged PR #24657: URL: https://github.com/apache/flink/pull/24657 -- 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-34216) Support fine-grained configuration to control filter push down for MongoDB Connector

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34216: -- Fix Version/s: mongodb-1.3.0 (was: mongodb-1.2.0) > Support

[jira] [Updated] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35139: -- Fix Version/s: mongodb-1.2.0 > Release flink-connector-mongodb vX.X.X for Flink 1.19 >

[jira] [Updated] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

2024-04-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35139: --- Labels: pull-request-available (was: ) > Release flink-connector-mongodb vX.X.X for Flink

Re: [PR] [FLINK-34930] Fork existing code from bahir-flink [flink-connector-kudu]

2024-04-17 Thread via GitHub
ferenc-csaky commented on PR #1: URL: https://github.com/apache/flink-connector-kudu/pull/1#issuecomment-2060816220 > @ferenc-csaky I've asked the Legal team for a confirmation on this topic, since the ASF owns both Bahir and Flink code. You can track

Re: [PR] [FLINK-34987][state] Introduce Internal State for Async State API [flink]

2024-04-17 Thread via GitHub
masteryhx commented on PR #24651: URL: https://github.com/apache/flink/pull/24651#issuecomment-2060813581 @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

[jira] [Commented] (FLINK-35132) Release flink-connector-aws v4.3.0 for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838058#comment-17838058 ] Danny Cranmer commented on FLINK-35132: ---

[jira] [Assigned] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35139: - Assignee: Danny Cranmer > Release flink-connector-mongodb vX.X.X for Flink 1.19 >

[jira] [Assigned] (FLINK-35140) Release flink-connector-opensearch vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35140: - Assignee: Sergey Nuyanzin > Release flink-connector-opensearch vX.X.X for Flink 1.19 >

Re: [PR] [FLINK-34908][pipeline-connector][doris] Fix Mysql pipeline to doris will lost precision for timestamp [flink-cdc]

2024-04-17 Thread via GitHub
gong commented on code in PR #3207: URL: https://github.com/apache/flink-cdc/pull/3207#discussion_r1568504940 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/test/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverterTest.java:

[jira] [Created] (FLINK-35140) Release flink-connector-opensearch vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35140: - Summary: Release flink-connector-opensearch vX.X.X for Flink 1.19 Key: FLINK-35140 URL: https://issues.apache.org/jira/browse/FLINK-35140 Project: Flink

[jira] [Updated] (FLINK-35140) Release flink-connector-opensearch vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35140: -- Description: [https://github.com/apache/flink-connector-opensearch]   > Release

[jira] [Created] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35136: - Summary: Release flink-connector-hbase vX.X.X for Flink 1.19 Key: FLINK-35136 URL: https://issues.apache.org/jira/browse/FLINK-35136 Project: Flink Issue

[jira] [Created] (FLINK-35141) Release flink-connector-pulsar vX.X.X for Flink 1.19

2024-04-17 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35141: - Summary: Release flink-connector-pulsar vX.X.X for Flink 1.19 Key: FLINK-35141 URL: https://issues.apache.org/jira/browse/FLINK-35141 Project: Flink Issue

<    1   2   3   >