diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/DppScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/load/DppScheduler.java index c037f25b60..f777cdfa74 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/DppScheduler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/DppScheduler.java @@ -552,7 +552,7 @@ public class DppScheduler { return String.format(ETL_OUTPUT_PATH, fsDefaultName, outputPath, dbId, loadLabel, etlOutputDir); } - private class InputSizeInvalidException extends LoadException { + private static class InputSizeInvalidException extends LoadException { public InputSizeInvalidException(String msg) { super(msg); } diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index f601faba68..48f7191531 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -2476,12 +2476,12 @@ public class Coordinator implements CoordInterface { // map from a BE host address to the per-node assigned scan ranges; // records scan range assignment for a single fragment - class FragmentScanRangeAssignment + static class FragmentScanRangeAssignment extends HashMap>> { } // Bucket sequence -> (scan node id -> list of TScanRangeParams) - class BucketSeqToScanRange extends HashMap>> { + static class BucketSeqToScanRange extends HashMap>> { }