Flink 零点漂移：原因、影响及解决方法 - 深入理解事件时间处理

Flink\u7684\u96f6\u70b9\u6e7f\u79fb\u6307\u7684\u662f\u5728\u5904\u7406\u4e8b\u4ef6\u65f6\u95f4\uff08Event\u00a0Time\uff09\u7684\u65f6\u5019\uff0c\u4e8b\u4ef6\u65f6\u95f4\u7684\u5f00\u59cb\u70b9\uff08\u96f6\u70b9\uff09\u53d1\u751f\u4e86\u504f\u79fb\u3002\u5e38\u89c1\u60c5\u51b5\u4e0b\uff0c\u4e8b\u4ef6\u65f6\u95f4\u6307\u7684\u662f\u4e8b\u4ef6\u5b9e\u9645\u53d1\u751f\u7684\u65f6\u95f4\uff0c\u800c\u5904\u7406\u65f6\u95f4\uff08Processing\u00a0Time\uff09\u6307\u7684\u662f\u4e8b\u4ef6\u88ab\u5904\u7406\u7684\u65f6\u95f4\u3002\n\n\u5728\u00a0Flink\u00a0\u4e2d\uff0c\u4e8b\u4ef6\u65f6\u95f4\u662f\u7531\u6570\u636e\u6e90\u4e2d\u7684\u65f6\u95f4\u7c7b\u57df\u786e\u5b9a\u7684\u3002\u5f53\u6570\u636e\u6e90\u7684\u65f6\u95f4\u7c7b\u57df\u4e0e\u5b9e\u9645\u4e8b\u4ef6\u53d1\u751f\u7684\u65f6\u95f4\u5b58\u5728\u504f\u79fb\u65f6\uff0c\u5c31\u4f1a\u53d1\u751f\u96f6\u70b9\u6e7f\u79fb\u3002\u8fd9\u79cd\u504f\u79fb\u53ef\u80fd\u662f\u7531\u6570\u636e\u6e90\u81ea\u8eab\u7684\u95ee\u9898\u5bfc\u81f4\u7684\uff0c\u4e5f\u53ef\u80fd\u662f\u7531\u6570\u636e\u5728\u4f20\u8f93\u8fc7\u7a0b\u4e2d\u7684\u5ef6\u79fb\u5bfc\u81f4\u7684\u3002\n\n\u96f6\u70b9\u6e7f\u79fb\u4f1a\u5bfc\u81f4\u4e8b\u4ef6\u65f6\u95f4\u548c\u5904\u7406\u65f6\u95f4\u4e4b\u95f4\u7684\u4e0d\u4e00\u81f4\uff0c\u53ef\u80fd\u5f71\u54cd\u5230\u57fa\u4e8e\u4e8b\u4ef6\u65f6\u95f4\u7684\u7a97\u53e3\u8ba1\u7b97\u7ed3\u679c\u7684\u51c6\u786e\u6027\u3002\u4e3a\u4e86\u89e3\u51b3\u96f6\u70b9\u6e7f\u79fb\u7684\u95ee\u9898\uff0c\u53ef\u4ee5\u91c7\u53d6\u4ee5\u4e0b\u63aa\u65bd\uff1a\n\n\u2001\u20011\u3002\u4f7f\u7528\u00a0Watermark\u00a0\u6765\u89e3\u51b3\u5ef6\u79fb\u7684\u95ee\u9898\uff1a\u00a0Watermark\u00a0\u662f\u4e00\u79cd\u7528\u4e8e\u6d4b\u91cf\u4e8b\u4ef6\u65f6\u95f4\u8fdb\u5c55\u7684\u673a\u5236\uff0c\u53ef\u4ee5\u7528\u6765\u63a8\u52a8\u7a97\u53e3\u7684\u89e3\u53d1\u3002\u901a\u8fc7\u5728\u6570\u636e\u6d41\u4e2d\u63d2\u5165\u00a0Watermark\uff0c\u53ef\u4ee5\u544a\u8bc9\u00a0Flink\u00a0\u4e8b\u4ef6\u65f6\u95f4\u7684\u8fdb\u5c55\u60c5\u51b5\uff0c\u5176\u4e00\u89e3\u51b3\u5ef6\u79fb\u5bfc\u81f4\u7684\u96f6\u70b9\u6e7f\u79fb\u95ee\u9898\u3002\n\n\u2001\u20012\u3002\u6570\u636e\u6e90\u65f6\u95f4\u7c7b\u57df\u7684\u4fee\u6539\uff1a\u5982\u679c\u6570\u636e\u6e90\u7684\u65f6\u95f4\u7c7b\u57df\u5b58\u5728\u504f\u79fb\uff0c\u53ef\u4ee5\u5728\u6570\u636e\u6d41\u5904\u7406\u8fc7\u7a0b\u4e2d\u5bf9\u65f6\u95f4\u7c7b\u57df\u8fdb\u884c\u4fee\u6539\uff0c\u4f7f\u5176\u4e0e\u5b9e\u9645\u4e8b\u4ef6\u53d1\u751f\u7684\u65f6\u95f4\u4fdd\u6301\u4e00\u81f4\u3002\n\n\u2001\u20013\u3002\u4f7f\u7528\u4e8b\u4ef6\u65f6\u95f4\u7a97\u53e3\uff1a\u00a0Flink\u00a0\u63d0\u4f9b\u4e86\u57fa\u4e8e\u4e8b\u4ef6\u65f6\u95f4\u7684\u7a97\u53e3\u8ba1\u7b97\u529f\u80fd\uff0c\u53ef\u4ee5\u6839\u636e\u4e8b\u4ef6\u65f6\u95f4\u5bf9\u6570\u636e\u8fdb\u884c\u5206\u7ec4\u548c\u805a\u5408\u3002\u4f7f\u7528\u4e8b\u4ef6\u65f6\u95f4\u7a97\u53e3\u53ef\u4ee5\u51c6\u786e\u7684\u8ba1\u7b97\u57fa\u4e8e\u4e8b\u4ef6\u65f6\u95f4\u7684\u7edf\u8ba1\u7ed3\u679c\uff0c\u5176\u4e00\u907f\u514d\u96f6\u70b9\u6e7f\u79fb\u5e26\u6765\u7684\u95ee\u9898\u3002\n\n\u603b\u7684\u6765\u8bf4\uff0c\u89e3\u51b3\u00a0Flink\u00a0\u4e2d\u7684\u96f6\u70b9\u6e7f\u79fb\u95ee\u9898\u9700\u8981\u7ed3\u5408\u4f7f\u7528\u00a0Watermark\u00a0\u548c\u5408\u7406\u8c03\u6574\u6570\u636e\u6e90\u65f6\u95f4\u7c7b\u57df\uff0c\u4ee5\u4fdd\u8bc1\u4e8b\u4ef6\u65f6\u95f4\u548c\u5904\u7406\u65f6\u95f4\u4e4b\u95f4\u7684\u4e00\u81f4\u6027\u3002