You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2020/04/08 14:15:18 UTC
[incubator-iotdb] branch fix_upgrade created (now 74a9eef)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch fix_upgrade
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
at 74a9eef fix concurrent modification exception
This branch includes the following new commits:
new 74a9eef fix concurrent modification exception
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[incubator-iotdb] 01/01: fix concurrent modification exception
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch fix_upgrade
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 74a9eef4ae415d2bfae10aa83a0ef1b5c469e20d
Author: qiaojialin <64...@qq.com>
AuthorDate: Wed Apr 8 22:15:12 2020 +0800
fix concurrent modification exception
---
.../iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index b8a342d..c0d8cef 100755
--- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -968,12 +968,12 @@ public class StorageGroupProcessor {
*/
public int countUpgradeFiles() {
int cntUpgradeFileNum = 0;
- for (TsFileResource seqTsFileResource : sequenceFileList) {
+ for (TsFileResource seqTsFileResource : new ArrayList<>(sequenceFileList)) {
if (UpgradeUtils.isNeedUpgrade(seqTsFileResource)) {
cntUpgradeFileNum += 1;
}
}
- for (TsFileResource unseqTsFileResource : unSequenceFileList) {
+ for (TsFileResource unseqTsFileResource : new ArrayList<>(unSequenceFileList)) {
if (UpgradeUtils.isNeedUpgrade(unseqTsFileResource)) {
cntUpgradeFileNum += 1;
}
@@ -982,10 +982,10 @@ public class StorageGroupProcessor {
}
public void upgrade() {
- for (TsFileResource seqTsFileResource : sequenceFileList) {
+ for (TsFileResource seqTsFileResource : new ArrayList<>(sequenceFileList)) {
seqTsFileResource.doUpgrade();
}
- for (TsFileResource unseqTsFileResource : unSequenceFileList) {
+ for (TsFileResource unseqTsFileResource : new ArrayList<>(unSequenceFileList)) {
unseqTsFileResource.doUpgrade();
}
}