diff --git a/docs/deployment/migration-guide.md b/docs/deployment/migration-guide.md index cbd74ee44..48ded45ad 100644 --- a/docs/deployment/migration-guide.md +++ b/docs/deployment/migration-guide.md @@ -24,6 +24,7 @@ * Since Kyuubi 1.9.0, the support of Spark SQL engine for Spark 3.1 is deprecated, and will be removed in the future. * Since Kyuubi 1.9.0, the support of Spark extensions for Spark 3.1 is removed, please use Spark 3.2 or higher versions. * Since Kyuubi 1.9.0, `kyuubi.frontend.login.timeout`, `kyuubi.frontend.thrift.login.timeout`, `kyuubi.frontend.backoff.slot.length`, `kyuubi.frontend.thrift.backoff.slot.length` are removed. +* Since Kyuubi 1.9.0, the support of Flink engine for Flink 1.16 is deprecated, and will be removed in the future. ## Upgrading from Kyuubi 1.8.0 to 1.8.1 diff --git a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala index 06165272d..0a4188fda 100644 --- a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala +++ b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/FlinkEngineUtils.scala @@ -56,6 +56,9 @@ object FlinkEngineUtils extends Logging { val flinkVersion = EnvironmentInformation.getVersion if (SUPPORTED_FLINK_VERSIONS.contains(FLINK_RUNTIME_VERSION)) { info(s"The current Flink version is $flinkVersion") + if (FlinkEngineUtils.FLINK_RUNTIME_VERSION === "1.16") { + warn("The support for Flink 1.16 is deprecated, and will be removed in the next version.") + } } else { throw new UnsupportedOperationException( s"You are using unsupported Flink version $flinkVersion, " +