[jira] [Updated] (FLINK-34947) Reduce JM scale down timeout

2024-03-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34947: --- Description: We introduced a logic to scale down the JobManager before the task managers are killed

[jira] [Updated] (FLINK-34947) Reduce JM scale down timeout

2024-03-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34947: --- Description: We introduced a logic to scale down the JobManager before the task managers are killed

[jira] [Updated] (FLINK-34947) Reduce JM scale down timeout

2024-03-26 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-34947: --- Summary: Reduce JM scale down timeout (was: Do not scale down JM in Orphan deletion propagation and

[jira] [Created] (FLINK-34947) Do not scale down JM in Orphan deletion propagation and reduce timeout

2024-03-26 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-34947: -- Summary: Do not scale down JM in Orphan deletion propagation and reduce timeout Key: FLINK-34947 URL: https://issues.apache.org/jira/browse/FLINK-34947 Project: Flink

[jira] [Updated] (FLINK-34946) Flink Website Menu Adjustment

2024-03-26 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-34946: Description: {color:#00}Discuss Thread:[https://lists.apache.org/thread/fvxrhc9nxzkjk

[jira] [Updated] (FLINK-34946) Flink Website Menu Adjustment

2024-03-26 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-34946: Description: {color:#00}Discuss Thread:[https://lists.apache.org/thread/fvxrhc9nxzkjk

[jira] [Updated] (FLINK-34946) Flink Website Menu Adjustment

2024-03-26 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-34946: Description: {color:#00}Discuss Thread:https://lists.apache.org/thread/fvxrhc9nxzkjkt

[jira] [Created] (FLINK-34946) Flink Website Menu Adjustment

2024-03-26 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-34946: --- Summary: Flink Website Menu Adjustment Key: FLINK-34946 URL: https://issues.apache.org/jira/browse/FLINK-34946 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-03-26 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831175#comment-17831175 ] Hang Ruan commented on FLINK-34445: --- Fine, I will take a look at this. Thanks ~ > Int

[jira] [Updated] (FLINK-34936) Register shared state files to FileMergingSnapshotManager

2024-03-26 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-34936: - Component/s: Runtime / Checkpointing > Register shared state files to FileMergingSnapshotManager

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-03-26 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831170#comment-17831170 ] Mason Chen commented on FLINK-34445: Anytime after https://issues.apache.org/jira/br

[jira] [Updated] (FLINK-34444) Add new endpoint handler to flink

2024-03-26 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-3: --- Fix Version/s: 1.20.0 > Add new endpoint handler to flink > - > >

[jira] [Updated] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-03-26 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-34445: --- Fix Version/s: 1.20.0 > Integrate new endpoint with Flink UI metrics section > -

[jira] [Updated] (FLINK-34064) Expose JobManagerOperatorMetrics via REST API

2024-03-26 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mason Chen updated FLINK-34064: --- Fix Version/s: 1.20.0 > Expose JobManagerOperatorMetrics via REST API >

[jira] [Created] (FLINK-34945) Support recover shuffle descriptor and partition metrics from tiered storage

2024-03-26 Thread Junrui Li (Jira)
Junrui Li created FLINK-34945: - Summary: Support recover shuffle descriptor and partition metrics from tiered storage Key: FLINK-34945 URL: https://issues.apache.org/jira/browse/FLINK-34945 Project: Flink

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

2024-03-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831151#comment-17831151 ] Rui Fan commented on FLINK-34643: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-29481) Show JobType on WebUI

2024-03-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831150#comment-17831150 ] Rui Fan commented on FLINK-29481: - Discuss with [~dangshazi] offlien, I will take over t

[jira] [Created] (FLINK-34944) Use Incremental Source Framework in Flink CDC OceanBase Source Connector

2024-03-26 Thread He Wang (Jira)
He Wang created FLINK-34944: --- Summary: Use Incremental Source Framework in Flink CDC OceanBase Source Connector Key: FLINK-34944 URL: https://issues.apache.org/jira/browse/FLINK-34944 Project: Flink

[jira] [Updated] (FLINK-29481) Show JobType on WebUI

2024-03-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-29481: Labels: features pull-request-available (was: features pull-request-available stale-assigned) > Show Job

[jira] [Assigned] (FLINK-29481) Show JobType on WebUI

2024-03-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-29481: --- Assignee: Rui Fan (was: LI Mingkun) > Show JobType on WebUI > - > >

[jira] [Updated] (FLINK-29481) Show JobType on WebUI

2024-03-26 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-29481: Fix Version/s: 1.20.0 > Show JobType on WebUI > - > > Key: FLINK-29481

[jira] [Comment Edited] (FLINK-33707) Verify the snapshot migration on Java17

2024-03-26 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831141#comment-17831141 ] Hangxiang Yu edited comment on FLINK-33707 at 3/27/24 2:46 AM: ---

[jira] [Commented] (FLINK-33707) Verify the snapshot migration on Java17

2024-03-26 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831141#comment-17831141 ] Hangxiang Yu commented on FLINK-33707: -- Hi, Scala API has been marked as deprecated

[jira] [Updated] (FLINK-34639) Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

2024-03-26 Thread He Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] He Wang updated FLINK-34639: Fix Version/s: cdc-3.1.0 > Flink CDC: Support DebeziumDeserializationSchema in OceanBase source connector

Re: [PR] [FLINK-33970][jdbc][docs] Remove dead link [flink-connector-jdbc]

2024-03-26 Thread via GitHub
GOODBOY008 commented on PR #88: URL: https://github.com/apache/flink-connector-jdbc/pull/88#issuecomment-2021803094 @Jiabao-Sun PTAL -- 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

[PR] [FLINK-34943] Support Flink 1.19, 1.20-SNAPSHOT for JDBC connector [flink-connector-jdbc]

2024-03-26 Thread via GitHub
GOODBOY008 opened a new pull request, #111: URL: https://github.com/apache/flink-connector-jdbc/pull/111 Changes: - Support Flink 1.19, 1.20-SNAPSHOT - Code polish -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-34943) Support Flink 1.19, 1.20-SNAPSHOT for JDBC connector

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34943: --- Labels: pull-request-available (was: ) > Support Flink 1.19, 1.20-SNAPSHOT for JDBC connect

Re: [PR] [hotfix] Change old com.ververica dependency to flink [flink-cdc]

2024-03-26 Thread via GitHub
xleoken commented on PR #3110: URL: https://github.com/apache/flink-cdc/pull/3110#issuecomment-2021795499 cc @leonardBang @PatrickRen @Jiabao-Sun -- 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 t

[jira] [Closed] (FLINK-34668) Report State handle of file merging directory to JM

2024-03-26 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-34668. -- Resolution: Resolved > Report State handle of file merging directory to JM > -

[jira] [Commented] (FLINK-34668) Report State handle of file merging directory to JM

2024-03-26 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831130#comment-17831130 ] Yanfei Lei commented on FLINK-34668: Merged via 05b27be > Report State handle of fi

[jira] [Updated] (FLINK-34943) Support Flink 1.19, 1.20-SNAPSHOT for JDBC connector

2024-03-26 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-34943: Summary: Support Flink 1.19, 1.20-SNAPSHOT for JDBC connector (was: Support Flink 1.19, 1

[jira] [Created] (FLINK-34943) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector

2024-03-26 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-34943: --- Summary: Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector Key: FLINK-34943 URL: https://issues.apache.org/jira/browse/FLINK-34943 Project: Flink

[jira] [Commented] (FLINK-34445) Integrate new endpoint with Flink UI metrics section

2024-03-26 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831119#comment-17831119 ] Hang Ruan commented on FLINK-34445: --- Sure, I would like to help in this part. When sho

[jira] [Updated] (FLINK-34942) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34942: --- Labels: pull-request-available (was: ) > Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch c

[PR] [FLINK-34942] Add support for Flink 1.19, 1.20-SNAPSHOT [flink-connector-opensearch]

2024-03-26 Thread via GitHub
snuyanzin opened a new pull request, #42: URL: https://github.com/apache/flink-connector-opensearch/pull/42 PR makes current code compilable with Flink 1.19, 1.20-SNAPSHOT also it bumps dependencies jackson to 1.15.3 junit5 to 5.10.2 assertj to 3.25.3 testcontainers to 1.19.7

[jira] [Created] (FLINK-34942) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector

2024-03-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34942: --- Summary: Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector Key: FLINK-34942 URL: https://issues.apache.org/jira/browse/FLINK-34942 Project: Flink

Re: [PR] [FLINK-34941][checkpoint] Add `CollectIteratorAssert#matchesRecordsFromSource` and `SinkTestSuiteBase#checkResultWithSemantic` with former signature [flink]

2024-03-26 Thread via GitHub
flinkbot commented on PR #24571: URL: https://github.com/apache/flink/pull/24571#issuecomment-2021523128 ## CI report: * 51baa4e6f3c83fc4050c50b54dd69c2e8f16f2f5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34941][checkpoint] Add `CollectIteratorAssert#matchesRecordsFromSource` and `SinkTestSuiteBase#checkResultWithSemantic` with former signature [flink]

2024-03-26 Thread via GitHub
snuyanzin commented on PR #24571: URL: https://github.com/apache/flink/pull/24571#issuecomment-2021520200 @Zakelly , @masteryhx could you please have a look since it is related to the change where you were participated [FLINK-34516](https://issues.apache.org/jira/browse/FLINK-34516) -- T

[jira] [Updated] (FLINK-34941) Cannot convert org.apache.flink.streaming.api.CheckpointingMode to org.apache.flink.core.execution.CheckpointingMode

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34941: --- Labels: pull-request-available (was: ) > Cannot convert org.apache.flink.streaming.api.Chec

[PR] [FLINK-34941][checkpoint] Add `CollectIteratorAssert#matchesRecordsFromSource` and `SinkTestSuiteBase#checkResultWithSemantic` with former signature [flink]

2024-03-26 Thread via GitHub
snuyanzin opened a new pull request, #24571: URL: https://github.com/apache/flink/pull/24571 ## What is the purpose of the change The PR introduces `CollectIteratorAssert#matchesRecordsFromSource` and `SinkTestSuiteBase#checkResultWithSemantic` with former signature to make downstrea

[jira] [Created] (FLINK-34941) Cannot convert org.apache.flink.streaming.api.CheckpointingMode to org.apache.flink.core.execution.CheckpointingMode

2024-03-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34941: --- Summary: Cannot convert org.apache.flink.streaming.api.CheckpointingMode to org.apache.flink.core.execution.CheckpointingMode Key: FLINK-34941 URL: https://issues.apache.o

Re: [PR] [FLINK-34513] GroupAggregateRestoreTest.testRestore fails [flink]

2024-03-26 Thread via GitHub
jnh5y commented on PR #24570: URL: https://github.com/apache/flink/pull/24570#issuecomment-2021439410 @bvarghese1 This approach fails since it breaks the JoinRestoreTest. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-34513] GroupAggregateRestoreTest.testRestore fails [flink]

2024-03-26 Thread via GitHub
flinkbot commented on PR #24570: URL: https://github.com/apache/flink/pull/24570#issuecomment-2021435634 ## CI report: * f91d4893b28331645d872d1452d3181f014af24f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34513) GroupAggregateRestoreTest.testRestore fails

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34513: --- Labels: pull-request-available test-stability (was: test-stability) > GroupAggregateRestore

[PR] [FLINK-34513] GroupAggregateRestoreTest.testRestore fails [flink]

2024-03-26 Thread via GitHub
jnh5y opened a new pull request, #24570: URL: https://github.com/apache/flink/pull/24570 * This addresses FLINK-34513 by changing `testMaterializedData` to only check the data after the restore. ## What is the purpose of the change Fix intermittent test failures. ## Does

Re: [PR] [FLINK-34419][docker] Add tests for JDK 17 & 21 [flink-docker]

2024-03-26 Thread via GitHub
morazow commented on PR #182: URL: https://github.com/apache/flink-docker/pull/182#issuecomment-2021392610 Thanks @XComp for looking into 🙏 I have squashed it as you suggested, fixed. I will update the other PRs similar to this one tomorrow. Thanks a lot! -- This is an autom

Re: [PR] [FLINK-26515][tests] Fix RetryingExecutorTest [flink]

2024-03-26 Thread via GitHub
flinkbot commented on PR #24569: URL: https://github.com/apache/flink/pull/24569#issuecomment-2021147280 ## CI report: * bd0e8d4a7e104a802ce5cbe19113ac8b63565423 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-03-26 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26515: - Assignee: Roman Khachatryan > RetryingExecutorTest. testDiscardOnTimeout failed

[PR] [FLINK-26515][tests] Fix RetryingExecutorTest [flink]

2024-03-26 Thread via GitHub
rkhachatryan opened a new pull request, #24569: URL: https://github.com/apache/flink/pull/24569 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring th

Re: [PR] [FLINK-33459][Connector/JDBC] Support the new source that keeps the same functionality as the original JDBC input format [flink-connector-jdbc]

2024-03-26 Thread via GitHub
snuyanzin commented on PR #78: URL: https://github.com/apache/flink-connector-jdbc/pull/78#issuecomment-2020733326 @davidradl @eskabetxe could you please have another look here? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[jira] [Comment Edited] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830957#comment-17830957 ] Piotr Nowojski edited comment on FLINK-26515 at 3/26/24 2:31 PM: -

[jira] [Updated] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-26515: --- Priority: Blocker (was: Critical) > RetryingExecutorTest. testDiscardOnTimeout failed on az

[jira] [Commented] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

2024-03-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830957#comment-17830957 ] Piotr Nowojski commented on FLINK-26515: occurance of the same issue in a privat

[jira] [Commented] (FLINK-34696) GSRecoverableWriterCommitter is generating excessive data blobs

2024-03-26 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830956#comment-17830956 ] Galen Warren commented on FLINK-34696: -- I'm not a committer so I can't approve anyt

[jira] [Closed] (FLINK-34014) Jdbc connector can avoid send empty insert to database when there's no buffer data

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-34014. --- > Jdbc connector can avoid send empty insert to database when there's no buffer > data > --

[jira] [Resolved] (FLINK-34014) Jdbc connector can avoid send empty insert to database when there's no buffer data

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-34014. - Fix Version/s: jdbc-3.2.0 Resolution: Fixed > Jdbc connector can avoid send empty

[jira] [Commented] (FLINK-34014) Jdbc connector can avoid send empty insert to database when there's no buffer data

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830948#comment-17830948 ] Sergey Nuyanzin commented on FLINK-34014: - Merged as [ffd2bdf887d997a6080f3a3bd

[jira] [Assigned] (FLINK-34014) Jdbc connector can avoid send empty insert to database when there's no buffer data

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-34014: --- Assignee: Jeyhun Karimov > Jdbc connector can avoid send empty insert to database w

Re: [PR] [FLINK-34014][jdbc] Avoid executeBatch when buffer is empty [flink-connector-jdbc]

2024-03-26 Thread via GitHub
snuyanzin merged PR #100: URL: https://github.com/apache/flink-connector-jdbc/pull/100 -- 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..

Re: [PR] [FLINK-34014][jdbc] Avoid executeBatch when buffer is empty [flink-connector-jdbc]

2024-03-26 Thread via GitHub
boring-cyborg[bot] commented on PR #100: URL: https://github.com/apache/flink-connector-jdbc/pull/100#issuecomment-2020536351 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 on

Re: [PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-26 Thread via GitHub
XComp commented on code in PR #24563: URL: https://github.com/apache/flink/pull/24563#discussion_r1539262029 ## flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java: ## @@ -246,6 +249,33 @@ public static CuratorFrameworkWithUnhandledErrorListener startC

Re: [PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-26 Thread via GitHub
XComp commented on code in PR #24563: URL: https://github.com/apache/flink/pull/24563#discussion_r1539254121 ## flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java: ## @@ -220,6 +222,52 @@ public class HighAvailabilityOptions {

Re: [PR] [FLINK-34014][jdbc] Avoid executeBatch when buffer is empty [flink-connector-jdbc]

2024-03-26 Thread via GitHub
snuyanzin commented on code in PR #100: URL: https://github.com/apache/flink-connector-jdbc/pull/100#discussion_r1539277654 ## flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/TableBufferedStatementExecutor.java: ## @@ -52,11 +52,13 @@ public

[jira] [Commented] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830931#comment-17830931 ] Sergey Nuyanzin commented on FLINK-25421: - Merged as [92e2b5f73ff087e56e56a5565

Re: [PR] [FLINK-34939][test] Hardens TestingLeaderElection [flink]

2024-03-26 Thread via GitHub
flinkbot commented on PR #24568: URL: https://github.com/apache/flink/pull/24568#issuecomment-2020444328 ## CI report: * f956c0997145ebd0ed07f234795161e7672d4d25 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-25421. - Fix Version/s: jdbc-3.2.0 Resolution: Fixed > Port JDBC Sink to new Unified Sink

[jira] [Closed] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-25421. --- > Port JDBC Sink to new Unified Sink API (FLIP-143) > --

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-03-26 Thread via GitHub
snuyanzin commented on PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-2020439861 Thanks for the hard work @eskabetxe and thanks everyone for the review @eskabetxe can you also please provide a PR to update `jdbc.md`? -- This is an automated m

Re: [PR] Bump org.postgresql:postgresql from 42.5.1 to 42.7.2 in /flink-connector-jdbc [flink-connector-jdbc]

2024-03-26 Thread via GitHub
dependabot[bot] closed pull request #104: Bump org.postgresql:postgresql from 42.5.1 to 42.7.2 in /flink-connector-jdbc URL: https://github.com/apache/flink-connector-jdbc/pull/104 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[PR] Bump org.postgresql:postgresql from 42.5.1 to 42.5.5 in /flink-connector-jdbc [flink-connector-jdbc]

2024-03-26 Thread via GitHub
dependabot[bot] opened a new pull request, #110: URL: https://github.com/apache/flink-connector-jdbc/pull/110 Bumps [org.postgresql:postgresql](https://github.com/pgjdbc/pgjdbc) from 42.5.1 to 42.5.5. Release notes Sourced from https://github.com/pgjdbc/pgjdbc/releases";>org.postgr

Re: [PR] Bump org.postgresql:postgresql from 42.5.1 to 42.7.2 in /flink-connector-jdbc [flink-connector-jdbc]

2024-03-26 Thread via GitHub
dependabot[bot] commented on PR #104: URL: https://github.com/apache/flink-connector-jdbc/pull/104#issuecomment-2020436094 Superseded by #110. -- 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

Re: [PR] [FLINK-25421] Port JDBC Sink to new Unified Sink API (FLIP-143) [flink-connector-jdbc]

2024-03-26 Thread via GitHub
snuyanzin merged PR #2: URL: https://github.com/apache/flink-connector-jdbc/pull/2 -- 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...@fl

[jira] [Assigned] (FLINK-25421) Port JDBC Sink to new Unified Sink API (FLIP-143)

2024-03-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-25421: --- Assignee: João Boto > Port JDBC Sink to new Unified Sink API (FLIP-143) > -

[jira] [Updated] (FLINK-34939) Harden TestingLeaderElection

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34939: --- Labels: pull-request-available (was: ) > Harden TestingLeaderElection > ---

[PR] [FLINK-34939][test] [flink]

2024-03-26 Thread via GitHub
XComp opened a new pull request, #24568: URL: https://github.com/apache/flink/pull/24568 ## What is the purpose of the change Hardens `TestingLeaderElection` to comply to the `LeaderContender` contract ## Brief change log * Notifying the contender of the leadership revoca

Re: [PR] [hotfix] Update dependencies [flink-connector-elasticsearch]

2024-03-26 Thread via GitHub
snuyanzin merged PR #93: URL: https://github.com/apache/flink-connector-elasticsearch/pull/93 -- 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-uns

Re: [PR] [hotfix] Add support for Flink 1.20 and drop 1.16 [flink-connector-elasticsearch]

2024-03-26 Thread via GitHub
snuyanzin commented on PR #94: URL: https://github.com/apache/flink-connector-elasticsearch/pull/94#issuecomment-2020396716 Thanks for taking 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 above to go

Re: [PR] [hotfix] Add support for Flink 1.20 and drop 1.16 [flink-connector-elasticsearch]

2024-03-26 Thread via GitHub
snuyanzin merged PR #94: URL: https://github.com/apache/flink-connector-elasticsearch/pull/94 -- 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-uns

Re: [PR] [FLINK-34572] Support OceanBase Jdbc Catalog [flink-connector-jdbc]

2024-03-26 Thread via GitHub
whhe commented on PR #109: URL: https://github.com/apache/flink-connector-jdbc/pull/109#issuecomment-2020383288 Would you please take a look on this? @leonardBang -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Created] (FLINK-34940) LeaderContender implementations handle invalid state

2024-03-26 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34940: - Summary: LeaderContender implementations handle invalid state Key: FLINK-34940 URL: https://issues.apache.org/jira/browse/FLINK-34940 Project: Flink Issue

Re: [PR] [FLINK-33984][runtime] Support batch snapshot for OperatorCoordinator. [flink]

2024-03-26 Thread via GitHub
zhuzhurk commented on code in PR #24415: URL: https://github.com/apache/flink/pull/24415#discussion_r1538868578 ## flink-core/src/main/java/org/apache/flink/api/connector/source/SupportsBatchSnapshot.java: ## @@ -0,0 +1,30 @@ +/* + * Licensed to the Apache Software Foundation (A

[jira] [Commented] (FLINK-34529) Projection cannot be pushed down through rank operator.

2024-03-26 Thread yisha zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830900#comment-17830900 ] yisha zhou commented on FLINK-34529: Hi [~libenchao] [~lincoln.86xy] , as your sugge

Re: [PR] [FLINK-34529][table-planner] Introduce FlinkProjectWindowTransposeRule. [flink]

2024-03-26 Thread via GitHub
flinkbot commented on PR #24567: URL: https://github.com/apache/flink/pull/24567#issuecomment-2020210585 ## CI report: * 839b369305d886c7575fe9c179db9965a3534432 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34529][table-planner] Introduce FlinkProjectWindowTransposeRule. [flink]

2024-03-26 Thread via GitHub
RubyChou opened a new pull request, #24567: URL: https://github.com/apache/flink/pull/24567 ## What is the purpose of the change *The PR aims to support pushing a Project past a Window in stream mode(It has been supported in batch mode).* ## Brief change log - *Introdu

[jira] [Updated] (FLINK-34529) Projection cannot be pushed down through rank operator.

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34529: --- Labels: pull-request-available (was: ) > Projection cannot be pushed down through rank oper

[jira] [Updated] (FLINK-34572) JDBC: Support OceanBase catalog

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

[PR] [FLINK-34572] Support OceanBase Jdbc Catalog [flink-connector-jdbc]

2024-03-26 Thread via GitHub
whhe opened a new pull request, #109: URL: https://github.com/apache/flink-connector-jdbc/pull/109 (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 unsubscri

[jira] [Commented] (FLINK-34751) RestClusterClient APIs doesn't work with running Flink application on YARN

2024-03-26 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830877#comment-17830877 ] Ferenc Csaky commented on FLINK-34751: -- Hi! Would you be able to share how to repro

Re: [PR] [FLINK-34938] Fix incorrect behaviour for comparison functions [flink]

2024-03-26 Thread via GitHub
flinkbot commented on PR #24566: URL: https://github.com/apache/flink/pull/24566#issuecomment-2020121492 ## CI report: * bdb81bd565f519aaee699bc954f6f1b45ac590f8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34937) Apache Infra GHA policy update

2024-03-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830876#comment-17830876 ] Matthias Pohl commented on FLINK-34937: --- I updated the link to refer to a publicly

[jira] [Updated] (FLINK-34938) Incorrect behaviour for comparison functions

2024-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34938: --- Labels: pull-request-available (was: ) > Incorrect behaviour for comparison functions > ---

[jira] [Updated] (FLINK-34937) Apache Infra GHA policy update

2024-03-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34937: -- Description: There is a policy update [announced in the infra ML|https://www.mail-archive.com

[PR] [FLINK-34938] Fix incorrect behaviour for comparison functions [flink]

2024-03-26 Thread via GitHub
dawidwys opened a new pull request, #24566: URL: https://github.com/apache/flink/pull/24566 ## What is the purpose of the change Fixes how SQL comparison functions work for TIMESTAMP types. ## Verifying this change Added tests in `ComparisonFunctionsITCase`. ## Doe

[jira] [Commented] (FLINK-34937) Apache Infra GHA policy update

2024-03-26 Thread Muhammet Orazov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830874#comment-17830874 ] Muhammet Orazov commented on FLINK-34937: - Hey [~mapohl], the first link is unre

[jira] [Created] (FLINK-34939) Harden TestingLeaderElection

2024-03-26 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34939: - Summary: Harden TestingLeaderElection Key: FLINK-34939 URL: https://issues.apache.org/jira/browse/FLINK-34939 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-34938) Incorrect behaviour for comparison functions

2024-03-26 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-34938: Summary: Incorrect behaviour for comparison functions Key: FLINK-34938 URL: https://issues.apache.org/jira/browse/FLINK-34938 Project: Flink Issue Ty

Re: [PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-26 Thread via GitHub
JTaky commented on PR #24563: URL: https://github.com/apache/flink/pull/24563#issuecomment-2020071741 @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-34668][checkpoint] Report state handle of file merging directory to JM [flink]

2024-03-26 Thread via GitHub
fredia merged PR #24513: URL: https://github.com/apache/flink/pull/24513 -- 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

Re: [PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-26 Thread via GitHub
ashangit commented on code in PR #24563: URL: https://github.com/apache/flink/pull/24563#discussion_r1538911667 ## flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java: ## @@ -220,6 +222,52 @@ public class HighAvailabilityOptions {

Re: [PR] [FLINK-33376][coordination] Extend ZooKeeper Curator configurations [flink]

2024-03-26 Thread via GitHub
ashangit commented on code in PR #24563: URL: https://github.com/apache/flink/pull/24563#discussion_r1538900208 ## docs/layouts/shortcodes/generated/high_availability_configuration.html: ## @@ -68,6 +80,12 @@ Integer Defines the session timeout for the

  1   2   >