diff --git a/src/main/scala/io/sdkman/changelogs/FlinkMigrations.scala b/src/main/scala/io/sdkman/changelogs/FlinkMigrations.scala
index 66494d9a1..264b45b88 100644
--- a/src/main/scala/io/sdkman/changelogs/FlinkMigrations.scala
+++ b/src/main/scala/io/sdkman/changelogs/FlinkMigrations.scala
@@ -21,4 +21,39 @@ class FlinkMigrations {
           " and at any scale.",
       websiteUrl = "https://flink.apache.org/"
     ).insert()
+
+  private def url(version: String, scala: String) =
+    s"https://archive.apache.org/dist/flink/flink-$version/flink-$version-bin-scala_$scala.tgz"
+
+  private def flinkVersion(
+      flinkVersion: String,
+      scalaVersion: String
+  ) =
+    Version(
+      candidate = "flink",
+      version = flinkVersion,
+      url = url(flinkVersion, scalaVersion)
+    )
+
+  @ChangeSet(
+    order = "008",
+    id = "008-add_flink_1_14_2",
+    author = "ChethanUK"
+  )
+  def migration008(implicit db: MongoDatabase) = {
+    val flinkVersions = List(
+      "1.11.6",
+      "1.12.7",
+      "1.13.5",
+      "1.14.2"
+    )
+    List("2.11", "2.12")
+      .flatMap { scalaVersion =>
+        flinkVersions.map { version =>
+          flinkVersion(version, scalaVersion)
+        }
+      }
+      .validate()
+      .insert()
+  }
 }
diff --git a/src/main/scala/io/sdkman/changelogs/SparkMigrations.scala b/src/main/scala/io/sdkman/changelogs/SparkMigrations.scala
index c72cf36b8..a5536328f 100644
--- a/src/main/scala/io/sdkman/changelogs/SparkMigrations.scala
+++ b/src/main/scala/io/sdkman/changelogs/SparkMigrations.scala
@@ -5,6 +5,20 @@ import com.mongodb.client.MongoDatabase
 
 @ChangeLog(order = "007")
 class SparkMigrations {
+
+  private def url(version: String, hadoop: String) =
+    s"https://archive.apache.org/dist/spark/spark-$version/spark-$version-bin-hadoop$hadoop.tgz"
+
+  private def sparkVersion(
+      sparkVersion: String,
+      hadoopVersion: String
+  ) =
+    Version(
+      candidate = "spark",
+      version = sparkVersion,
+      url = url(sparkVersion, hadoopVersion)
+    )
+
   @ChangeSet(
     order = "017",
     id = "016-add_spark_3.2.0",