This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 843774fff65 [fix](cloud) getVersionUpdateTimeMs out of bound (#38074)
843774fff65 is described below
commit 843774fff65fc4e540ceb7efcfeaee7fed09b981
Author: zhengyu <[email protected]>
AuthorDate: Fri Jul 19 08:51:03 2024 +0800
[fix](cloud) getVersionUpdateTimeMs out of bound (#38074)
Signed-off-by: freemandealer <[email protected]>
---
.../src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
index 882bb7f6933..5036a0e01c4 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/catalog/CloudPartition.java
@@ -130,8 +130,8 @@ public class CloudPartition extends Partition {
if (resp.getStatus().getCode() == MetaServiceCode.OK) {
version = resp.getVersion();
// Cache visible version, see hasData() for details.
- assert resp.getVersionUpdateTimeMsList().size() == 1;
- setCachedVisibleVersion(version,
resp.getVersionUpdateTimeMs(0));
+ long mTime = resp.getVersionUpdateTimeMsList().size() == 1 ?
resp.getVersionUpdateTimeMs(0) : 0;
+ setCachedVisibleVersion(version, mTime);
} else {
assert resp.getStatus().getCode() ==
MetaServiceCode.VERSION_NOT_FOUND;
version = Partition.PARTITION_INIT_VERSION;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
