diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/CalciteModule3.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/CalciteModule3.java index 03846a81e9e00..f608650363100 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/CalciteModule3.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/utils/CalciteModule3.java @@ -46,16 +46,16 @@ public class CalciteModule3 { private final SqlIndentifierDelegate sqlIndentifierDelegate; static { - boolean findCalciteInCurrentClassLoader = false; + boolean calciteFound = false; ClassLoader currentClassLoader = Thread.currentThread().getContextClassLoader(); try { currentClassLoader.loadClass(SqlParserDelegate.CLASS_NAME); - findCalciteInCurrentClassLoader = true; + calciteFound = true; } catch (ClassNotFoundException e) { } try { - if (findCalciteInCurrentClassLoader) { + if (calciteFound) { submoduleClassLoader = currentClassLoader; } else { submoduleClassLoader = initCalciteClassLoader();