This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch two_stage_pipeline
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/two_stage_pipeline by this
push:
new cc1bead fix
cc1bead is described below
commit cc1bead5cb0ac80bbff91cc37e5aa6fe3f9ad40f
Author: JackieTien97 <[email protected]>
AuthorDate: Wed Jan 27 13:00:30 2021 +0800
fix
---
.../org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
b/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
index 8120d00..f4adacf 100644
---
a/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
+++
b/server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
@@ -26,7 +26,6 @@ import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
-import java.util.concurrent.ExecutionException;
import org.apache.iotdb.db.engine.fileSystem.SystemFileFactory;
import org.apache.iotdb.db.engine.flush.MemTableFlushTask;
import org.apache.iotdb.db.engine.memtable.IMemTable;
@@ -219,7 +218,7 @@ public class TsFileRecoverPerformer {
// otherwise this file is not closed before crush, do nothing so we can
continue writing
// into it
- } catch (IOException | ExecutionException e) {
+ } catch (IOException e) {
throw new StorageGroupProcessorException(e);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();