public static ReadPhase getReadPhaseByPhase(String phase) {
        return Stream.of(ReadPhase.values()).filter(v -> v.getPhase().equals(phase)).findFirst().orElse(null);
    }
get the read phase enum by phase

@param phase the phase name
@return the read phase enum
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/enums/ReadPhase.java