[jira] [Updated] (FLINK-34537) Autoscaler JDBC Support HikariPool

2024-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34537: --- Labels: pull-request-available (was: ) > Autoscaler JDBC Support HikariPool >

[PR] [FLINK-34537] Autoscaler JDBC Support HikariPool [flink-kubernetes-operator]

2024-02-28 Thread via GitHub
czy006 opened a new pull request, #785: URL: https://github.com/apache/flink-kubernetes-operator/pull/785 ## What is the purpose of the change *Autoscaler JDBC Support HikariPool to Replace JDBC DirverManager* ## Brief change log - *Add Autoscaler

[jira] [Updated] (FLINK-34537) Autoscaler JDBC Support HikariPool

2024-02-28 Thread ConradJam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ConradJam updated FLINK-34537: -- Description: Autoscaler Using HikariPool to replace native JDBC connections.  Helps reduce database

[jira] [Updated] (FLINK-34537) Autoscaler JDBC Support HikariPool

2024-02-28 Thread ConradJam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ConradJam updated FLINK-34537: -- Summary: Autoscaler JDBC Support HikariPool (was: Autoscaler JDBC) > Autoscaler JDBC Support

[jira] [Created] (FLINK-34537) Autoscaler JDBC

2024-02-28 Thread ConradJam (Jira)
ConradJam created FLINK-34537: - Summary: Autoscaler JDBC Key: FLINK-34537 URL: https://issues.apache.org/jira/browse/FLINK-34537 Project: Flink Issue Type: Improvement Components:

Re: [PR] [FLINK-34509] [docs] add missing "url" option for Debezium Avro [flink]

2024-02-28 Thread via GitHub
affo commented on PR #24395: URL: https://github.com/apache/flink/pull/24395#issuecomment-1968635738 > Thanks @affo for driving it! Just left some comments, PTAL. Thank you @JingGe for reviewing. I just added `Confluent` where needed, and also made the use of `JSON` instead of

Re: [PR] [FLINK-34274][runtime] Implicitly disable resource wait timeout for A… [flink]

2024-02-28 Thread via GitHub
XComp commented on PR #24238: URL: https://github.com/apache/flink/pull/24238#issuecomment-1968607712 > I added the changes I proposed. That should be good enough from my end, if you're ok with those changes (just to bring the PR closer to being merged and resolving the test instability in

Re: [PR] [FLINK-34274][runtime] Implicitly disable resource wait timeout for A… [flink]

2024-02-28 Thread via GitHub
XComp commented on code in PR #24238: URL: https://github.com/apache/flink/pull/24238#discussion_r1505659537 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerBuilder.java: ## Review Comment: I removed the comment because it's

Re: [PR] [FLINK-34274][runtime] Implicitly disable resource wait timeout for A… [flink]

2024-02-28 Thread via GitHub
XComp commented on code in PR #24238: URL: https://github.com/apache/flink/pull/24238#discussion_r1505657635 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerBuilder.java: ## @@ -117,6 +118,12 @@ public AdaptiveSchedulerBuilder

Re: [PR] [FLINK-34517][table]fix environment configs ignored when calling procedure operation [flink]

2024-02-28 Thread via GitHub
luoyuxia commented on code in PR #24397: URL: https://github.com/apache/flink/pull/24397#discussion_r1505636104 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerCallProcedureOperation.java: ## @@ -138,6 +137,14 @@ private

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-28 Thread via GitHub
masteryhx commented on code in PR #24181: URL: https://github.com/apache/flink/pull/24181#discussion_r1505595039 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -321,6 +321,8 @@ public abstract class StreamTask>

Re: [PR] [FLINK-34352][doc] Improve the documentation of allowNonRestoredState [flink]

2024-02-28 Thread via GitHub
masteryhx commented on PR #24396: URL: https://github.com/apache/flink/pull/24396#issuecomment-1968514402 @Zakelly Thanks for the review. I have addressed your comments. PTAL again. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [hotfix] Fix configuration through TernaryBoolean in EmbeddedRocksDBStateBackend. [flink]

2024-02-28 Thread via GitHub
StefanRRichter merged PR #24392: URL: https://github.com/apache/flink/pull/24392 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

2024-02-28 Thread junzhong qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821560#comment-17821560 ] junzhong qin commented on FLINK-31810: -- Hi [~yunta] , > First of all, we can certainly rescale

[jira] [Created] (FLINK-34536) Support reading long value as Timestamp column in JSON format

2024-02-28 Thread yisha zhou (Jira)
yisha zhou created FLINK-34536: -- Summary: Support reading long value as Timestamp column in JSON format Key: FLINK-34536 URL: https://issues.apache.org/jira/browse/FLINK-34536 Project: Flink

<    1   2   3