Skip to content

Commit 4e2f602

Browse files
committed
Remove flink. prefix for create session configurations
1 parent 1dddd08 commit 4e2f602

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/session/FlinkSQLSessionManager.scala

+7-4
Original file line numberDiff line numberDiff line change
@@ -54,21 +54,24 @@ class FlinkSQLSessionManager(engineContext: DefaultContext)
5454
password: String,
5555
ipAddress: String,
5656
conf: Map[String, String]): Session = {
57-
conf.get(KYUUBI_SESSION_HANDLE_KEY).map(SessionHandle.fromUUID).flatMap(
57+
val newConf = conf.map {
58+
case (k, v) => k.stripPrefix("flink.") -> v
59+
}
60+
newConf.get(KYUUBI_SESSION_HANDLE_KEY).map(SessionHandle.fromUUID).flatMap(
5861
getSessionOption).getOrElse {
5962
val flinkInternalSession = sessionManager.openSession(
6063
SessionEnvironment.newBuilder
6164
.setSessionEndpointVersion(SqlGatewayRestAPIVersion.V1)
62-
.addSessionConfig(mapAsJavaMap(conf))
65+
.addSessionConfig(mapAsJavaMap(newConf))
6366
.build)
6467
val sessionConfig = flinkInternalSession.getSessionConfig
65-
sessionConfig.putAll(conf.asJava)
68+
sessionConfig.putAll(newConf.asJava)
6669
val session = new FlinkSessionImpl(
6770
protocol,
6871
user,
6972
password,
7073
ipAddress,
71-
conf,
74+
newConf,
7275
this,
7376
flinkInternalSession)
7477
session

0 commit comments

Comments
 (0)