Re: [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2

+1 (non-binding) - Validated checksum hash and signature. - Confirmed that no binaries exist in the source archive. - Built the source with JDK 8. - Verified the web PR. - Ensured the JAR is built by JDK 8. Best, Zhongqiang Gong Danny Cranmer 于2024年4月18日周四 18:20写道： > Hi everyone, > > Please

[jira] [Created] (FLINK-35516) Update the Experimental annotation to PublicEvolving for files connector

RocMarshal created FLINK-35516: -- Summary: Update the Experimental annotation to PublicEvolving for files connector Key: FLINK-35516 URL: https://issues.apache.org/jira/browse/FLINK-35516 Project: Flink

Re: [DISCUSS] FLIP-XXX Add K8S conditions to Flink CRD

Thank you Thomas for the valuable feedback. I have included couple of screenshots in the Proposal and included screenshots of how status will looks like if we have a Condition type other than Ready. Thanks Lajith K On Mon, Jun 3, 2024 at 6:48 AM Thomas Weise wrote: > Thanks for the

Re: [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2

Thanks Leonard for the checking and Rui for the discussion. I cancel the '-1 (non-binding)' vote. And +1(non-binding) for the vote thread. - Verified hash - Test a few of usage demo on mysql-5.7 - build from source code with jdk-1.8 on MacOS. Best regards, Yuepeng Pan. On 2024/06/03 14:46:35

Re: [DISCUSS] Add Flink CDC Channel to Apache Flink Slack Workspace

I’ve created flink-cdc channel in Apache Flink Slack Workspace via https://issues.apache.org/jira/browse/FLINK-35514 Best, Leonard > 2024年5月29日 下午9:53，Ahmed Hamdy 写道： > > Thanks Zhongqiang, +1 for sure. > Best Regards > Ahmed Hamdy > > >

[jira] [Created] (FLINK-35515) Upgrade hive version to 4.0.0

vikasap created FLINK-35515: --- Summary: Upgrade hive version to 4.0.0 Key: FLINK-35515 URL: https://issues.apache.org/jira/browse/FLINK-35515 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace

Zhongqiang Gong created FLINK-35514: --- Summary: Add Flink CDC Channel to Apache Flink Slack Workspace Key: FLINK-35514 URL: https://issues.apache.org/jira/browse/FLINK-35514 Project: Flink

Re: [DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0

Hi Ferenc, Thanks for the proposal. +1 for it! This FLIP will improve the user experience. Regards, Jeyhun On Mon, Jun 3, 2024 at 1:50 PM Ferenc Csaky wrote: > Hi Hang, > > Thank you for your inputs, both points make sense, updated the > FLIP according to them. > > Best, > Ferenc > > > >

[jira] [Created] (FLINK-35513) ArtifactFetchManager unit tests are failing

Elphas Toringepi created FLINK-35513: Summary: ArtifactFetchManager unit tests are failing Key: FLINK-35513 URL: https://issues.apache.org/jira/browse/FLINK-35513 Project: Flink Issue

[jira] [Created] (FLINK-35512) ArtifactFetchManagerTest unit tests fail

Hong Liang Teoh created FLINK-35512: --- Summary: ArtifactFetchManagerTest unit tests fail Key: FLINK-35512 URL: https://issues.apache.org/jira/browse/FLINK-35512 Project: Flink Issue Type:

Re: [VOTE] Release flink-connector-jdbc v3.2.0, release candidate #2

> -1 (non-binding) > blocked by https://issues.apache.org/jira/browse/FLINK-35496. I just replied in https://issues.apache.org/jira/browse/FLINK-35496 , I think the API annotation understanding is incorrect in this case, hope to see your

[jira] [Created] (FLINK-35511) Enhance metrics. The incremental and full phases count the number of records separately

melin created FLINK-35511: - Summary: Enhance metrics. The incremental and full phases count the number of records separately Key: FLINK-35511 URL: https://issues.apache.org/jira/browse/FLINK-35511 Project:

[jira] [Created] (FLINK-35510) Implement basic incremental checkpoint for ForStStateBackend

Feifan Wang created FLINK-35510: --- Summary: Implement basic incremental checkpoint for ForStStateBackend Key: FLINK-35510 URL: https://issues.apache.org/jira/browse/FLINK-35510 Project: Flink

Re: [DISCUSS] Merge "flink run" and "flink run-application" in Flink 2.0

Hi Hang, Thank you for your inputs, both points make sense, updated the FLIP according to them. Best, Ferenc On Friday, 31 May 2024 at 04:31, Hang Ruan wrote: > > > Hi, Ferenc. > > +1 for this proposal. This FLIP will help to make the CLI clearer for users. > > I think we should better

[jira] [Created] (FLINK-35509) Slack community invite link has expired

Ufuk Celebi created FLINK-35509: --- Summary: Slack community invite link has expired Key: FLINK-35509 URL: https://issues.apache.org/jira/browse/FLINK-35509 Project: Flink Issue Type: Bug

Re: Slack Invite

I will update the Flink website. On Thu, May 30, 2024 at 10:08 AM gongzhongqiang wrote: > Hi, > The invite link : > > https://join.slack.com/t/apache-flink/shared_invite/zt-2jtsd06wy-31q_aELVkdc4dHsx0GMhOQ > > Best, > Zhongqiang Gong > > Nelson de Menezes Neto 于2024年5月30日周四 15:01写道： > > > Hey

Re: [DISCUSS] Flink CDC 3.2 Release Planning

Hey, qingsheng Thanks for driving the 3.2 release forward, it involved more contributions and work than we plan at the beginning. I’d like to help the release management as one release manager, feel free to ping me if you need any help from my side. Best, Leonard > 2024年6月3日 下午4:21，Qingsheng

Re: [DISCUSS] Flink CDC 3.2 Release Planning

Hi devs, Considering the current timeline and my workload, it would be great to have someone help with managing this release cycle of Flink CDC. Feel free to contact me if you are interested! Best, Qingsheng On Mon, May 27, 2024 at 7:39 PM Leonard Xu wrote: > > Hey, Xiqian > > > In 3.2 KO

[jira] [Created] (FLINK-35508) Use OceanBase LTS version Docker image in testing

He Wang created FLINK-35508: --- Summary: Use OceanBase LTS version Docker image in testing Key: FLINK-35508 URL: https://issues.apache.org/jira/browse/FLINK-35508 Project: Flink Issue Type:

Re: Native Kubernetes Task Managers

Hi Alexis, Are you describing the logic of adjusting the following part： | final String podName = String.format(TASK_MANAGER_POD_FORMAT, clusterId, currentMaxAttemptId, ++currentMaxPodId); | `currentMaxAttemptId` relates to the number of rebuilds for ResourceManager, and `currentMaxPodId`

Re: Native Kubernetes Task Managers

Ah no, I meant that I wouldn't use a stateful set, rather just adjust the names of the pods that are created/managed directly by the job manager. Regards, Alexis. Am Mo., 3. Juni 2024 um 07:31 Uhr schrieb Xintong Song < tonysong...@gmail.com>: > I may not have understood what you mean by the