You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by we...@apache.org on 2020/11/10 17:11:50 UTC
[hadoop] branch trunk updated: HADOOP-17142. Fix outdated
properties of JournalNode when performing rollback. Contributed by Deegue.
This is an automated email from the ASF dual-hosted git repository.
weichiu pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 82de07c HADOOP-17142. Fix outdated properties of JournalNode when performing rollback. Contributed by Deegue.
82de07c is described below
commit 82de07c794fe119946bec2e563c1937f312e8ac9
Author: Yizhong Zhang <zy...@163.com>
AuthorDate: Wed Nov 11 01:11:31 2020 +0800
HADOOP-17142. Fix outdated properties of JournalNode when performing rollback. Contributed by Deegue.
---
.../main/java/org/apache/hadoop/hdfs/qjournal/server/JNStorage.java | 4 ++++
.../src/main/java/org/apache/hadoop/hdfs/qjournal/server/Journal.java | 2 ++
2 files changed, 6 insertions(+)
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/JNStorage.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/JNStorage.java
index cb80362..7f82bff 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/JNStorage.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/JNStorage.java
@@ -236,6 +236,10 @@ class JNStorage extends Storage {
void analyzeStorage() throws IOException {
this.state = sd.analyzeStorage(StartupOption.REGULAR, this);
+ refreshStorage();
+ }
+
+ void refreshStorage() throws IOException {
if (state == StorageState.NORMAL) {
readProperties(sd);
}
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/Journal.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/Journal.java
index a045ad6a..99a087e 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/Journal.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/qjournal/server/Journal.java
@@ -1178,6 +1178,8 @@ public class Journal implements Closeable {
// directory will be renamed. It will be reopened lazily on next access.
IOUtils.cleanupWithLogger(LOG, committedTxnId);
storage.getJournalManager().doRollback();
+ // HADOOP-17142: refresh properties after rollback performed.
+ storage.refreshStorage();
}
synchronized void discardSegments(long startTxId) throws IOException {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org