diff --git a/dataset-registry/pom.xml b/dataset-registry/pom.xml
index 999053d7..978428a1 100644
--- a/dataset-registry/pom.xml
+++ b/dataset-registry/pom.xml
@@ -13,7 +13,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<scala.maj.version>2.12</scala.maj.version>
 		<scala.version>2.12.11</scala.version>
-        <flink.version>1.15.2</flink.version>
+        <flink.version>1.13.5</flink.version>
 		<kafka.version>2.4.0</kafka.version>
 		<java.target.runtime>11</java.target.runtime>
 		<jackson-jaxrs.version>1.9.13</jackson-jaxrs.version>
diff --git a/framework/pom.xml b/framework/pom.xml
index 04a3cd73..86eed3c3 100644
--- a/framework/pom.xml
+++ b/framework/pom.xml
@@ -13,7 +13,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<scala.maj.version>2.12</scala.maj.version>
 		<scala.version>2.12.11</scala.version>
-		<flink.version>1.15.2</flink.version>
+		<flink.version>1.13.5</flink.version>
 		<kafka.version>2.4.0</kafka.version>
 		<java.target.runtime>11</java.target.runtime>
 		<jackson-jaxrs.version>1.9.13</jackson-jaxrs.version>
@@ -29,7 +29,7 @@
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-connector-kafka</artifactId>
+            <artifactId>flink-connector-kafka_${scala.maj.version}</artifactId>
             <version>${flink.version}</version>
         </dependency>
         <dependency>
@@ -109,7 +109,7 @@
         </dependency>
         <dependency>
             <groupId>org.apache.flink</groupId>
-            <artifactId>flink-test-utils</artifactId>
+            <artifactId>flink-test-utils_${scala.maj.version}</artifactId>
             <version>${flink.version}</version>
             <scope>test</scope>
         </dependency>
diff --git a/pom.xml b/pom.xml
index 7010ad9d..bbeaddf9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -30,7 +30,7 @@
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<scala.maj.version>2.12</scala.maj.version>
 		<scala.version>2.12.11</scala.version>
-		<flink.version>1.15.2</flink.version>
+		<flink.version>1.13.5</flink.version>
 		<kafka.version>2.4.0</kafka.version>
 		<java.target.runtime>11</java.target.runtime>
 		<jackson-jaxrs.version>1.9.13</jackson-jaxrs.version>