[jira] [Created] (FLINK-35738) Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

Rui Fan created FLINK-35738: --- Summary: Release Testing: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order Key: FLINK-35738 URL: https://issues.apache.

[jira] [Closed] (FLINK-35606) Release Testing Instructions: Verify FLINK-26050 Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35606. --- Resolution: Fixed > Release Testing Instructions: Verify FLINK-26050 Too many small sst files in > rocksdb

[jira] [Closed] (FLINK-35608) Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-35608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-35608. --- Resolution: Won't Fix > Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause > -

[jira] [Commented] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861325#comment-17861325 ] Yuxin Tan commented on FLINK-35690: --- [~fanrui] Thanks for the reminding. We have assig

[jira] [Assigned] (FLINK-35690) Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integration with Apache Celeborn

[ https://issues.apache.org/jira/browse/FLINK-35690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35690: -- Assignee: xuhuang > Release Testing: Verify FLIP-459: Support Flink hybrid shuffle integratio

[jira] [Comment Edited] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861319#comment-17861319 ] Feng Jin edited comment on FLINK-35187 at 7/2/24 6:23 AM: -- Rele

[jira] [Commented] (FLINK-35187) FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

[ https://issues.apache.org/jira/browse/FLINK-35187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861319#comment-17861319 ] Feng Jin commented on FLINK-35187: -- Release Note: In 1.20, we introduced the Materiali

[jira] [Resolved] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-35727. Fix Version/s: 2.0.0 1.18.2 1.20.0

[jira] [Assigned] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-35727: -- Assignee: Samrat Deb > "Run kubernetes pyflink application test" failed due to access

[jira] [Resolved] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

[ https://issues.apache.org/jira/browse/FLINK-35728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-35728. Fix Version/s: 2.0.0 1.18.2 1.20.0

[jira] [Assigned] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

[ https://issues.apache.org/jira/browse/FLINK-35728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-35728: -- Assignee: Samrat Deb > PyFlink end-to-end test because miniconda couldn't be download

[jira] [Updated] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown

[ https://issues.apache.org/jira/browse/FLINK-35737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-35737: Description: MemoryExecutionGraphInfoStore registers a ShutdownHook upon construction and deregis

[jira] [Created] (FLINK-35737) Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown

Feng Jiajie created FLINK-35737: --- Summary: Prevent Memory Leak by Closing MemoryExecutionGraphInfoStore on MiniCluster Shutdown Key: FLINK-35737 URL: https://issues.apache.org/jira/browse/FLINK-35737 Pr

[jira] [Updated] (FLINK-33995) Add test in test_file_sink.sh s3 StreamingFileSink for csv

[ https://issues.apache.org/jira/browse/FLINK-33995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-33995: --- Affects Version/s: 2.0.0 > Add test in test_file_sink.sh s3 StreamingFileSink for csv > ---

[jira] [Commented] (FLINK-35608) Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-35608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861291#comment-17861291 ] Rui Fan commented on FLINK-35608: - Hi [~jhughes] , thanks for your feedback! If this Ji

[jira] [Resolved] (FLINK-35734) Do not override the user-defined checkpoint interval in continuous mode.

[ https://issues.apache.org/jira/browse/FLINK-35734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu resolved FLINK-35734. --- Resolution: Fixed > Do not override the user-defined checkpoint interval in continuous mode. > -

[jira] [Comment Edited] (FLINK-35734) Do not override the user-defined checkpoint interval in continuous mode.

[ https://issues.apache.org/jira/browse/FLINK-35734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861162#comment-17861162 ] dalongliu edited comment on FLINK-35734 at 7/2/24 1:32 AM: --- Me

[jira] [Commented] (FLINK-35498) Unexpected argument name conflict error when do extract method params from udf

[ https://issues.apache.org/jira/browse/FLINK-35498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861290#comment-17861290 ] lincoln lee commented on FLINK-35498: - fixed in master: 84165b23cfc756881d43cdab1b26

[jira] [Updated] (FLINK-35498) Unexpected argument name conflict error when do extract method params from udf

[ https://issues.apache.org/jira/browse/FLINK-35498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35498: Fix Version/s: 2.0.0 1.20.0 1.19.2 > Unexpected argument nam

[jira] [Updated] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-34914: - Description: As the application scenario of `Catalog` expands, which widely applied in services such as

[jira] [Updated] (FLINK-34914) FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-34914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-34914: - Description: As the application scenario of `Catalog` expands, which widely applied in services such as

[jira] [Commented] (FLINK-35608) Release Testing Instructions: Verify FLIP-376: Add DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-35608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861214#comment-17861214 ] Jim Hughes commented on FLINK-35608: I did the implementation for FLIP-376 / FLINK-3

[jira] [Commented] (FLINK-35663) Release Testing: FLIP-436: Introduce Catalog-related Syntax

[ https://issues.apache.org/jira/browse/FLINK-35663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861211#comment-17861211 ] Yubin Li commented on FLINK-35663: -- [~ferenc-csaky] Thanks for the volunteering(y) > R

[jira] [Commented] (FLINK-35727) "Run kubernetes pyflink application test" failed due to access denied issue

[ https://issues.apache.org/jira/browse/FLINK-35727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861208#comment-17861208 ] Samrat Deb commented on FLINK-35727: i would like to work on the issue .  can you pl

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861194#comment-17861194 ] Matthias Pohl edited comment on FLINK-35042 at 7/1/24 3:18 PM: ---

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861194#comment-17861194 ] Matthias Pohl edited comment on FLINK-35042 at 7/1/24 3:16 PM: ---

[jira] [Commented] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server

[ https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861196#comment-17861196 ] Matthias Pohl commented on FLINK-34919: --- 2.0: https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-34919) WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails starting REST server

[ https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34919: -- Affects Version/s: 2.0.0 > WebMonitorEndpointTest.cleansUpExpiredExecutionGraphs fails startin

[jira] [Comment Edited] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861194#comment-17861194 ] Matthias Pohl edited comment on FLINK-35042 at 7/1/24 3:11 PM: ---

[jira] [Commented] (FLINK-35042) Streaming File Sink s3 end-to-end test failed as TM lost

[ https://issues.apache.org/jira/browse/FLINK-35042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861194#comment-17861194 ] Matthias Pohl commented on FLINK-35042: --- https://dev.azure.com/apache-flink/apache

[jira] [Assigned] (FLINK-35734) Do not override the user-defined checkpoint interval in continuous mode.

[ https://issues.apache.org/jira/browse/FLINK-35734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu reassigned FLINK-35734: - Assignee: Feng Jin > Do not override the user-defined checkpoint interval in continuous mode. >

[jira] [Commented] (FLINK-35734) Do not override the user-defined checkpoint interval in continuous mode.

[ https://issues.apache.org/jira/browse/FLINK-35734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861162#comment-17861162 ] dalongliu commented on FLINK-35734: --- Merged in master: 3aa3c48ab19360ec3055b3ae791d64e

[jira] [Comment Edited] (FLINK-35695) Release Testing: Verify FLINK-32315: Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-35695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861156#comment-17861156 ] Mate Czagany edited comment on FLINK-35695 at 7/1/24 1:16 PM:

[jira] [Commented] (FLINK-35695) Release Testing: Verify FLINK-32315: Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-35695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861156#comment-17861156 ] Mate Czagany commented on FLINK-35695: -- h2. Setup Build flink and flink-docker usi

[jira] [Updated] (FLINK-35695) Release Testing: Verify FLINK-32315: Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-35695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mate Czagany updated FLINK-35695: - Attachment: image-2024-07-01-14-54-17-770.png > Release Testing: Verify FLINK-32315: Support loc

[jira] [Updated] (FLINK-35695) Release Testing: Verify FLINK-32315: Support local file upload in K8s mode

[ https://issues.apache.org/jira/browse/FLINK-35695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mate Czagany updated FLINK-35695: - Attachment: image-2024-07-01-15-04-53-764.png > Release Testing: Verify FLINK-32315: Support loc

[jira] [Created] (FLINK-35736) Add E2e migration scripts for Flink CDC

yux created FLINK-35736: --- Summary: Add E2e migration scripts for Flink CDC Key: FLINK-35736 URL: https://issues.apache.org/jira/browse/FLINK-35736 Project: Flink Issue Type: Improvement Compo

[jira] [Commented] (FLINK-35728) PyFlink end-to-end test because miniconda couldn't be downloaded

[ https://issues.apache.org/jira/browse/FLINK-35728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861122#comment-17861122 ] Samrat Deb commented on FLINK-35728: Hi Matthias,  i think there is some issue with

[jira] [Commented] (FLINK-35022) Add TypeInformed Element Converter for DynamoDbSink

[ https://issues.apache.org/jira/browse/FLINK-35022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861118#comment-17861118 ] Hong Liang Teoh commented on FLINK-35022: -  merged commit [{{36479a9}}|https://

[jira] [Assigned] (FLINK-35735) Don't list catalogs when closing session

[ https://issues.apache.org/jira/browse/FLINK-35735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-35735: - Assignee: xuyang > Don't list catalogs when closing session > -

[jira] [Updated] (FLINK-35734) Do not override the user-defined checkpoint interval in continuous mode.

[ https://issues.apache.org/jira/browse/FLINK-35734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jin updated FLINK-35734: - Summary: Do not override the user-defined checkpoint interval in continuous mode. (was: Not override th

[jira] [Created] (FLINK-35735) Don't list catalogs when closing session

Shengkai Fang created FLINK-35735: - Summary: Don't list catalogs when closing session Key: FLINK-35735 URL: https://issues.apache.org/jira/browse/FLINK-35735 Project: Flink Issue Type: Improv