Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-rabbitmq]

2024-04-19 Thread via GitHub
dannycranmer merged PR #24: URL: https://github.com/apache/flink-connector-rabbitmq/pull/24 -- 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-35142][Connectors/RabbitMQ] Drop support for Flink 1.17 [flink-connector-rabbitmq]

2024-04-19 Thread via GitHub
dannycranmer merged PR #27: URL: https://github.com/apache/flink-connector-rabbitmq/pull/27 -- 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-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages [flink-cdc]

2024-04-19 Thread via GitHub
yuxiqian commented on PR #3212: URL: https://github.com/apache/flink-cdc/pull/3212#issuecomment-2066306357 Seems removing connector jar dependencies break SQL Job E2e tests. Need to fix this first. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838954#comment-17838954 ] Danny Cranmer commented on FLINK-35174: --- Merged commit 66e323a into apache:main > Bump

[PR] [FLINK-35168][State] Basic State Iterator for async processing [flink]

2024-04-19 Thread via GitHub
Zakelly opened a new pull request, #24690: URL: https://github.com/apache/flink/pull/24690 ## What is the purpose of the change This PR ship the basic logic of state iterator, only leave the necessary part abstract for subclass to implement. Most of the code is future-related.

Re: [PR] Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 [flink-connector-rabbitmq]

2024-04-19 Thread via GitHub
dannycranmer closed pull request #25: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.0 URL: https://github.com/apache/flink-connector-rabbitmq/pull/25 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Component/s: Connectors/ RabbitMQ (was: Connectors / AWS) > Bump

Re: [PR] [FLINK-35162][state] Implement WriteBatchOperation and general MultiGetOperation for ForSt [flink]

2024-04-19 Thread via GitHub
ljz2051 commented on code in PR #24681: URL: https://github.com/apache/flink/pull/24681#discussion_r1572156946 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ContextKey.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-35162][state] Implement WriteBatchOperation and general MultiGetOperation for ForSt [flink]

2024-04-19 Thread via GitHub
ljz2051 commented on code in PR #24681: URL: https://github.com/apache/flink/pull/24681#discussion_r1572160266 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBOperation.java: ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache

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

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

Re: [PR] [FLINK-35039][rest] Use PUT method supported by YARN web proxy instead of POST [flink]

2024-04-19 Thread via GitHub
Myasuka commented on PR #24689: URL: https://github.com/apache/flink/pull/24689#issuecomment-2066319875 @yeezychao Can your solution also works in standalone environment? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

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

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

[jira] [Created] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector

2024-04-19 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35174: - Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector Key: FLINK-35174 URL: https://issues.apache.org/jira/browse/FLINK-35174

Re: [PR] [FLINK-33460][Connector/JDBC] Support property authentication connection. [flink-connector-jdbc]

2024-04-19 Thread via GitHub
RocMarshal commented on code in PR #115: URL: https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572083767 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java: ## @@ -90,13 +98,31 @@ public

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

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

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Description: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink

Re: [PR] Fix problem due to HBaseRowDataLookupFunction returned to reuse objects [flink-connector-hbase]

2024-04-19 Thread via GitHub
Tan-JiaLiang commented on PR #20: URL: https://github.com/apache/flink-connector-hbase/pull/20#issuecomment-2066268025 @Jackson-xky This is a serious problem in the hbase lookup join. Are you still working on it? I'd be happy to help. -- This is an automated message from the Apache Git

Re: [PR] [FLINK-35162][state] Implement WriteBatchOperation and general MultiGetOperation for ForSt [flink]

2024-04-19 Thread via GitHub
ljz2051 commented on code in PR #24681: URL: https://github.com/apache/flink/pull/24681#discussion_r1572153463 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ContextKey.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache

[jira] [Updated] (FLINK-35142) Release flink-connector-rabbitmq v3.1.0 for Flink 1.19

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

Re: [PR] [FLINK-33460][Connector/JDBC] Support property authentication connection. [flink-connector-jdbc]

2024-04-19 Thread via GitHub
eskabetxe commented on code in PR #115: URL: https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572162247 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java: ## @@ -90,13 +98,31 @@ public

Re: [PR] [FLINK-35162][state] Implement WriteBatchOperation and general MultiGetOperation for ForSt [flink]

2024-04-19 Thread via GitHub
ljz2051 commented on PR #24681: URL: https://github.com/apache/flink/pull/24681#issuecomment-2066281635 @Zakelly Thanks for your review! I have addressed all comments your mentioned. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

2024-04-19 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 edited comment on FLINK-35132 at 4/19/24 10:27 AM: - RC1

Re: [PR] [FLINK-33460][Connector/JDBC] Support property authentication connection. [flink-connector-jdbc]

2024-04-19 Thread via GitHub
eskabetxe commented on code in PR #115: URL: https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572162247 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java: ## @@ -90,13 +98,31 @@ public

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

2024-04-19 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 edited comment on FLINK-35137 at 4/19/24 10:28 AM: - RC1

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

2024-04-19 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 edited comment on FLINK-35139 at 4/19/24 10:28 AM: - RC1

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

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838591#comment-17838591 ] Danny Cranmer edited comment on FLINK-35137 at 4/19/24 10:28 AM: - RC2

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

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838592#comment-17838592 ] Danny Cranmer edited comment on FLINK-35139 at 4/19/24 10:28 AM: - RC2

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

2024-04-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838590#comment-17838590 ] Danny Cranmer edited comment on FLINK-35135 at 4/19/24 10:28 AM: - RC1

Re: [PR] [FLINK-35174][Connectors/RabbitMQ] Bump commons-compress to 1.26.1 [flink-connector-rabbitmq]

2024-04-19 Thread via GitHub
hlteoh37 commented on PR #28: URL: https://github.com/apache/flink-connector-rabbitmq/pull/28#issuecomment-2066287030 Seems like there is a dependency convergence error ``` Warning: Dependency convergence error for org.apache.commons:commons-lang3:3.14.0 paths to dependency

Re: [PR] [FLINK-35174][Connectors/RabbitMQ] Bump commons-compress to 1.26.1 [flink-connector-rabbitmq]

2024-04-19 Thread via GitHub
dannycranmer merged PR #28: URL: https://github.com/apache/flink-connector-rabbitmq/pull/28 -- 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-35039) Create Profiling JobManager/TaskManager Instance failed

2024-04-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-35039: Assignee: ude > Create Profiling JobManager/TaskManager Instance failed >

[jira] [Commented] (FLINK-35039) Create Profiling JobManager/TaskManager Instance failed

2024-04-19 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838951#comment-17838951 ] Yun Tang commented on FLINK-35039: -- [~wczhu] Already assigned to you. > Create Profiling

[jira] [Updated] (FLINK-35168) Basic State Iterator for async processing

2024-04-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35168: --- Labels: pull-request-available (was: ) > Basic State Iterator for async processing >

Re: [PR] [FLINK-35168][State] Basic State Iterator for async processing [flink]

2024-04-19 Thread via GitHub
flinkbot commented on PR #24690: URL: https://github.com/apache/flink/pull/24690#issuecomment-2066354887 ## CI report: * 5fa3b48c1caed9d9e4ff9b31c1b8640318c18555 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window

2024-04-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838962#comment-17838962 ] Hong Liang Teoh commented on FLINK-35069: - Thanks [~lijinzhong] for the fix! Are we planning to

Re: [PR] [FLINK-28048][connectors] Introduce Source API alternative to FiniteTestSource [flink]

2024-04-19 Thread via GitHub
afedulov commented on PR #23777: URL: https://github.com/apache/flink/pull/23777#issuecomment-2066761675 CI is green: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58998=results -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [BP-1.19][FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment [flink]

2024-04-19 Thread via GitHub
zentol merged PR #24686: URL: https://github.com/apache/flink/pull/24686 -- 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] [Comment Edited] (FLINK-35159) CreatingExecutionGraph can leak CheckpointCoordinator and cause JM crash

2024-04-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838908#comment-17838908 ] Chesnay Schepler edited comment on FLINK-35159 at 4/19/24 3:03 PM: ---

[jira] [Closed] (FLINK-35159) CreatingExecutionGraph can leak CheckpointCoordinator and cause JM crash

2024-04-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-35159. Resolution: Fixed > CreatingExecutionGraph can leak CheckpointCoordinator and cause JM

[jira] [Created] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

2024-04-19 Thread RocMarshal (Jira)
RocMarshal created FLINK-35176: -- Summary: Support property authentication connection for JDBC catalog & dynamic table Key: FLINK-35176 URL: https://issues.apache.org/jira/browse/FLINK-35176 Project:

[jira] [Updated] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

2024-04-19 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-35176: --- Parent: FLINK-25420 Issue Type: Sub-task (was: Improvement) > Support property

Re: [PR] [FLINK-34574] Add CPU and memory size autoscaler quota [flink-kubernetes-operator]

2024-04-19 Thread via GitHub
gyfora merged PR #789: URL: https://github.com/apache/flink-kubernetes-operator/pull/789 -- 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] [Closed] (FLINK-34574) Add CPU and memory size autoscaler quota

2024-04-19 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-34574. -- Fix Version/s: kubernetes-operator-1.9.0 Resolution: Fixed merged to main

[PR] [FLINK-33460][Connector/JDBC] Support property authentication connection for JDBC catalog & dynamic table [flink-connector-jdbc]

2024-04-19 Thread via GitHub
RocMarshal opened a new pull request, #116: URL: https://github.com/apache/flink-connector-jdbc/pull/116 - Support property authentication connection for JDBC catalog & dynamic table -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-34227) Job doesn't disconnect from ResourceManager

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

[jira] [Commented] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

2024-04-19 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839001#comment-17839001 ] Ryan Skraba commented on FLINK-35175: - 1.20 Hadoop 3.1.3 / Compile

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

2024-04-19 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17839003#comment-17839003 ] Ryan Skraba commented on FLINK-18476: - 1.19 Java 11 / Test (module: misc)

Re: [PR] [BP-1.18][FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment [flink]

2024-04-19 Thread via GitHub
zentol merged PR #24687: URL: https://github.com/apache/flink/pull/24687 -- 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-33460][Connector/JDBC] Support property authentication connection. [flink-connector-jdbc]

2024-04-19 Thread via GitHub
RocMarshal commented on code in PR #115: URL: https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572398050 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java: ## @@ -90,13 +98,31 @@ public

Re: [PR] [FLINK-33460][Connector/JDBC] Support property authentication connection. [flink-connector-jdbc]

2024-04-19 Thread via GitHub
RocMarshal commented on code in PR #115: URL: https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1572398050 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java: ## @@ -90,13 +98,31 @@ public

[jira] [Comment Edited] (FLINK-35159) CreatingExecutionGraph can leak CheckpointCoordinator and cause JM crash

2024-04-19 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838908#comment-17838908 ] Chesnay Schepler edited comment on FLINK-35159 at 4/19/24 1:40 PM: ---

Re: [PR] [BP-1.19][FLINK-35159] Transition ExecutionGraph to RUNNING after slot assignment [flink]

2024-04-19 Thread via GitHub
zentol commented on PR #24686: URL: https://github.com/apache/flink/pull/24686#issuecomment-2066614601 @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.

<    1   2