退订

 退订，谢谢！

[jira] [Created] (FLINK-24480) EqualiserCodeGeneratorTest fails on azure

Xintong Song created FLINK-24480: Summary: EqualiserCodeGeneratorTest fails on azure Key: FLINK-24480 URL: https://issues.apache.org/jira/browse/FLINK-24480 Project: Flink Issue Type: Bug

What's the purpose of uniqueId in FileWriterBucket

Hi, folks, >From 1.14, file sink add a uid to a committed file, so would you mind to tell >me what’s the purpose of this field? Can it be removed safely? https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/datastream/file_sink/#part-file-configuration

[jira] [Created] (FLINK-24479) Bug fix RocksIteratorWrapper#seekToLast method

xiangqiao created FLINK-24479: - Summary: Bug fix RocksIteratorWrapper#seekToLast method Key: FLINK-24479 URL: https://issues.apache.org/jira/browse/FLINK-24479 Project: Flink Issue Type: Bug

Re: The Apache Flink should pay more attention to ensuring API compatibility.

Hi all, It was a wonderful discussion. I think it can be made clear that PublicEvolving must not provide cross version compatibility, which means that once the connector wants to use new features, it must not be cross version compatible. However, the connector must maintain multiple versions. Ma

[jira] [Created] (FLINK-24478) gradle quickstart is out-of-date

David Anderson created FLINK-24478: -- Summary: gradle quickstart is out-of-date Key: FLINK-24478 URL: https://issues.apache.org/jira/browse/FLINK-24478 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24477) Add MongoDB sink

Nir Tsruya created FLINK-24477: -- Summary: Add MongoDB sink Key: FLINK-24477 URL: https://issues.apache.org/jira/browse/FLINK-24477 Project: Flink Issue Type: New Feature Components: Co

[jira] [Created] (FLINK-24476) Rename all ElasticSearch to Elasticsearch (without camel case)

Ryan Skraba created FLINK-24476: --- Summary: Rename all ElasticSearch to Elasticsearch (without camel case) Key: FLINK-24476 URL: https://issues.apache.org/jira/browse/FLINK-24476 Project: Flink

[jira] [Created] (FLINK-24475) Remove no longer used NestedMap* classes

Piotr Nowojski created FLINK-24475: -- Summary: Remove no longer used NestedMap* classes Key: FLINK-24475 URL: https://issues.apache.org/jira/browse/FLINK-24475 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24474) Standalone clusters should bind to localhost by default

Chesnay Schepler created FLINK-24474: Summary: Standalone clusters should bind to localhost by default Key: FLINK-24474 URL: https://issues.apache.org/jira/browse/FLINK-24474 Project: Flink

[jira] [Created] (FLINK-24473) getString value from any datatype columns

Spongebob created FLINK-24473: - Summary: getString value from any datatype columns Key: FLINK-24473 URL: https://issues.apache.org/jira/browse/FLINK-24473 Project: Flink Issue Type: Improvement

Re: The Apache Flink should pay more attention to ensuring API compatibility.

Hi Arvid, Yes, reflection can solve this problem on the connector side, but this increases the burden to connectors. That also means all the existing released source connectors which use "metricGroup" will not work on 1.14, and they have to release a new version. It's just a problem of who changes

[jira] [Created] (FLINK-24472) DispatcherTest is unstable

Piotr Nowojski created FLINK-24472: -- Summary: DispatcherTest is unstable Key: FLINK-24472 URL: https://issues.apache.org/jira/browse/FLINK-24472 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-24471) Add microbenchmark for throughput with debloating enabled

Piotr Nowojski created FLINK-24471: -- Summary: Add microbenchmark for throughput with debloating enabled Key: FLINK-24471 URL: https://issues.apache.org/jira/browse/FLINK-24471 Project: Flink

[jira] [Created] (FLINK-24470) EMA for buffer debloat level

Anton Kalashnikov created FLINK-24470: - Summary: EMA for buffer debloat level Key: FLINK-24470 URL: https://issues.apache.org/jira/browse/FLINK-24470 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-24469) Incorrect calcualtion of the buffer size in case of channel data skew

Anton Kalashnikov created FLINK-24469: - Summary: Incorrect calcualtion of the buffer size in case of channel data skew Key: FLINK-24469 URL: https://issues.apache.org/jira/browse/FLINK-24469 Proje

[jira] [Created] (FLINK-24468) NPE when notifyNewBufferSize

Anton Kalashnikov created FLINK-24468: - Summary: NPE when notifyNewBufferSize Key: FLINK-24468 URL: https://issues.apache.org/jira/browse/FLINK-24468 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24467) Set min and max buffer size even if the difference less than threshold

Anton Kalashnikov created FLINK-24467: - Summary: Set min and max buffer size even if the difference less than threshold Key: FLINK-24467 URL: https://issues.apache.org/jira/browse/FLINK-24467 Proj

unsubscribe (退订)

Hi, To unsubscribe emails from Flink dev mail list, send an email to dev-unsubscr...@flink.apache.org To unsubscribe emails from Flink user mail list, send an email to user-unsubscr...@flink.apache.org To unsubscribe emails from Flink user -zh mail list, send an email to user-zh-unsubscr..

[jira] [Created] (FLINK-24466) Interval Join late events handling behaviour is not consistent

Francesco Guardiani created FLINK-24466: --- Summary: Interval Join late events handling behaviour is not consistent Key: FLINK-24466 URL: https://issues.apache.org/jira/browse/FLINK-24466 Project:

[jira] [Created] (FLINK-24465) Wrong javadoc and documentation for buffer timeout

Dawid Wysakowicz created FLINK-24465: Summary: Wrong javadoc and documentation for buffer timeout Key: FLINK-24465 URL: https://issues.apache.org/jira/browse/FLINK-24465 Project: Flink Is