[jira] [Created] (FLINK-25460) Update slf4j-api dependency to 1.7.32

Martijn Visser created FLINK-25460: -- Summary: Update slf4j-api dependency to 1.7.32 Key: FLINK-25460 URL: https://issues.apache.org/jira/browse/FLINK-25460 Project: Flink Issue Type:

Re: About Clickhouse connector

Hi, I don't have permission to give you edit rights on Confluence, but I am wondering if it's necessary to create a FLIP for a new connector. I don't think a new connector would result in any new changes in Flink, since you would use the already available APIs? There's also already a Clickhouse

Re: [DISCUSS] Releasing Flink 1.14.3

Thank you all! That means that there's currently no more blocker to start with the Flink 1.14.3 release. The only thing that's needed is a committer that's willing to follow the release process [1] Any volunteers? Best regards, Martijn [1]

[jira] [Created] (FLINK-25461) Update net.sf.py4j:py4j dependency to 0.10.8.1

Martijn Visser created FLINK-25461: -- Summary: Update net.sf.py4j:py4j dependency to 0.10.8.1 Key: FLINK-25461 URL: https://issues.apache.org/jira/browse/FLINK-25461 Project: Flink Issue

[NOTICE] Increased build instability

Dear community, We are currently experiencing an increased build instability phase [1, 2]. Due to this, please be cautious when merging new changes by making sure that CI has completely passed. Also please double check that your change could not introduce a test failure before ruling it out as

About Clickhouse connector

Hi, Community. FLIP-202: https://cwiki.apache.org/confluence/display/FLINK/FLIP-202%3A+Introduce+ClickHouse+Connector I want to contribute to Flink. Could someone help me to get the 'FLIP Page

[VOTE] Apache Flink ML Release 2.0.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 2.0.0 of Apache Flink ML, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Testing Guideline** You can find here [1] a page in the project wiki on

[jira] [Created] (FLINK-25462) Allow override partitioning for KeyedStream

Viktor Feklin created FLINK-25462: - Summary: Allow override partitioning for KeyedStream Key: FLINK-25462 URL: https://issues.apache.org/jira/browse/FLINK-25462 Project: Flink Issue Type:

[jira] [Created] (FLINK-25463) Set is not supported in User Defined Functions

Surendra Lalwani created FLINK-25463: Summary: Set is not supported in User Defined Functions Key: FLINK-25463 URL: https://issues.apache.org/jira/browse/FLINK-25463 Project: Flink

Re: [DISCUSS] Releasing Flink ML 2.0.0

Thank you Till and Zhipeng for the vote and the comments! Based on the response received in this thread, we will go ahead and release Flink ML 2.0.0 RC1 today. Cheers, Dong Till Rohrmann 于2021年12月18日 周六下午8:04写道： > Great to see that the community is ready to release Flink ML 2.0.0. Big +1 > for

Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage

Hi all, After some experimentation, we felt no problem putting the dynamic storage outside of flink, and it also allowed us to design the interface in more depth. What do you think? If there is no problem, I am asking for PMC's help here: we want to propose flink-dynamic-storage as a flink

[jira] [Created] (FLINK-25464) Python tests hangs on install dependencies

Yun Gao created FLINK-25464: --- Summary: Python tests hangs on install dependencies Key: FLINK-25464 URL: https://issues.apache.org/jira/browse/FLINK-25464 Project: Flink Issue Type: Bug

[DISCUSS] Introduce Hash Lookup Join

Hi everyone, Look up join [1] is commonly used feature in Flink SQL. We have received many optimization requirements on look up join. For example: 1. Enforces left side of lookup join do a hash

[jira] [Created] (FLINK-25466) TTL configuration could parse in StateTtlConfig#DISABLED

Yun Tang created FLINK-25466: Summary: TTL configuration could parse in StateTtlConfig#DISABLED Key: FLINK-25466 URL: https://issues.apache.org/jira/browse/FLINK-25466 Project: Flink Issue Type:

[jira] [Created] (FLINK-25465) Correct the logic to materizate on wrapped changelog state

Yun Tang created FLINK-25465: Summary: Correct the logic to materizate on wrapped changelog state Key: FLINK-25465 URL: https://issues.apache.org/jira/browse/FLINK-25465 Project: Flink Issue

[jira] [Created] (FLINK-25455) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator fails on AZP

Till Rohrmann created FLINK-25455: - Summary: FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator fails on AZP Key: FLINK-25455 URL:

[jira] [Created] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint

Till Rohrmann created FLINK-25456: - Summary: FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint Key: FLINK-25456 URL: https://issues.apache.org/jira/browse/FLINK-25456 Project: Flink

[jira] [Created] (FLINK-25457) Read timeouts when downloading from alicloud-mvn-mirror

Till Rohrmann created FLINK-25457: - Summary: Read timeouts when downloading from alicloud-mvn-mirror Key: FLINK-25457 URL: https://issues.apache.org/jira/browse/FLINK-25457 Project: Flink

[jira] [Created] (FLINK-25458) Supports local recovery

Yun Tang created FLINK-25458: Summary: Supports local recovery Key: FLINK-25458 URL: https://issues.apache.org/jira/browse/FLINK-25458 Project: Flink Issue Type: Sub-task Reporter:

About ClickHouse Connector

Hi, Community. FLIP-202: https://cwiki.apache.org/confluence/display/FLINK/FLIP-202%3A+Introduce+ClickHouse+Connector I want to contribute to Flink. Could someone help me to get the 'FLIP Page Edit Permission' ? JIRA Username: RocMarshal Confluence Username: RocMarshal

[jira] [Created] (FLINK-25459) When inserting row type fields into sink, the order needs to be maintained

qyw created FLINK-25459: --- Summary: When inserting row type fields into sink, the order needs to be maintained Key: FLINK-25459 URL: https://issues.apache.org/jira/browse/FLINK-25459 Project: Flink

[jira] [Created] (FLINK-25454) Negative time in throughput calculator

Anton Kalashnikov created FLINK-25454: - Summary: Negative time in throughput calculator Key: FLINK-25454 URL: https://issues.apache.org/jira/browse/FLINK-25454 Project: Flink Issue Type: