[jira] [Commented] (FLINK-35615) CDC3.0, the pipeline of mysql-doris , do not support the MySQL field type timestamp(6)

[ https://issues.apache.org/jira/browse/FLINK-35615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860925#comment-17860925 ] yux commented on FLINK-35615: - I could reproduce this issue by inserting a timestamp with no

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860921#comment-17860921 ] Hilmi Al Fatih commented on FLINK-34554: [~fpaul] From theoretical perspective,

[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=17860863#comment-17860863 ] Matthias Pohl commented on FLINK-35728: --- Probably related infrastructure issue: FL

[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=17860862#comment-17860862 ] Matthias Pohl commented on FLINK-35727: --- Probably related infrastructure issue: FL

[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=17860861#comment-17860861 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

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

[ https://issues.apache.org/jira/browse/FLINK-35727 ] Matthias Pohl deleted comment on FLINK-35727: --- was (Author: mapohl): https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=60538&view=logs&j=bea52777-eaf8-5663-8482-18fbc36

[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=17860859#comment-17860859 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

[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=17860857#comment-17860857 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

[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=17860860#comment-17860860 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can.

[ https://issues.apache.org/jira/browse/FLINK-35721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-35721: Fix Version/s: 1.19.2 > I found out that in the Flink SQL documentation it says that Doubl

[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=17860856#comment-17860856 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

[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=17860855#comment-17860855 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-35698) Parquet connector fails to load ROW after save

[ https://issues.apache.org/jira/browse/FLINK-35698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-35698: Fix Version/s: 1.20.0 1.19.2 > Parquet connector fails to load ROW afte

[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=17860854#comment-17860854 ] Matthias Pohl commented on FLINK-35728: --- https://dev.azure.com/apache-flink/apache

[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=17860853#comment-17860853 ] Matthias Pohl commented on FLINK-35728: --- https://dev.azure.com/apache-flink/apache

[jira] [Updated] (FLINK-35685) Some metrics in the MetricStore are duplicated when increasing or decreasing task parallelism

[ https://issues.apache.org/jira/browse/FLINK-35685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-35685: Fix Version/s: 1.20.0 1.19.2 > Some metrics in the MetricStore are dupl

[jira] [Commented] (FLINK-35562) WindowTableFunctionProcTimeRestoreTest produced no output for 900 seconds

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

[jira] [Created] (FLINK-35729) HiveITCase.testReadWriteHive

Matthias Pohl created FLINK-35729: - Summary: HiveITCase.testReadWriteHive Key: FLINK-35729 URL: https://issues.apache.org/jira/browse/FLINK-35729 Project: Flink Issue Type: Bug Comp

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

Matthias Pohl created FLINK-35728: - Summary: PyFlink end-to-end test because miniconda couldn't be downloaded Key: FLINK-35728 URL: https://issues.apache.org/jira/browse/FLINK-35728 Project: Flink

[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=17860848#comment-17860848 ] Matthias Pohl commented on FLINK-35727: --- https://dev.azure.com/apache-flink/apache

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

Matthias Pohl created FLINK-35727: - Summary: "Run kubernetes pyflink application test" failed due to access denied issue Key: FLINK-35727 URL: https://issues.apache.org/jira/browse/FLINK-35727 Project

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860834#comment-17860834 ] Fabian Paul commented on FLINK-34554: - [~hilmialf] thanks for the very detailed anal

[jira] [Commented] (FLINK-34554) Using EXACTLY_ONCE with KafkaSink cause broker's OOM due to newly created transactionalId per checkpoint

[ https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860823#comment-17860823 ] Martijn Visser commented on FLINK-34554: [~loserwang1024] I think that would req

[jira] [Created] (FLINK-35726) Data Stream to Table API converts Map to RAW 'java.util.Map'

David Perkins created FLINK-35726: - Summary: Data Stream to Table API converts Map to RAW 'java.util.Map' Key: FLINK-35726 URL: https://issues.apache.org/jira/browse/FLINK-35726 Project: Flink

[jira] [Closed] (FLINK-35640) Deprecate Flink 1.15 in the operator

[ https://issues.apache.org/jira/browse/FLINK-35640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35640. -- Assignee: Mate Czagany Resolution: Fixed merged to main f2adb1593393765d7b4c03213fda31e3683b120a

[jira] [Commented] (FLINK-25453) LocalFileSystem#listStatus throws FileNotFoundException when a file is deleted concurrently in the directory

[ https://issues.apache.org/jira/browse/FLINK-25453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860817#comment-17860817 ] Matthias Pohl commented on FLINK-25453: --- {code} org.apache.flink.runtime.JobExcept

[jira] [Assigned] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

[ https://issues.apache.org/jira/browse/FLINK-33496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes reassigned FLINK-33496: -- Assignee: Jim Hughes > Expose DISTRIBUTED BY clause via parser >

[jira] [Updated] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

[ https://issues.apache.org/jira/browse/FLINK-33497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jim Hughes updated FLINK-33497: --- Parent: (was: FLINK-33494) Issue Type: New Feature (was: Sub-task) > Update the Kafka c

[jira] [Created] (FLINK-35725) Translate new DISTRIBUTED BY documentation into Chinese

Jim Hughes created FLINK-35725: -- Summary: Translate new DISTRIBUTED BY documentation into Chinese Key: FLINK-35725 URL: https://issues.apache.org/jira/browse/FLINK-35725 Project: Flink Issue Typ

[jira] [Updated] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[ https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhi.wang updated FLINK-35724: - Priority: Critical (was: Major) > javax.xml.bind.JAXBException not found with jdk11 while writing to os

[jira] [Updated] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[ https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhi.wang updated FLINK-35724: - Affects Version/s: 1.19.1 > javax.xml.bind.JAXBException not found with jdk11 while writing to oss > ---

[jira] [Created] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

zhi.wang created FLINK-35724: Summary: javax.xml.bind.JAXBException not found with jdk11 while writing to oss Key: FLINK-35724 URL: https://issues.apache.org/jira/browse/FLINK-35724 Project: Flink

[jira] [Updated] (FLINK-35724) javax.xml.bind.JAXBException not found with jdk11 while writing to oss

[ https://issues.apache.org/jira/browse/FLINK-35724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhi.wang updated FLINK-35724: - Description: writing data to oss with jdk11 will throw an exception of `java.lang.NoClassDefFoundError:

[jira] [Closed] (FLINK-35699) Incorrect Jackson shade through fabric8 in flink-kubernetes

[ https://issues.apache.org/jira/browse/FLINK-35699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35699. -- Assignee: Ferenc Csaky Resolution: Fixed 1.20: 7f40c35fc744a9cacb3310f3dcfbc8b8a82e5c7d 1.19: 74

[jira] [Commented] (FLINK-35699) Incorrect Jackson shade through fabric8 in flink-kubernetes

[ https://issues.apache.org/jira/browse/FLINK-35699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860785#comment-17860785 ] Gyula Fora commented on FLINK-35699: merged to master b32703f77f1e427411ef04a32c4fa2

[jira] [Updated] (FLINK-35696) JSON_VALUE/QUERY functions incorrectly map floating numbers

[ https://issues.apache.org/jira/browse/FLINK-35696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-35696: - Fix Version/s: (was: shaded-19.0) > JSON_VALUE/QUERY functions incorrectly map float

[jira] [Closed] (FLINK-35723) Publish shaded jsonpath

[ https://issues.apache.org/jira/browse/FLINK-35723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-35723. Resolution: Fixed Fixed in b23e1a811fcacbc5f53993297304131246bb5d04 > Publish shaded json

[jira] [Created] (FLINK-35723) Publish shaded jsonpath

Dawid Wysakowicz created FLINK-35723: Summary: Publish shaded jsonpath Key: FLINK-35723 URL: https://issues.apache.org/jira/browse/FLINK-35723 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-35696) JSON_VALUE/QUERY functions incorrectly map floating numbers

[ https://issues.apache.org/jira/browse/FLINK-35696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-35696: - Fix Version/s: shaded-19.0 > JSON_VALUE/QUERY functions incorrectly map floating numbers

[jira] [Commented] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860782#comment-17860782 ] Matthias Pohl commented on FLINK-35722: --- We touched checkpointing as part of FLINK

[jira] [Updated] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35722: -- Description: A test instability in {{CoordinatorEventsToStreamOperatorRecipientExactlyOnceITC

[jira] [Updated] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35722: -- Attachment: FLINK-35552.testCheckpoint.log > CoordinatorEventsToStreamOperatorRecipientExactly

[jira] [Updated] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

[ https://issues.apache.org/jira/browse/FLINK-35722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-35722: -- Attachment: logs-ci-test_ci_core-1719524892.zip > CoordinatorEventsToStreamOperatorRecipientEx

[jira] [Created] (FLINK-35722) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

Matthias Pohl created FLINK-35722: - Summary: CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event Key: FLINK-35722 URL: https://issues.apache.org/jira/

[jira] [Closed] (FLINK-35649) Bump Flink version to 1.19.1 in k8s-operator

[ https://issues.apache.org/jira/browse/FLINK-35649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35649. -- Assignee: Ferenc Csaky Resolution: Fixed merged to main 7b01553101875ca669447335e4ff5d3be40eada1

[jira] [Resolved] (FLINK-35353) Translate "Profiler" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-35353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-35353. -- Fix Version/s: 1.20.0 1.19.2 (was: 1.19.0) Resolution:

[jira] [Created] (FLINK-35721) I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can.

jinzhuguang created FLINK-35721: --- Summary: I found out that in the Flink SQL documentation it says that Double type cannot be converted to Boolean type, but in reality, it can. Key: FLINK-35721 URL: https://issues.a

[jira] [Created] (FLINK-35720) flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink

Nicolas Ferrario created FLINK-35720: Summary: flink-connector-kafka fails to restore from checkpoint when using an EXACTLY_ONCE sink Key: FLINK-35720 URL: https://issues.apache.org/jira/browse/FLINK-35720

[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=17860741#comment-17860741 ] Ferenc Csaky commented on FLINK-35663: -- cc [~Weijie Guo] > Release Testing: FLIP-4

[jira] [Commented] (FLINK-32312) SSLConnectionSocketFactory produced no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-32312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17860731#comment-17860731 ] Matthias Pohl commented on FLINK-32312: --- [https://github.com/XComp/flink/actions/r