(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 ... 299300301302303304305 ... 933

Topics (32650)

Replies

Last Post

Views

[jira] [Created] (FLINK-18787) Add a "cluster-info" command to the Flink command line client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18786) Performance regresssion on 2020.07.29 in some state backend benchmarks by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18785) flink goes into dead lock leader election when restoring from a do-not-exist checkpoint/savepoint path by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18784) Push Projection through WatermarkAssigner by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18783) Load AkkaRpcService through separate class loader by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18782) How to retain the column'name when convert a Table to DataStream by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18781) Example in table/sql/queries.md Exists section is not correct by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Checkpointing under backpressure by Thomas Weise

by Piotr Nowojski-5

[jira] [Created] (FLINK-18780) FlinkKafkaProducer should add another constructor accepting SerializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18778) Support the SupportsProjectionPushDown interface for LookupTableSource by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18779) Support the SupportsFilterPushDown interface for ScanTableSource. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18777) Supports schema registry catalog by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18776) "compile_cron_scala212" failed to compile by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18775) Rework PyFlink Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18774) Support debezium-avro format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18773) Enable parallel classloading by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18772) Hide submit job web ui elements when running in per-job/application mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18771) "Kerberized YARN per-job on Docker test" failed with "Client cannot authenticate via:[TOKEN, KERBEROS]" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18770) Emitting element fails in KryoSerializer by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18769) Streaming Table job stuck when enabling minibatching by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18768) Imporve SQL kafka connector docs about passing kafka properties by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18767) Streaming job stuck when disabling operator chaining by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18766) Support add_sink() for Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18765) Support map() and flat_map() for Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18764) Support from_collection for Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18763) Support basic TypeInformation for Python DataStream API by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18762) Make network buffers per incoming/outgoing channel can be configured separately by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18761) Support Python DataStream API (Stateless part) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18760) Redundant task managers should be released when there's no job running in session cluster by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] Align the semantic of returning null from InputFormat#nextRecord by Benchao Li-2

by Benchao Li-2

[jira] [Created] (FLINK-18759) Add readme.md for TPC-DS tools by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18758) Support debezium data type in debezium format by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18757) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed with "Topic XX not present in metadata after 60000 ms" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18755) RabbitMQ QoS Chinese Documentation by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 299300301302303304305 ... 933