Streaming optimizations - CS 591 K1: Data Stream Processing and Analytics Spring 2020what conditions does the optimization improve performance? • can the decision be automatic? • Safety: under what conditions does the optimization preserve correctness? • maintain state semantics University 2020 Catalog of Optimizations 14 ??? Vasiliki Kalavri | Boston University 2020 15 Safety • Attribute availability: the set of attributes B reads from must be disjoint from the set of re-ordering with Eddy B A D C Eddy C D A B ??? Vasiliki Kalavri | Boston University 2020 18 Safety • attribute availability: the set of attributes B reads from must be disjoint from the set of attributes0 码力 | 54 页 | 2.83 MB | 1 年前3
监控Apache Flink应用程序(入门)garbage collection times. 4.13.1.3 Possible Alerts • container memory limit < container memory + safety margin caolei – 监控Apache Flink应用程序(入门) 进度和吞吐量监控 – 21 4.13.2 CPU Besides memory, you should0 码力 | 23 页 | 148.62 KB | 1 年前3
Exactly-once fault-tolerance in Apache Flink - CS 591 K1: Data Stream Processing and Analytics Spring 2020retrieve a distributed cut in a system execution that yields a system configuration Validity (safety): Termination (liveness): Obtain a valid system configuration A full system configuration is eventually retrieve a distributed cut in a system execution that yields a system configuration Validity (safety): Termination (liveness): Obtain a valid system configuration A full system configuration is eventually0 码力 | 81 页 | 13.18 MB | 1 年前3
共 3 条
- 1













