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

Topics (27279)

Replies

Last Post

Views

[jira] [Created] (FLINK-9337) Implement AvroDeserializationSchema by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9336) Queryable state fails with Exception after task manager restore by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9335) Expose client logs via Flink UI by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9333) QuickStart Docs Spelling fix and some info regarding IntelliJ JVM Options by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9332) Fix Codegen error of CallGenerator by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9331) MesosResourceManager sometimes does not request new Containers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber by Fabian Hueske-2

by Kostas Kloudas

[jira] [Created] (FLINK-9330) Improve logging of SlotPool for debugging purposes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9329) hasRowtimeAttribute will throw NPE if user use setProctimeAttribute for table source by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restor due to StateBackendTestBase class not register snapshots in some UTs by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9327) Support explicit ROW value constructor in Flink SQL by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink Memory Usage by Pedro Elias

by Pedro Elias

[jira] [Created] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9325) generate the _meta file only when the writing is totally successful by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Version Compatibility of Flink-1.4.2 with Zookeeper-3.4.11 by Stalin Jeyaraj

by Chesnay Schepler-3

[jira] [Created] (FLINK-9323) Move checkstyle configuration by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9322) Add exception throwing map function that simulates failures to the general purpose DataStream job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9321) Rename SubtasksAllAccumulatorsHandlers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9320) Update `test-ha.sh` end-to-end test to use general purpose DataStream job by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9319) Move some flink-docs dependencies into profiles by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9318) Mark ConfigOptionsDocsCompletenessTest as IT case by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9317) Async I/O API Example For Scala has Variable Name error by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[HA] Is it possible to remove external dependency caused by high-availability.zookeeper.storageDir by Hao Chen

by Fabian Hueske-2

[jira] [Created] (FLINK-9316) Expose operator unique ID to the DataStream operators. by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Request for contributor permission by blues zheng

by blues zheng

[jira] [Created] (FLINK-9315) TaskManagerRunner.shutDown() would stuck in waiting rpc service terminated by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9314) Enable SSL mutual authentication for Netty / TaskManagers by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9313) Enable mutual authentication for RPC (akka) by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9312) Perform mutual authentication during SSL handshakes by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9311) PubSub connector by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9310) Update default cyphersuites by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9309) Recommend HA setup on Production Readiness Checklist by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9308) The method enableCheckpointing with low values like 10 are forming DoS on Kafka Clusters by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 467468469470471472473 ... 780