[jira] [Commented] (FLINK-34644) RestServerEndpointITCase.testShouldWaitForHandlersWhenClosing failed with ConnectionClosedException

2024-04-17 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838232#comment-17838232 ] Ryan Skraba commented on FLINK-34644: - 1.20 Java 21: Test (module: core) https://gi

[jira] [Commented] (FLINK-35041) IncrementalRemoteKeyedStateHandleTest.testSharedStateReRegistration failed

2024-04-17 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838233#comment-17838233 ] Ryan Skraba commented on FLINK-35041: - 1.20 Java 8: Test (module: core) https://git

[jira] [Commented] (FLINK-34646) AggregateITCase.testDistinctWithRetract timed out

2024-04-17 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838231#comment-17838231 ] Ryan Skraba commented on FLINK-34646: - 1.18 AdaptiveScheduler: Test (module: table)

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

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35115: -- Affects Version/s: aws-connector-4.2.0 aws-connector-4.1.0

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

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35115: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > Kinesis

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

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35115: -- Fix Version/s: aws-connector-4.2.0 > Kinesis connector writes wrong Kinesis sequence number at

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

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35115: -- Affects Version/s: 1.17.2 1.15.4 > Kinesis connector writes wrong Kines

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

2024-04-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35115: -- Priority: Blocker (was: Major) > Kinesis connector writes wrong Kinesis sequence number at st

[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&focusedCommentId=17838224#comment-17838224 ] Danny Cranmer commented on FLINK-35124: --- Actually I still think this is the issue,

[jira] [Assigned] (FLINK-35125) Implement ValueState for ForStStateBackend

2024-04-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-35125: Assignee: Jinzhong Li > Implement ValueState for ForStStateBackend >

[jira] [Resolved] (FLINK-34987) Introduce Internal State Interface for Async State API

2024-04-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34987. -- Fix Version/s: 1.20.0 Resolution: Fixed merged 7699a0d2...2c5078bc into master > Intro

[jira] [Commented] (FLINK-33394) DataGeneratorSourceITCase.testGatedRateLimiter fails on AZP

2024-04-17 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838223#comment-17838223 ] Ryan Skraba commented on FLINK-33394: - This should be closed as a duplicate of FLINK

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

2024-04-17 Thread via GitHub
masteryhx closed pull request #24651: [FLINK-34987][state] Introduce Internal State for Async State API URL: https://github.com/apache/flink/pull/24651 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[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&focusedCommentId=17838216#comment-17838216 ] Aleksandr Pilipenko commented on FLINK-35115: - Investigating further > Kine

[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&focusedCommentId=17838219#comment-17838219 ] Zhanghao Chen commented on FLINK-35145: --- [~fangyong] [~huweihua] WDYT about this?

[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: Improvement

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&focusedCommentId=17838206#comment-17838206 ] Aleksandr Pilipenko commented on FLINK-35115: - [~vadim.vararu] thank you for

[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&focusedCommentId=17838203#comment-17838203 ] Danny Cranmer edited comment on FLINK-35124 at 4/17/24 1:57 PM: --

[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&focusedCommentId=17838203#comment-17838203 ] Danny Cranmer commented on FLINK-35124: --- ok cool. This sounds like a better fix. B

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&focusedCommentId=17838198#comment-17838198 ] Etienne Chauchot commented on FLINK-35124: -- Fount it ! The suppression.xml issu

[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&focusedCommentId=17838195#comment-17838195 ] Etienne Chauchot edited comment on FLINK-35124 at 4/17/24 1:42 PM: ---

[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&focusedCommentId=17838195#comment-17838195 ] Etienne Chauchot commented on FLINK-35124: -- To be more precise, I meant: before

[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 un

[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 > PubSubConsumingTest.testStoppingConnectorWhenDese

[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 1.1

[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 Flin

[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&focusedCommentId=17838182#comment-17838182 ] Danny Cranmer commented on FLINK-35136: --- Thanks for picking this up [~ferenc-csaky

[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 u

[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 flink-connect

[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 flink-connector-hb

[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&focusedCommentId=17838185#comment-17838185 ] Danny Cranmer commented on FLINK-35124: --- Thanks [~echauchot]. I believe it is poss

[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 flink-connector-jdb

[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&focusedCommentId=17838181#comment-17838181 ] Danny Cranmer commented on FLINK-35137: --- https://lists.apache.org/thread/q6dmc5dbz

[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. To

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: [726e484](https://github.com/apache/flink-kubernetes-operator/commit/726e484c6a9b412156382

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 Apach

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 InternalTimerServiceImp

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&focusedCommentId=17838130#comment-17838130 ] xuyang commented on FLINK-34583: Hi, [~xccui] can you provide more details about this bu

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 t

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 ab

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: '#/compo

[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: Improvemen

[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 source

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. To

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 Se

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&focusedCommentId=17838121#comment-17838121 ] Vadim Vararu commented on FLINK-35115: -- [~a.pilipenko] Yes, I can reproduce this co

[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: '#/compo

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. CheckpointCon

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&focusedCommentId=17838077#comment-17838077 ] Jiabao Sun commented on FLINK-35139: mongodb main: 660ffe4f33f3ce60da139159741644f48

[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&focusedCommentId=17838092#comment-17838092 ] Zakelly Lan commented on FLINK-34936: - Merged into master via 31ea1a93 > Register r

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 getInternalT

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 flink-connector-

[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&focusedCommentId=17838101#comment-17838101 ] Ferenc Csaky commented on FLINK-35136: -- Currently we have a v3.0.0 HBase connector

[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 f

[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 sy

[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&focusedCommentId=17838093#comment-17838093 ] Zakelly Lan commented on FLINK-35025: - Merged into master via c7be45d0...fe8dde4e >

[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 Issu

[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: issues-unsubscr

[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: ## @@ -15

[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&focusedCommentId=17838086#comment-17838086 ] Danny Cranmer commented on FLINK-35139: --- https://lists.apache.org/thread/s18g7obgp

[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 unsubscribe,

[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 Ty

[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 unsubscribe,

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 o

[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 flink-conn

[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 ri

[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 specu

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: issues-unsubscr...@flink.apache

[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: issues-unsubscr...@flink.apache

<    1   2   3   >