(DEPRECATED) Apache Flink Mailing List archive.

This used to be a public archive of the Flink mailing mailing list.

We recommend using the official Apache Mailing List Archive: https://lists.apache.org/list.html?dev@flink.apache.org

New Topic

People

1 ... 16171819202122 ... 778

Topics (27203)

Replies

Last Post

Views

[jira] [Created] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22765) ExceptionUtilsITCase.testIsMetaspaceOutOfMemoryError is unstable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22764) Disable Values Source node in streaming plan optimization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22762) cannot use set table.sql-dialect=hive; by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22761) Cannot remove POJO fields by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22760) HiveParser::setCurrentTimestamp fails with hive-3.1.2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22759) Correct the applicability of RocksDB related options as per operator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22758) java.lang.IllegalStateException: Trying to access closed classloader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22757) Update GCS documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22756) DispatcherTest.testJobStatusIsShownDuringTermination fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22755) SequenceStreamingFileSinkITCase.testWriteSequenceFile fail by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22754) Finished job not always archived properly by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22753) Activate log-based Checkpoints for StateFun by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22752) Add robust default state configuration to StateFun by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22751) Reduce JVM Metaspace memory for StateFun by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22750) Simplify Unit Testing of Remote Functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Apache Flink 1.12.4 released by Arvid Heise-4

by Arvid Heise-4

[jira] [Created] (FLINK-22749) Apply a robust default State Backend Configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22748) Allow dynamic target topic selection in Kafka sinks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[Parquet support] by Etienne Chauchot

by Etienne Chauchot

[jira] [Created] (FLINK-22747) Update commons-io to 2.8 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22746) Links to connectors in docs are broken by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Releasing Flink 1.13.1 by Konstantin Knauf-4

by dwysakowicz

[jira] [Created] (FLINK-22745) MesosWorkerStore is started with an illegal namespace by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Re: [Statefun] Truncated Messages in Python workers by Stephan Ewen

by Igal Shilman

[jira] [Created] (FLINK-22744) Simplify TableEnvironment.create() by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22743) Adding offsets for TUMBLE* functions for more flexible window start and end time. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22742) Lookup join condition with process time throws org.codehaus.commons.compiler.CompileException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22741) Hide Flink complexity from Stateful Functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22740) Drop legacy planner from docs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22739) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke fail due to TestTimedOutException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22738) org.apache.flink.connector.jdbc.xa.JdbcExactlyOnceSinkE2eTest no output for 900 seconds due to block on downloading docker image by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-22737) Add support for CURRENT_WATERMARK to SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

upsert kafka sink why not send all data that contain update_before,delete by Jocean shi

by Jocean shi

1 ... 16171819202122 ... 778