问题一:Flink 在正常处理下的延迟大约是多少?
Flink 在正常处理下的延迟大约是多少?
参考回答:
在正常处理的情况下,Flink 引擎框架本身除了定期去做 Checkpoint 的快照,几乎没有其他额外的开销,而且 Checkpoint 快照很大一部分是异步的,所以 Flink 的端到端延迟大约在 100 毫秒左右。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/671119
问题二:Flink 在容错恢复时面临的主要挑战是什么?
Flink 在容错恢复时面临的主要挑战是什么?
参考回答:
Flink 在容错恢复时面临的主要挑战是恢复代价较大,需要将整个作业停掉,然后从过去的快照检查点整体恢复,这个过程可能需要几秒钟甚至分钟级,特别是在作业状态较大的情况下。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/671150
问题三:容错恢复包括哪些主要步骤?
容错恢复包括哪些主要步骤?
参考回答:
容错恢复是一个全链路的问题,包括 failure detect、job cancel、新的资源申请调度、状态恢复和重建等。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/671151
问题四:Flink 中的数据可以分为哪几类?
Flink 中的数据可以分为哪几类?
参考回答:
Flink 中的数据可以粗略分为三类:元信息、处理的中间数据(Inflight Data)和算子状态数据。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/671152
问题五:Checkpoint 在 Flink 中扮演什么角色?
Checkpoint 在 Flink 中扮演什么角色?
参考回答:
Checkpoint 在 Flink 中用于实现容错恢复,通过定期保存作业的状态,以便在发生故障时可以从最近的 Checkpoint 恢复作业。
关于本问题的更多回答可点击原文查看: