(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 ... 145146147148149150151 ... 780

Topics (27278)

Replies

Last Post

Views

[VOTE] FLIP-36: Support Interactive Programming in Flink by Xuannan Su

by Xuannan Su

[jira] [Created] (FLINK-18801) Add the new document "10 minutes to PyFlink" by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[DISCUSS] StreamingFileSink: parallelizing active buckets checkpointing? by Paul Bernier

by Till Rohrmann

[jira] [Created] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18799) improve slot allocation to make resource balance among machines. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18798) Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18797) docs and examples use deprecated forms of keyBy by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

to be a contributor by 朱丹

by Congxian Qiu

[jira] [Created] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18795) Support for HBase 2 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18794) Custom metric doesn't work in flink1.11.1 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18793) Fix Typo for api.common.eventtime.WatermarkStrategy Description by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18792) TaskManager Start Failure by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18791) Simplify the logic of SqlCommandParser and CliClient by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18790) Set a connection timeout that is lower than the request timeout for remote functions by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18789) Use TableEnvironment#executeSql to execute insert statement in sql client by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-18788) Refactor sql-client based the proposed interfaces of FLIP-84 by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[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...

1 ... 145146147148149150151 ... 780