[jira] [Updated] (FLINK-34679) "Core Concept" Pages for Flink CDC Documentation

2024-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34679: --- Labels: pull-request-available (was: ) > "Core Concept" Pages for Flink CDC Documentation

[PR] [FLINK-34679][cdc] add doc under core-concept. [flink-cdc]

2024-03-15 Thread via GitHub
LYanquan opened a new pull request, #3153: URL: https://github.com/apache/flink-cdc/pull/3153 A follow up of https://github.com/apache/flink-cdc/pull/3146 to complete the docs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-34671) Update the content of README.md in FlinkCDC project

2024-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34671: --- Labels: pull-request-available (was: ) > Update the content of README.md in FlinkCDC

[PR] [FLINK-34671][cdc] update README.md file to update links and description. [flink-cdc]

2024-03-15 Thread via GitHub
LYanquan opened a new pull request, #3152: URL: https://github.com/apache/flink-cdc/pull/3152 Some links of document should be updated after https://github.com/apache/flink-cdc/pull/3146 merged. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-34700) CLONE - Create Git tag and mark version as released in Jira

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34700: Reporter: lincoln lee (was: Sergey Nuyanzin) > CLONE - Create Git tag and mark version as

[jira] [Assigned] (FLINK-34701) Publish the Dockerfiles for the new release

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34701: --- Assignee: lincoln lee (was: Jing Ge) > Publish the Dockerfiles for the new release >

[jira] [Updated] (FLINK-34701) Publish the Dockerfiles for the new release

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34701: Reporter: lincoln lee (was: Sergey Nuyanzin) > Publish the Dockerfiles for the new release >

[jira] [Updated] (FLINK-34701) Publish the Dockerfiles for the new release

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34701: Summary: Publish the Dockerfiles for the new release (was: CLONE - Publish the Dockerfiles for

[jira] [Updated] (FLINK-34700) Create Git tag and mark version as released in Jira

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34700: Summary: Create Git tag and mark version as released in Jira (was: CLONE - Create Git tag and

[jira] [Closed] (FLINK-34700) Create Git tag and mark version as released in Jira

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34700. --- Resolution: Fixed https://github.com/apache/flink/releases/tag/release-1.19.0 > Create Git tag and

[jira] [Assigned] (FLINK-34700) CLONE - Create Git tag and mark version as released in Jira

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34700: --- Assignee: (was: Jing Ge) > CLONE - Create Git tag and mark version as released in Jira

[jira] [Closed] (FLINK-34699) Deploy artifacts to Maven Central Repository

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34699. --- Resolution: Fixed release: [https://dist.apache.org/repos/dist/release/flink/flink-1.19.0/] dev

[jira] [Assigned] (FLINK-34700) CLONE - Create Git tag and mark version as released in Jira

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34700: --- Assignee: lincoln lee > CLONE - Create Git tag and mark version as released in Jira >

[jira] [Assigned] (FLINK-34699) CLONE - Deploy artifacts to Maven Central Repository

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34699: --- Assignee: lincoln lee (was: Jing Ge) > CLONE - Deploy artifacts to Maven Central

[jira] [Updated] (FLINK-34699) CLONE - Deploy artifacts to Maven Central Repository

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34699: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > CLONE - Deploy artifacts to Maven Central

[jira] [Updated] (FLINK-34699) Deploy artifacts to Maven Central Repository

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34699: Summary: Deploy artifacts to Maven Central Repository (was: CLONE - Deploy artifacts to Maven

[jira] [Closed] (FLINK-34698) Deploy Python artifacts to PyPI

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34698. --- Resolution: Fixed pypi: [https://pypi.org/project/apache-flink/#files]

[jira] [Assigned] (FLINK-34698) Deploy Python artifacts to PyPI

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34698: --- Assignee: lincoln lee (was: Jing Ge) > Deploy Python artifacts to PyPI >

[jira] [Created] (FLINK-34701) CLONE - Publish the Dockerfiles for the new release

2024-03-15 Thread lincoln lee (Jira)
lincoln lee created FLINK-34701: --- Summary: CLONE - Publish the Dockerfiles for the new release Key: FLINK-34701 URL: https://issues.apache.org/jira/browse/FLINK-34701 Project: Flink Issue

[jira] [Updated] (FLINK-34698) Deploy Python artifacts to PyPI

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34698: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Deploy Python artifacts to PyPI >

[jira] [Updated] (FLINK-34698) Deploy Python artifacts to PyPI

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34698: Summary: Deploy Python artifacts to PyPI (was: CLONE - Deploy Python artifacts to PyPI) >

[jira] [Updated] (FLINK-34697) Finalize release 1.19.0

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34697: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Finalize release 1.19.0 > ---

[jira] [Assigned] (FLINK-34697) Finalize release 1.19.0

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34697: --- Assignee: lincoln lee (was: Jing Ge) > Finalize release 1.19.0 > ---

[jira] [Updated] (FLINK-34697) Finalize release 1.19.0

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34697: Labels: release (was: ) > Finalize release 1.19.0 > --- > >

[jira] [Created] (FLINK-34700) CLONE - Create Git tag and mark version as released in Jira

2024-03-15 Thread lincoln lee (Jira)
lincoln lee created FLINK-34700: --- Summary: CLONE - Create Git tag and mark version as released in Jira Key: FLINK-34700 URL: https://issues.apache.org/jira/browse/FLINK-34700 Project: Flink

[jira] [Created] (FLINK-34699) CLONE - Deploy artifacts to Maven Central Repository

2024-03-15 Thread lincoln lee (Jira)
lincoln lee created FLINK-34699: --- Summary: CLONE - Deploy artifacts to Maven Central Repository Key: FLINK-34699 URL: https://issues.apache.org/jira/browse/FLINK-34699 Project: Flink Issue

[jira] [Updated] (FLINK-34697) Finalize release 1.19.0

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34697: Fix Version/s: 1.19.0 > Finalize release 1.19.0 > --- > >

[jira] [Created] (FLINK-34697) Finalize release 1.19.0

2024-03-15 Thread lincoln lee (Jira)
lincoln lee created FLINK-34697: --- Summary: Finalize release 1.19.0 Key: FLINK-34697 URL: https://issues.apache.org/jira/browse/FLINK-34697 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-34698) CLONE - Deploy Python artifacts to PyPI

2024-03-15 Thread lincoln lee (Jira)
lincoln lee created FLINK-34698: --- Summary: CLONE - Deploy Python artifacts to PyPI Key: FLINK-34698 URL: https://issues.apache.org/jira/browse/FLINK-34698 Project: Flink Issue Type: Sub-task

Re: [PR] Bump follow-redirects from 1.15.1 to 1.15.6 in /flink-runtime-web/web-dashboard [flink]

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

[PR] Bump follow-redirects from 1.15.1 to 1.15.6 in /flink-runtime-web/web-dashboard [flink]

2024-03-15 Thread via GitHub
dependabot[bot] opened a new pull request, #24507: URL: https://github.com/apache/flink/pull/24507 Bumps [follow-redirects](https://github.com/follow-redirects/follow-redirects) from 1.15.1 to 1.15.6. Commits

[PR] Bump org.apache.zookeeper:zookeeper from 3.6.3 to 3.8.4 [flink-ml]

2024-03-15 Thread via GitHub
dependabot[bot] opened a new pull request, #259: URL: https://github.com/apache/flink-ml/pull/259 Bumps org.apache.zookeeper:zookeeper from 3.6.3 to 3.8.4. [![Dependabot compatibility

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

2024-03-15 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-34643. - Fix Version/s: 1.20.0 Resolution: Fixed Merged into master as

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
rkhachatryan merged PR #24484: URL: https://github.com/apache/flink/pull/24484 -- 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-34696) GSRecoverableWriterCommitter is generating excessive data blobs

2024-03-15 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827590#comment-17827590 ] Galen Warren commented on FLINK-34696: -- One more thing, regarding: {quote}To mitigate this problem,

Re: [PR] [table] Add support for temporal join on rolling aggregates [flink]

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

[PR] [table] Add support for temporal join on rolling aggregates [flink]

2024-03-15 Thread via GitHub
schevalley2 opened a new pull request, #24506: URL: https://github.com/apache/flink/pull/24506 ## What is the purpose of the change This is more of a proposal to demonstrate a possible fix. I am looking for feedback for people that are more knowledgeable. Following this thread

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

2024-03-15 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827568#comment-17827568 ] Galen Warren edited comment on FLINK-34696 at 3/15/24 5:49 PM: --- No, this

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

2024-03-15 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827568#comment-17827568 ] Galen Warren commented on FLINK-34696: -- No, this just moves the storage of the temporary files to a

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

2024-03-15 Thread Tobias Hofer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827557#comment-17827557 ] Tobias Hofer commented on FLINK-34696: -- Will the temporary bucket prevent the use of object

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

2024-03-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-34696: --- Issue Type: Improvement (was: Bug) > GSRecoverableWriterCommitter is generating excessive

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

2024-03-15 Thread Galen Warren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827528#comment-17827528 ] Galen Warren commented on FLINK-34696: -- Yes, the issue is recoverability. However, there is one

Re: [PR] [hotfix] In case of unexpected errors do not loose the primary failur [flink]

2024-03-15 Thread via GitHub
pnowojski merged PR #24487: URL: https://github.com/apache/flink/pull/24487 -- 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] [hotfix] In case of unexpected errors do not loose the primary failur [flink]

2024-03-15 Thread via GitHub
pnowojski commented on PR #24487: URL: https://github.com/apache/flink/pull/24487#issuecomment-1999835148 Merging. Builds are failing due to unrelated test instabilities/bugs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

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

2024-03-15 Thread Simon-Shlomo Poil (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon-Shlomo Poil updated FLINK-34696: -- Description: *Description:* The `composeBlobs` method in

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

2024-03-15 Thread Simon-Shlomo Poil (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon-Shlomo Poil updated FLINK-34696: -- Description: The `composeBlobs` method in

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

2024-03-15 Thread Simon-Shlomo Poil (Jira)
Simon-Shlomo Poil created FLINK-34696: - Summary: GSRecoverableWriterCommitter is generating excessive data blobs Key: FLINK-34696 URL: https://issues.apache.org/jira/browse/FLINK-34696 Project:

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
rkhachatryan commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1526332843 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## Review Comment: Done. -- This is an automated message from the Apache

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
rkhachatryan commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1526329297 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/logging/LoggerAuditingExtension.java: ## @@ -81,7 +81,9 @@ public void

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
XComp commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1526327468 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -205,6 +268,8 @@ private static JobID runJob(ClusterClient clusterClient) throws

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-15 Thread via GitHub
Zakelly commented on PR #24497: URL: https://github.com/apache/flink/pull/24497#issuecomment-1999698683 @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.

[jira] [Closed] (FLINK-33816) SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain failed due async checkpoint triggering not being completed

2024-03-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-33816. -- Fix Version/s: 2.0.0 Assignee: jiabao.sun Resolution: Fixed merged commit

[jira] [Comment Edited] (FLINK-33816) SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain failed due async checkpoint triggering not being completed

2024-03-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827503#comment-17827503 ] Piotr Nowojski edited comment on FLINK-33816 at 3/15/24 1:33 PM: - Thanks

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
rkhachatryan commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1526297069 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -205,6 +268,8 @@ private static JobID runJob(ClusterClient clusterClient)

Re: [PR] [FLINK-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain [flink]

2024-03-15 Thread via GitHub
pnowojski merged PR #24016: URL: https://github.com/apache/flink/pull/24016 -- 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-33816][streaming] Fix unstable test SourceStreamTaskTest.testTriggeringStopWithSavepointWithDrain [flink]

2024-03-15 Thread via GitHub
pnowojski commented on PR #24016: URL: https://github.com/apache/flink/pull/24016#issuecomment-1999674592 Thanks for the fix! -- 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

[jira] [Resolved] (FLINK-34194) Upgrade Flink CI Docker container to Ubuntu 22.04

2024-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34194. --- Fix Version/s: 1.20.0 Resolution: Fixed master:

Re: [PR] [FLINK-34194][ci] Updates test CI container to be based on Ubuntu 22.04 [flink]

2024-03-15 Thread via GitHub
XComp merged PR #24165: URL: https://github.com/apache/flink/pull/24165 -- 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-34533) Propose a pull request for website updates

2024-03-15 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34533. --- Resolution: Won't Fix > Propose a pull request for website updates >

[jira] [Commented] (FLINK-34695) Move Flink's CI docker container into a public repo

2024-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827500#comment-17827500 ] Matthias Pohl commented on FLINK-34695: --- This should be discussed in the dev ML before going ahead

Re: [PR] [FLINK-34194][ci] Updates test CI container to be based on Ubuntu 22.04 [flink]

2024-03-15 Thread via GitHub
XComp commented on PR #24165: URL: https://github.com/apache/flink/pull/24165#issuecomment-1999640749 I agree with you. I had this discussion with @zentol recently as well. Ideally, we should move the Docker image into a Apache-owned repo and push to a public Docker registry. I created

[jira] [Commented] (FLINK-34695) Move Flink's CI docker container into a public repo

2024-03-15 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827499#comment-17827499 ] Matthias Pohl commented on FLINK-34695: --- {quote} Where shall the Docker image code be located?

[jira] [Commented] (FLINK-34693) Memory leak in KafkaWriter

2024-03-15 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827496#comment-17827496 ] Leonard Xu commented on FLINK-34693: [~srichter] Thanks for your report, but the Affects version

[jira] [Commented] (FLINK-34693) Memory leak in KafkaWriter

2024-03-15 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827495#comment-17827495 ] Leonard Xu commented on FLINK-34693: [~renqs] Would you like look into this issue? > Memory leak in

[jira] [Created] (FLINK-34695) Move Flink's CI docker container into a public repo

2024-03-15 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34695: - Summary: Move Flink's CI docker container into a public repo Key: FLINK-34695 URL: https://issues.apache.org/jira/browse/FLINK-34695 Project: Flink Issue

[jira] [Created] (FLINK-34694) Delete num of associations for streaming outer join

2024-03-15 Thread Roman Boyko (Jira)
Roman Boyko created FLINK-34694: --- Summary: Delete num of associations for streaming outer join Key: FLINK-34694 URL: https://issues.apache.org/jira/browse/FLINK-34694 Project: Flink Issue

Re: [PR] [FLINK-31472] Remove external timer service reference from AsyncSinkThrottling Test [flink]

2024-03-15 Thread via GitHub
XComp commented on PR #24481: URL: https://github.com/apache/flink/pull/24481#issuecomment-1999570415 @dannycranmer do you have capacity to look into it. I saw that you reviewed the FLINK-25793 work which introduced this test. I'm not too familiar with this part of the code. That's why I'd

[jira] [Updated] (FLINK-34693) Memory leak in KafkaWriter

2024-03-15 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-34693: --- Attachment: (was: image-2024-03-15-10-30-50-902.png) > Memory leak in KafkaWriter >

[jira] [Updated] (FLINK-34693) Memory leak in KafkaWriter

2024-03-15 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-34693: --- Description: KafkaWriter is keeping objects in Dequeue of closeables

Re: [PR] [FLINK-34516] Move CheckpointingMode to flink-core [flink]

2024-03-15 Thread via GitHub
Zakelly commented on PR #24381: URL: https://github.com/apache/flink/pull/24381#issuecomment-1999431941 @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.

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-15 Thread via GitHub
Zakelly commented on PR #24497: URL: https://github.com/apache/flink/pull/24497#issuecomment-1999420909 @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.

Re: [PR] [FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files [flink]

2024-03-15 Thread via GitHub
Zakelly commented on PR #24480: URL: https://github.com/apache/flink/pull/24480#issuecomment-1999414694 > @Zakelly @fredia Could you take a look ? @masteryhx How about waiting for the FLINK-34668, where some new state handles will be introduced. -- This is an automated message

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

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827462#comment-17827462 ] Jiabao Sun commented on FLINK-34585: Thanks [~kunni] for volunteering. Assigned to you. > [JUnit5

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

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun reassigned FLINK-34585: -- Assignee: LvYanquan > [JUnit5 Migration] Module: Flink CDC >

[jira] [Commented] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17827460#comment-17827460 ] Jiabao Sun commented on FLINK-25544: master: 62f44e0118539c1ed0dedf47099326f97c9d0427 > [JUnit5

[jira] [Updated] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-25544: --- Release Note: (was: master: 62f44e0118539c1ed0dedf47099326f97c9d0427) > [JUnit5 Migration]

[jira] [Resolved] (FLINK-25544) [JUnit5 Migration] Module: flink-streaming-java

2024-03-15 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun resolved FLINK-25544. Fix Version/s: 1.20.0 Release Note: master: 62f44e0118539c1ed0dedf47099326f97c9d0427

Re: [PR] [FLINK-25544][streaming][JUnit5 Migration] The runtime package of module flink-stream-java [flink]

2024-03-15 Thread via GitHub
Jiabao-Sun merged PR #24483: URL: https://github.com/apache/flink/pull/24483 -- 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-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-15 Thread via GitHub
masteryhx commented on code in PR #24322: URL: https://github.com/apache/flink/pull/24322#discussion_r1526040906 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBNativeMetricOptionsTest.java: ## @@ -29,7 +29,11 @@

Re: [PR] [FLINK-34593][release] Add release note for version 1.19 [flink]

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

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-15 Thread via GitHub
lincoln-lil merged PR #24394: URL: https://github.com/apache/flink/pull/24394 -- 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-34690] Cast decimal to VARCHAR/INT/BIGINT/LARGEINT as primary … [flink-cdc]

2024-03-15 Thread via GitHub
loserwang1024 commented on code in PR #3150: URL: https://github.com/apache/flink-cdc/pull/3150#discussion_r1526000193 ##

[jira] [Updated] (FLINK-34693) Memory leak in KafkaWriter

2024-03-15 Thread Stefan Richter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-34693: --- Description: KafkaWriter is keeping instances of {{TwoPhaseCommitProducer}} in Dequeue of

[jira] [Created] (FLINK-34693) Memory leak in KafkaWriter

2024-03-15 Thread Stefan Richter (Jira)
Stefan Richter created FLINK-34693: -- Summary: Memory leak in KafkaWriter Key: FLINK-34693 URL: https://issues.apache.org/jira/browse/FLINK-34693 Project: Flink Issue Type: Bug

Re: [PR] [FLINK-34533][release] Add release note for version 1.19 [flink]

2024-03-15 Thread via GitHub
lincoln-lil commented on PR #24394: URL: https://github.com/apache/flink/pull/24394#issuecomment-1999261121 Will merge this. -- 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.

Re: [PR] Update oracle-cdc.md [flink-cdc]

2024-03-15 Thread via GitHub
e-mhui commented on PR #3151: URL: https://github.com/apache/flink-cdc/pull/3151#issuecomment-1999260453 If you are using Flink SQL, you need to add "debezium" as a prefix. However, when using the DataStream API, you don't need the "debezium" prefix. -- This is an automated

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
XComp commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1525984268 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/logging/LoggerAuditingExtension.java: ## @@ -81,7 +81,9 @@ public void

Re: [PR] [release] Update version to 1.9-SNAPSHOT [flink-kubernetes-operator]

2024-03-15 Thread via GitHub
mxm merged PR #798: URL: https://github.com/apache/flink-kubernetes-operator/pull/798 -- 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] [release] Adjust website for Kubernetes operator 1.8.0 release [flink-web]

2024-03-15 Thread via GitHub
mxm commented on PR #726: URL: https://github.com/apache/flink-web/pull/726#issuecomment-1999239653 Yes, the blog post is still a TODO, although it isn't strictly needed for the release. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread

2024-03-15 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinzhong Li updated FLINK-34670: Description: Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl is

[jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread

2024-03-15 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinzhong Li updated FLINK-34670: Description: Now, the asyncOperations ThreadPoolExecutor of SubtaskCheckpointCoordinatorImpl is

[jira] [Updated] (FLINK-34670) The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one worker thread

2024-03-15 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jinzhong Li updated FLINK-34670: Summary: The asyncOperationsThreadPool in SubtaskCheckpointCoordinatorImpl can only create one

[PR] Update oracle-cdc.md [flink-cdc]

2024-03-15 Thread via GitHub
stardustman opened a new pull request, #3151: URL: https://github.com/apache/flink-cdc/pull/3151 fix error the "log.mining.strategy" should be start with prefix "debezium." according to

Re: [PR] [FLINK-34643][tests] Fix JobIDLoggingITCase [flink]

2024-03-15 Thread via GitHub
XComp commented on code in PR #24484: URL: https://github.com/apache/flink/pull/24484#discussion_r1525054790 ## flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java: ## @@ -116,18 +116,55 @@ public void testJobIDLogging(@InjectClusterClient

Re: [PR] [FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files [flink]

2024-03-15 Thread via GitHub
masteryhx commented on PR #24480: URL: https://github.com/apache/flink/pull/24480#issuecomment-1999194013 @Zakelly @fredia Could you take 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 to

[jira] [Updated] (FLINK-34677) Refactor the structure of documentation for Flink CDC

2024-03-15 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-34677: --- Component/s: Documentation > Refactor the structure of documentation for Flink CDC >

Re: [PR] [FLINK-34409][ci] Enables (most) tests that were disabled for the AdaptiveScheduler due to missing features [flink]

2024-03-15 Thread via GitHub
XComp commented on PR #24285: URL: https://github.com/apache/flink/pull/24285#issuecomment-1999190279 I fixed an indentation issue and rebased the branch. @MartijnVisser @JingGe can one of you go ahead and approve this one? So that we can finalize the efforts and merge this PR. I'm going

Re: [PR] [FLINK-34546] Emit span with failure labels on failure in AdaptiveScheduler. [flink]

2024-03-15 Thread via GitHub
StefanRRichter merged PR #24498: URL: https://github.com/apache/flink/pull/24498 -- 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-34660][checkpoint] Parse cluster configuration for AutoRescalingITCase#testCheckpointRescalingInKeyedState [flink]

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

Re: [PR] [Oracle][MySQL][SqlServer][PostgresSQL] Fix Oracle/MySQL/SqlServer/PostgresSQL CDC parser schema change event failed [flink-cdc]

2024-03-15 Thread via GitHub
e-mhui commented on PR #2315: URL: https://github.com/apache/flink-cdc/pull/2315#issuecomment-1999166980 > > ```sql > > debezium.database.history.store.only.captured.tables.ddl > > ``` > > I read the doc

  1   2   >