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

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

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

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

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

[ 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] [Commented] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

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

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

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]

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-34953][ci] Add github ci for flink-web to auto commit build files [flink-web]

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

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

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

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

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

Re: [PR] [FLINK-35116] Bump operator sdk version to 4.8.3 [flink-kubernetes-operator]

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:

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

[ 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] [Updated] (FLINK-35137) Release flink-connector-jdbc v3.2.0 for Flink 1.19

[ 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] [Assigned] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19

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

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

[ 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] [Comment Edited] (FLINK-35124) Connector Release Fails to run Checkstyle

[ 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] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ 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] [Commented] (FLINK-35145) Add timeout for cluster termination

[ 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] [Updated] (FLINK-35145) Add timeout for cluster termination

[ 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] [Created] (FLINK-35145) Add timeout for cluster termination

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:

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

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

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

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

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

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-35125) Implement ValueState for ForStStateBackend

[ 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] [Commented] (FLINK-34646) AggregateITCase.testDistinctWithRetract timed out

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838238#comment-17838238 ] Ryan Skraba commented on FLINK-35041: - 1.20 test_ci_core

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

[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838277#comment-17838277 ] Etienne Chauchot edited comment on FLINK-35124 at 4/17/24 4:21 PM: --- It

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

[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838277#comment-17838277 ] Etienne Chauchot commented on FLINK-35124: -- It was failing on cassandra before the _utils.sh

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

[ 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] [Updated] (FLINK-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

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

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

[ 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] [Assigned] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19

[ 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] [Updated] (FLINK-35145) Add timeout for cluster termination

[ 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] [Updated] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838224#comment-17838224 ] Danny Cranmer commented on FLINK-35124: --- Actually I still think this is the issue, since it runs

[jira] [Created] (FLINK-35146) CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan

Ryan Skraba created FLINK-35146: --- Summary: CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan Key: FLINK-35146 URL: https://issues.apache.org/jira/browse/FLINK-35146 Project: Flink

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

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

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

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 @@ +/* + *

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

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]

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 @@ +/* + *

[jira] [Commented] (FLINK-31421) DataGeneratorSourceITCase.testGatedRateLimiter failed on CI

[ https://issues.apache.org/jira/browse/FLINK-31421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838234#comment-17838234 ] Ryan Skraba commented on FLINK-31421: - 1.19 Hadoop 3.1.3: Test (module: misc)

[jira] [Updated] (FLINK-35146) CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan

[ https://issues.apache.org/jira/browse/FLINK-35146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryan Skraba updated FLINK-35146: Labels: test-stability (was: ) > CompileAndExecuteRemotePlanITCase.testCompileAndExecutePlan >

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

[ 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-35136) Release flink-connector-hbase v4.0.0 for Flink 1.19

[ 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] [Assigned] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

[ 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

[ 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] [Comment Edited] (FLINK-35124) Connector Release Fails to run Checkstyle

[ 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

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

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]

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

[ 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-34987][state] Introduce Internal State for Async State API [flink]

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

[jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838235#comment-17838235 ] Ryan Skraba commented on FLINK-33186: - 1.20 test_cron_hadoop313

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

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.

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

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

[ 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-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

[ 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] [Commented] (FLINK-35124) Connector Release Fails to run Checkstyle

[ 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

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

[ 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

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

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 @@ +/* + *

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

[ https://issues.apache.org/jira/browse/FLINK-33394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838223#comment-17838223 ] Ryan Skraba commented on FLINK-33394: - This should be closed as a duplicate of FLINK-31421 (Weirdly

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

[ 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

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

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

[ 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

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358 ] Aleksandr Pilipenko commented on FLINK-35115: - snapshotState method in FlinkKinesisConsumer

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

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35115: --- Labels: kinesis pull-request-available (was: kinesis) > Kinesis connector writes wrong

[PR] [FLINK-35115] Allow kinesis consumer to snapshotState after operator had been cancelled [flink-connector-aws]

z3d1k opened a new pull request, #138: URL: https://github.com/apache/flink-connector-aws/pull/138 ## Purpose of the change Perform snapshot state even after source operator had been cancelled. This solves the issue when operator state is not being saved during stor-with-savepoint

Re: [PR] [FLINK-35115] Allow kinesis consumer to snapshotState after operator had been cancelled [flink-connector-aws]

z3d1k commented on PR #138: URL: https://github.com/apache/flink-connector-aws/pull/138#issuecomment-2061752988 @dannycranmer, @hlteoh37 please take a look -- 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-35116] Bump operator sdk version to 4.8.3 [flink-kubernetes-operator]

mbalassi merged PR #816: URL: https://github.com/apache/flink-kubernetes-operator/pull/816 -- 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:

[PR] [FLINK-31860] FlinkDeployments never finalize when namespace is deleted [flink-kubernetes-operator]

jiangzho opened a new pull request, #817: URL: https://github.com/apache/flink-kubernetes-operator/pull/817 ## What is the purpose of the change This patch is to tackle the corner case where `cleanup` of CustomResource is constantly failing due to event publish failure, and

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

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358 ] Aleksandr Pilipenko edited comment on FLINK-35115 at 4/17/24 7:01 PM:

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-2061766848 Thanks a lot @xuyangzhong for your review. I addressed your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-34583: Attachment: image-2024-04-17-16-35-06-153.png > Bug for dynamic table option hints with multiple

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

[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui updated FLINK-34583: Attachment: image-2024-04-17-16-48-49-073.png > Bug for dynamic table option hints with multiple

Re: [PR] [FLINK-31860] FlinkDeployments never finalize when namespace is deleted [flink-kubernetes-operator]

jiangzho commented on PR #817: URL: https://github.com/apache/flink-kubernetes-operator/pull/817#issuecomment-2062344434 Thanks @gyfora for quick turnaround ! The commit has been updated with style fix. This patch is validated via minikube setup. -- This is an automated message

Re: [PR] [FLINK-35148][core] Improve InstantiationUtil for checking nullary pu… [flink]

flinkbot commented on PR #24675: URL: https://github.com/apache/flink/pull/24675#issuecomment-2062593439 ## CI report: * fc79b8051c60e2628b2098e82bc945f79b08a3d3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35148][core] Improve InstantiationUtil for checking nullary pu… [flink]

liuml07 commented on PR #24675: URL: https://github.com/apache/flink/pull/24675#issuecomment-2062592367 @snuyanzin could you take a look? Thanks, -- 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

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

[ https://issues.apache.org/jira/browse/FLINK-34583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838379#comment-17838379 ] Xingcan Cui commented on FLINK-34583: - Hi [~xuyangzhong], thanks for looking into this. I hit the

[jira] [Created] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

Sharon Xie created FLINK-35147: -- Summary: SinkMaterializer throws StateMigrationException when widening the field type in the output table Key: FLINK-35147 URL: https://issues.apache.org/jira/browse/FLINK-35147

[jira] [Created] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor

Mingliang Liu created FLINK-35148: - Summary: Improve InstantiationUtil for checking nullary public constructor Key: FLINK-35148 URL: https://issues.apache.org/jira/browse/FLINK-35148 Project: Flink

[jira] [Updated] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor

[ https://issues.apache.org/jira/browse/FLINK-35148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35148: --- Labels: pull-request-available (was: ) > Improve InstantiationUtil for checking nullary

[jira] [Updated] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

[ https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35147: --- Description: When a field type in the output table is changed from int -> bigint or timestamp(3)

[jira] [Updated] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

[ https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35147: --- Description: When a field type in the output table is changed from int -> bigint or timestamp(3)

[jira] [Updated] (FLINK-35147) SinkMaterializer throws StateMigrationException when widening the field type in the output table

[ https://issues.apache.org/jira/browse/FLINK-35147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharon Xie updated FLINK-35147: --- Description: When a field type in the output table is changed from int -> bigint or timestamp(3)

[PR] [FLINK-35148][core] Improve InstantiationUtil for checking nullary pu… [flink]

liuml07 opened a new pull request, #24675: URL: https://github.com/apache/flink/pull/24675 …blic constructor ## What is the purpose of the change https://issues.apache.org/jira/browse/FLINK-35148 InstantiationUtil#hasPublicNullaryConstructor checks whether the

Re: [PR] [minor][docs] Optimize markdown styles in quickstart doc [flink-cdc]

Jiabao-Sun merged PR #3217: URL: https://github.com/apache/flink-cdc/pull/3217 -- 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] [BP-3.0][minor][cdc][docs] Optimize markdown styles in quickstart doc [flink-cdc]

Jiabao-Sun merged PR #3223: URL: https://github.com/apache/flink-cdc/pull/3223 -- 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-34549][API] Introduce config, context and processingTimerService for DataStream API V2 [flink]

reswqa commented on PR #24541: URL: https://github.com/apache/flink/pull/24541#issuecomment-2062837816 @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-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added [flink-cdc]

loserwang1024 commented on code in PR #3230: URL: https://github.com/apache/flink-cdc/pull/3230#discussion_r1569794515 ## 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] [Created] (FLINK-35150) The specified upload does not exist. The upload ID may be invalid

qyw created FLINK-35150: --- Summary: The specified upload does not exist. The upload ID may be invalid Key: FLINK-35150 URL: https://issues.apache.org/jira/browse/FLINK-35150 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35150) The specified upload does not exist. The upload ID may be invalid

[ https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qyw updated FLINK-35150: Attachment: image-2024-04-18-11-20-25-583.png > The specified upload does not exist. The upload ID may be invalid

[jira] [Updated] (FLINK-35150) The specified upload does not exist. The upload ID may be invalid

[ https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qyw updated FLINK-35150: Attachment: image-2024-04-18-11-20-43-126.png > The specified upload does not exist. The upload ID may be invalid

[jira] [Updated] (FLINK-35150) The specified upload does not exist. The upload ID may be invalid

[ https://issues.apache.org/jira/browse/FLINK-35150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qyw updated FLINK-35150: Attachment: (was: image-2024-04-18-11-07-15-555.png) > The specified upload does not exist. The upload ID may

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

Zakelly commented on code in PR #24632: URL: https://github.com/apache/flink/pull/24632#discussion_r1569850955 ## flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopDataInputStream.java: ## @@ -140,4 +144,43 @@ public void skipFully(long

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

yunfengzhou-hub commented on code in PR #24672: URL: https://github.com/apache/flink/pull/24672#discussion_r1569902836 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java: ## @@ -117,6 +120,7 @@ public class

[jira] [Updated] (FLINK-35151) Flink mysql cdc will stuck when suspend binlog split and ChangeEventQueue is full

[ https://issues.apache.org/jira/browse/FLINK-35151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Gong updated FLINK-35151: - Description: Flink mysql cdc will  stuck when suspend binlog split and ChangeEventQueue is full.

Re: [PR] [FLINK-35027][runtime/checkpoint] Implement checkpoint drain in AsyncExecutionController [flink]

flinkbot commented on PR #24676: URL: https://github.com/apache/flink/pull/24676#issuecomment-2062993344 ## CI report: * bc18939af1ffea146d6f2214d061cca4dc136ca6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35027) Implement checkpoint drain in AsyncExecutionController

[ https://issues.apache.org/jira/browse/FLINK-35027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35027: --- Labels: pull-request-available (was: ) > Implement checkpoint drain in

[jira] [Assigned] (FLINK-34738) "Deployment - YARN" Page for Flink CDC Chinese Documentation

[ https://issues.apache.org/jira/browse/FLINK-34738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34738: -- Assignee: Vincent Woo > "Deployment - YARN" Page for Flink CDC Chinese Documentation >

Re: [PR] [FLINK-28693][table] Fix janino compile failed because the code generated refers the class in table-planner [flink]

xuyangzhong commented on PR #24280: URL: https://github.com/apache/flink/pull/24280#issuecomment-2062858561 Thanks very much for the bp @snuyanzin  -- 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

<    1   2   3   >