Hi ALL, Recently, we have designed and implemented a proposal in FLINK to support Asynchronous Operation while streaming. The main feature of this proposal is to introduce async i/o operation in FLINK to boost the TPS of streaming job without delaying the checkpoint, and provide an easy way for the FLINK users to implement their async i/o codes in FLINK job.
Here is the link to Google Doc: https://docs.google.com/ document/d/1Lr9UYXEz6s6R_3PWg3bZQLF3upGaNEkc0rQCFSzaYDI/edit Any feedback is appreciated. Thanks, David
