flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yun Tang <myas...@live.com>
Subject Re: 关于flink中端对端的精确一次性理解问题
Date Tue, 27 Aug 2019 07:00:09 GMT
Hi

ԿһTwoPhaseCommitSinkFunctionʵ֣preCommitsnapshotStateʱãὫǰcurrentTransactionHolder洢pendingCommitTransactionsֱnotifyCheckpointCompleteʱҲcommitʱpendingCommitTransactionsȡԲpreCommitʱҪдDzġ

TwoPhaseCommitSinkFunctionȷʵҪʵcheckpoint intervalܾܺöûDzstateϴʱó뼶

ף

________________________________
From: 1900 <575209351@qq.com>
Sent: Tuesday, August 27, 2019 14:15
To: user-zh <user-zh@flink.apache.org>
Subject: flinkж˶Զ˵ľȷһ

flink˶Զ˵Ķ壬ö׶ύflinkѾװˣŵTwoPhaseCommitSinkFunctionУֻҪʵֶӦķ,



C beginTransaction

C preCommit

C commit

C abort



sink˵IJݵȵģͲҪʵˣҪʵдMYSQLʵֶ˶Զ˾ȷһԣDz
preCommitҪд
ȻcommitύĴʱ͸checkpointʱˣcheckpointʱܳDzζʱܳзգ
checkpointҪĽţԭÿһcheckpointҪÿһΣüʱ䣿
Ǽʱ䶼㵽´checkpointУĴʱˣDz⣿
˶Զ˾ȷһDzЧС
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message