提交 40e5a358 编写于 作者: D dt0 提交者: wangzelin.wzl

add archive converge strategy

上级 ba2d7ae2
...@@ -458,6 +458,15 @@ int ObArchiveSender::do_statisfy_converge_strategy_(const ObPGKey& pg_key, const ...@@ -458,6 +458,15 @@ int ObArchiveSender::do_statisfy_converge_strategy_(const ObPGKey& pg_key, const
} else if (ObTimeUtility::current_time() - checkpoint_ts >= max_delay_time) { } else if (ObTimeUtility::current_time() - checkpoint_ts >= max_delay_time) {
can_send = true; can_send = true;
ARCHIVE_LOG(TRACE, "can send due to pg checkpoint ts delay reach limit", K(pg_key)); ARCHIVE_LOG(TRACE, "can send due to pg checkpoint ts delay reach limit", K(pg_key));
} else if (log_id == 0) {
// For new pg created after archive starts, its checkpoint ts is faked while max archived log id is zero.
// Other modules depend on archive will be waited util max archived log id is bigger than zero,
// so this task should be archived immediately.
can_send = true;
ARCHIVE_LOG(TRACE, "can send due to max archived log id is zero", K(pg_key));
} else if (!is_first_record_finish) {
can_send = true;
ARCHIVE_LOG(TRACE, "can send due to kickoff log not finish", K(pg_key));
} }
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册