(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 ... 471472473474475476477 ... 783

Topics (27402)

Replies

Last Post

Views

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

Confusing error message in MemCheckpointStreamFactory with large state size? by Ken Krugler

by Fabian Hueske-2

[jira] [Created] (FLINK-9307) Running flink program doesn't print infos in console any more by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9306) Execute YARN IT tests for legacy and new mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9305) Register flink-s3-fs-* for the s3a:// scheme as well by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9304) Timer service shutdown should not be interrupted by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9302) Checkpoints continues to fail when using filesystem state backend with CIRCULAR REFERENCE:java.io.IOException by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9301) NotSoMiniClusterIterations job fails on travis by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9298) setup_quickstart hanging by Shang Yuanchun (Jira...

by Chesnay Schepler-3

[jira] [Created] (FLINK-9300) Improve error message when in-memory state is too large by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9299) ProcessWindowFunction documentation Java examples have errors by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9297) Make size of JobManager's ioExecutor configurable by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9296) Support distinct aggregation on non-windowed grouped streaming tables by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

Flink consuming more memory than expected by Gabriel Pelielo

by Fabian Hueske-2

[jira] [Created] (FLINK-9295) FlinkKafkaProducer011 sometimes throws ProducerFencedExceptions when in EXACTLY_ONCE mode by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

[jira] [Created] (FLINK-9293) SlotPool should check slot id when accepting a slot offer with existing allocation id by Shang Yuanchun (Jira...

by Shang Yuanchun (Jira...

1 ... 471472473474475476477 ... 783