Fix reflection

apache · Dec 28, 2021 · a4496c3 · a4496c3
1 parent 3b4e86a
commit a4496c3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala b/...ubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala
@@ -51,7 +51,7 @@ object FlinkEngineUtils extends Logging {
   }
 
   def getSessionContext(localExecutor: LocalExecutor, sessionId: String): SessionContext = {
-    val method = classOf[LocalExecutor].getMethod("getSessionContext", classOf[String])
+    val method = classOf[LocalExecutor].getDeclaredMethod("getSessionContext", classOf[String])
     method.setAccessible(true)
     method.invoke(localExecutor, sessionId).asInstanceOf[SessionContext]
   }