throw IOException instead of Exception

Author: wuchong

fluss-server/src/main/java/org/apache/fluss/server/log/LogLoader.java

@@ -32,6 +32,7 @@
 import java.io.File;
 import java.io.IOException;
 import java.nio.file.Files;
+import java.nio.file.NoSuchFileException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Comparator;
@@ -81,7 +82,7 @@ public LogLoader(
      *
      * @return the offsets of the Log successfully loaded from disk
      */
-    public LoadedLogOffsets load() throws Exception {
+    public LoadedLogOffsets load() throws IOException {
         // load all the log and index files.
         logSegments.close();
         logSegments.clear();
@@ -130,7 +131,7 @@ public LoadedLogOffsets load() throws Exception {
      * @throws LogSegmentOffsetOverflowException if the segment contains messages that cause index
      *     offset overflow
      */
-    private int recoverSegment(LogSegment segment) throws Exception {
+    private int recoverSegment(LogSegment segment) throws IOException {
         WriterStateManager writerStateManager =
                 new WriterStateManager(
                         logSegments.getTableBucket(),
@@ -264,7 +265,7 @@ private void removeAndDeleteSegments(Iterator<LogSegment> segmentsToDelete) {
     }
 
     /** Loads segments from disk into the provided segments. */
-    private void loadSegmentFiles() throws Exception {
+    private void loadSegmentFiles() throws IOException {
         File[] sortedFiles = logTabletDir.listFiles();
         if (sortedFiles != null) {
             Arrays.sort(sortedFiles, Comparator.comparing(File::getName));
@@ -288,8 +289,8 @@ private void loadSegmentFiles() throws Exception {
 
                         try {
                             segment.sanityCheck(timeIndexFileNewlyCreated);
-                        } catch (Exception e) {
-                            if (e instanceof NoSuchFieldException) {
+                        } catch (IOException e) {
+                            if (e instanceof NoSuchFileException) {
                                 if (isCleanShutdown
                                         || segment.getBaseOffset() < recoveryPointCheckpoint) {
                                     LOG.error(

fluss-server/src/main/java/org/apache/fluss/server/log/LogSegment.java

@@ -44,6 +44,7 @@
 
 import java.io.File;
 import java.io.IOException;
+import java.nio.file.NoSuchFileException;
 import java.util.Optional;
 
 import static org.apache.fluss.record.LogRecordBatchFormat.V0_RECORD_BATCH_HEADER_SIZE;
@@ -172,7 +173,7 @@ public void resizeIndexes(int size) throws IOException {
         timeIndex().resize(size);
     }
 
-    public void sanityCheck(boolean timeIndexFileNewlyCreated) throws Exception {
+    public void sanityCheck(boolean timeIndexFileNewlyCreated) throws IOException {
         if (lazyOffsetIndex.file().exists()) {
             // Resize the time index file to 0 if it is newly created.
             if (timeIndexFileNewlyCreated) {
@@ -182,7 +183,7 @@ public void sanityCheck(boolean timeIndexFileNewlyCreated) throws Exception {
             // we will recover the segments above the recovery point in recoverLog()
             // in any case so sanity checking them here is redundant.
         } else {
-            throw new NoSuchFieldException(
+            throw new NoSuchFileException(
                     "Offset index file "
                             + lazyOffsetIndex.file().getAbsolutePath()
                             + " does not exist.");
@@ -301,7 +302,7 @@ public boolean deleted() {
      * Run recovery on the given segment. This will rebuild the index from the log file and lop off
      * any invalid bytes from the end of the log and index.
      */
-    public int recover() throws Exception {
+    public int recover() throws IOException {
         offsetIndex().reset();
         timeIndex().reset();
         int validBytes = 0;