configure cross Flink version build

Author: novakov-alexey

build.sbt

@@ -1,12 +1,14 @@
 import sbtrelease.ReleaseStateTransformations._
+import ReleaseProcess._
 
 Global / onChangedBuildSource := ReloadOnSourceChanges
 Global / excludeLintKeys      := Set(git.useGitDescribe)
 
 lazy val rootScalaVersion = "3.2.2"
-lazy val flinkVersion     = "1.16.1"
+lazy val flinkVersion     = System.getProperty("flinkVersion", "1.16.2")
 
 lazy val root = (project in file("."))
+  .settings(ReleaseProcess.releaseSettings(flinkVersion): _*)
   .settings(
     name               := "flink-scala-api",
     scalaVersion       := rootScalaVersion,
@@ -100,7 +102,12 @@ lazy val root = (project in file("."))
                           )
                         else Seq.empty[ReleaseStep]),
     releaseProcess ++= (if (sys.env.contains("RELEASE_PUBLISH"))
-                          Seq[ReleaseStep](inquireVersions, setNextVersion, commitNextVersion, pushChanges)
+                          Seq[ReleaseStep](
+                            inquireVersions,
+                            setNextVersion,
+                            commitNextVersion,
+                            pushChanges
+                          )
                         else Seq.empty[ReleaseStep]),
     mdocIn := new File("README.md")
   )

project/release.scala

@@ -0,0 +1,27 @@
+import sbtrelease.ReleasePlugin._
+import sbtrelease.Version
+import sbtrelease.versionFormatError
+import sbt.AutoPlugin
+import sbt._
+import Keys._
+
+object ReleaseProcess extends AutoPlugin {
+  import sbtrelease.ReleasePlugin.autoImport._
+
+  def cutFlinkPrefix(v: String): String =
+    if (v.contains("_")) v.split("_").tail.mkString else v
+
+  def releaseSettings(flinkVersion: String): Seq[Setting[_]] = Seq(
+    releaseVersion := { ver =>
+      Version(cutFlinkPrefix(ver))
+        .map(_.withoutQualifier.string)
+        .map(v => flinkVersion + "_" + v)
+        .getOrElse(versionFormatError(ver))
+    },
+    releaseNextVersion := { ver =>
+      Version(cutFlinkPrefix(ver))
+        .map(_.bump(releaseVersionBump.value).asSnapshot.string)
+        .getOrElse(versionFormatError(ver))
+    }
+  )
+}

release.sh

@@ -0,0 +1,6 @@
+#!/bin/bash
+set -ex
+RELEASE_VERSION_BUMP=true sbt -DflinkVersion=1.15.4 test 'release with-defaults'
+RELEASE_VERSION_BUMP=true sbt -DflinkVersion=1.16.2 test 'release with-defaults'
+RELEASE_VERSION_BUMP=true sbt -DflinkVersion=1.17.1 test 'release with-defaults'
+wait

version.sbt

@@ -1 +1 @@
-ThisBuild / version := "1.16.1.4-SNAPSHOT"
+ThisBuild / version := "1.0.0-SNAPSHOT"