[jira] [Commented] (FLINK-35697) Release Testing: Verify FLIP-451 Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863777#comment-17863777 ] Muhammet Orazov commented on FLINK-35697: - Hey all, I have finished the regress

[jira] [Commented] (FLINK-35697) Release Testing: Verify FLIP-451 Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863521#comment-17863521 ] Muhammet Orazov commented on FLINK-35697: - Thanks all (y) I have already done t

[jira] [Commented] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862775#comment-17862775 ] Muhammet Orazov commented on FLINK-34487: - Hey [~mapohl] , I have added backpor

[jira] [Commented] (FLINK-35697) Release Testing: Verify FLIP-451 Introduce timeout configuration to AsyncSink

[ https://issues.apache.org/jira/browse/FLINK-35697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862672#comment-17862672 ] Muhammet Orazov commented on FLINK-35697: - Hey [~chalixar], Thanks for the upda

[jira] [Commented] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17862670#comment-17862670 ] Muhammet Orazov commented on FLINK-34487: - Hey [~mapohl] ,   Sure I will creat

[jira] [Commented] (FLINK-35654) Add Flink CDC verification guide in docs

[ https://issues.apache.org/jira/browse/FLINK-35654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860391#comment-17860391 ] Muhammet Orazov commented on FLINK-35654: - Hey [~xiqian_yu], Great, thanks for t

[jira] [Commented] (FLINK-35565) Flink KafkaSource Batch Job Gets Into Infinite Loop after Resetting Offset

[ https://issues.apache.org/jira/browse/FLINK-35565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860130#comment-17860130 ] Muhammet Orazov commented on FLINK-35565: - The solution of https://issues.apache

[jira] [Commented] (FLINK-35670) Support Postgres CDC Pipeline Source

[ https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860127#comment-17860127 ] Muhammet Orazov commented on FLINK-35670: - Hello [~zhengjun.kissy] , I didn't f

[jira] [Commented] (FLINK-35670) Support Postgres CDC Pipeline Source

[ https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859498#comment-17859498 ] Muhammet Orazov commented on FLINK-35670: - Hey all, please feel free to assign t

[jira] [Commented] (FLINK-35671) Support Iceberg CDC Pipeline Sink

[ https://issues.apache.org/jira/browse/FLINK-35671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859499#comment-17859499 ] Muhammet Orazov commented on FLINK-35671: - Hey all, please feel free to assign t

[jira] [Created] (FLINK-35671) Support Iceberg CDC Pipeline Sink

Muhammet Orazov created FLINK-35671: --- Summary: Support Iceberg CDC Pipeline Sink Key: FLINK-35671 URL: https://issues.apache.org/jira/browse/FLINK-35671 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-35670) Support Postgres CDC Pipeline Source

[ https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muhammet Orazov updated FLINK-35670: Description: Similar to other [CDC pipeline sources|https://nightlies.apache.org/flink/fli

[jira] [Updated] (FLINK-35670) Support Postgres CDC Pipeline Source

[ https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muhammet Orazov updated FLINK-35670: Summary: Support Postgres CDC Pipeline Source (was: Support Postgres Pipeline Source) >

[jira] [Created] (FLINK-35670) Support Postgres Pipeline Source

Muhammet Orazov created FLINK-35670: --- Summary: Support Postgres Pipeline Source Key: FLINK-35670 URL: https://issues.apache.org/jira/browse/FLINK-35670 Project: Flink Issue Type: Improvemen

[jira] [Commented] (FLINK-35654) Add Flink CDC verification guide in docs

[ https://issues.apache.org/jira/browse/FLINK-35654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856450#comment-17856450 ] Muhammet Orazov commented on FLINK-35654: - Thanks [~xiqian_yu] ! This is indeed

[jira] [Commented] (FLINK-25538) [JUnit5 Migration] Module: flink-connector-kafka

[ https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856294#comment-17856294 ] Muhammet Orazov commented on FLINK-25538: - Hey all, I have create new PR [https

[jira] [Commented] (FLINK-35067) Support metadata 'op_type' virtual column for Postgres CDC Connector.

[ https://issues.apache.org/jira/browse/FLINK-35067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17856058#comment-17856058 ] Muhammet Orazov commented on FLINK-35067: - Hey all, [~loserwang1024] feel free

[jira] [Commented] (FLINK-25538) [JUnit5 Migration] Module: flink-connector-kafka

[ https://issues.apache.org/jira/browse/FLINK-25538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851573#comment-17851573 ] Muhammet Orazov commented on FLINK-25538: - Thanks [~martijnvisser], could you pl

[jira] [Created] (FLINK-35491) [JUnit5 Migration] Module: Flink CDC modules

Muhammet Orazov created FLINK-35491: --- Summary: [JUnit5 Migration] Module: Flink CDC modules Key: FLINK-35491 URL: https://issues.apache.org/jira/browse/FLINK-35491 Project: Flink Issue Type

[jira] [Commented] (FLINK-35490) [JUnit5 Migration] Module: Flink CDC flink-cdc-connect/flink-cdc-source-connectors

[ https://issues.apache.org/jira/browse/FLINK-35490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850663#comment-17850663 ] Muhammet Orazov commented on FLINK-35490: - I would be happy to work on this, ple

[jira] [Created] (FLINK-35490) [JUnit5 Migration] Module: Flink CDC flink-cdc-connect/flink-cdc-source-connectors

Muhammet Orazov created FLINK-35490: --- Summary: [JUnit5 Migration] Module: Flink CDC flink-cdc-connect/flink-cdc-source-connectors Key: FLINK-35490 URL: https://issues.apache.org/jira/browse/FLINK-35490

[jira] [Commented] (FLINK-34585) [JUnit5 Migration] Module: Flink CDC

[ https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850662#comment-17850662 ] Muhammet Orazov commented on FLINK-34585: - Hey all, Since this is lots of effor

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849229#comment-17849229 ] Muhammet Orazov commented on FLINK-34582: - Ohh no. Yes indeed you are right [~ma

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848998#comment-17848998 ] Muhammet Orazov commented on FLINK-34582: - At the moment the latest one for Linu

[jira] [Commented] (FLINK-34582) release build tools lost the newly added py3.11 packages for mac

[ https://issues.apache.org/jira/browse/FLINK-34582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848958#comment-17848958 ] Muhammet Orazov commented on FLINK-34582: - Hello [~hxb] ,   Any idea why we do

[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848510#comment-17848510 ] Muhammet Orazov commented on FLINK-34470: - Hey [~dongwoo.kim] , sorry for late r

[jira] [Commented] (FLINK-20402) Migrate test_tpch.sh

[ https://issues.apache.org/jira/browse/FLINK-20402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848150#comment-17848150 ] Muhammet Orazov commented on FLINK-20402: - Hey all, I would like to work on thi

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846857#comment-17846857 ] Muhammet Orazov commented on FLINK-20392: - [~mapohl] yes, I agree I think it is

[jira] [Comment Edited] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846609#comment-17846609 ] Muhammet Orazov edited comment on FLINK-20392 at 5/15/24 12:25 PM: ---

[jira] [Commented] (FLINK-20392) Migrating bash e2e tests to Java/Docker

[ https://issues.apache.org/jira/browse/FLINK-20392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846609#comment-17846609 ] Muhammet Orazov commented on FLINK-20392: - Thanks [~lorenzo.affetti] ,   {quote

[jira] [Commented] (FLINK-20400) Migrate test_streaming_sql.sh

[ https://issues.apache.org/jira/browse/FLINK-20400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17841555#comment-17841555 ] Muhammet Orazov commented on FLINK-20400: - Hello [~jark], [~mapohl], Could you

[jira] [Commented] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838471#comment-17838471 ] Muhammet Orazov commented on FLINK-34508: - The [YarnFileStageTestS3ITCase|https

[jira] [Commented] (FLINK-35129) Postgres source commits the offset after every multiple checkpoint cycles.

[ https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838427#comment-17838427 ] Muhammet Orazov commented on FLINK-35129: - Hey [~loserwang1024] , I would be hap

[jira] [Commented] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837531#comment-17837531 ] Muhammet Orazov commented on FLINK-34508: - Hey [~mapohl], On the GitHub CI, the

[jira] [Commented] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837530#comment-17837530 ] Muhammet Orazov commented on FLINK-34508: - In the Azure Pipeline the YarnFileSta

[jira] [Comment Edited] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486 ] Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 6:19 AM:

[jira] [Comment Edited] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486 ] Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 2:51 AM:

[jira] [Comment Edited] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486 ] Muhammet Orazov edited comment on FLINK-34508 at 4/16/24 2:49 AM:

[jira] [Commented] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837486#comment-17837486 ] Muhammet Orazov commented on FLINK-34508: - Hey all, I have add changes to remov

[jira] [Commented] (FLINK-35078) Include Flink CDC pipeline connector sub-modules in the CI runs

[ https://issues.apache.org/jira/browse/FLINK-35078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836021#comment-17836021 ] Muhammet Orazov commented on FLINK-35078: - I will be happy to address this. > I

[jira] [Created] (FLINK-35078) Include Flink CDC pipeline connector sub-modules in the CI runs

Muhammet Orazov created FLINK-35078: --- Summary: Include Flink CDC pipeline connector sub-modules in the CI runs Key: FLINK-35078 URL: https://issues.apache.org/jira/browse/FLINK-35078 Project: Flink

[jira] [Commented] (FLINK-34470) Transactional message + Table api kafka source with 'latest-offset' scan bound mode causes indefinitely hanging

[ https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835321#comment-17835321 ] Muhammet Orazov commented on FLINK-34470: - Hey [~dongwoo.kim] ,   Would you li

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

[ 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] [Commented] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830257#comment-17830257 ] Muhammet Orazov commented on FLINK-34487: - Hello [~mapohl], could you please hav

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

[ https://issues.apache.org/jira/browse/FLINK-33707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17830254#comment-17830254 ] Muhammet Orazov commented on FLINK-33707: - Hello, Would this affect the Flink 1

[jira] [Commented] (FLINK-34508) Migrate S3-related ITCases and e2e tests to Minio

[ https://issues.apache.org/jira/browse/FLINK-34508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822527#comment-17822527 ] Muhammet Orazov commented on FLINK-34508: - Hey [~mapohl], let me take this task

[jira] [Commented] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822511#comment-17822511 ] Muhammet Orazov commented on FLINK-34487: - Yes definitely! It is good initiative

[jira] [Commented] (FLINK-34487) Integrate tools/azure-pipelines/build-python-wheels.yml into GHA nightly workflow

[ https://issues.apache.org/jira/browse/FLINK-34487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822420#comment-17822420 ] Muhammet Orazov commented on FLINK-34487: - Hey [~mapohl], I'd like to work on th

[jira] [Commented] (FLINK-34419) flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21

[ https://issues.apache.org/jira/browse/FLINK-34419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821627#comment-17821627 ] Muhammet Orazov commented on FLINK-34419: - Hello [~mapohl],  Thanks! Could you

[jira] [Commented] (FLINK-34419) flink-docker's .github/workflows/snapshot.yml doesn't support JDK 17 and 21

[ https://issues.apache.org/jira/browse/FLINK-34419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821445#comment-17821445 ] Muhammet Orazov commented on FLINK-34419: - Hello [~mapohl] , I would like to wo