fix flinkrunner snapshot tag

ferenc-csaky · ferenc-csaky · commit 0823fefd6eb4 · 2025-10-30T13:33:55.000+01:00
diff --git a/sqrl-testing/sqrl-testing-integration/src/test/java/com/datasqrl/flinkrunner/AbstractITSupport.java b/sqrl-testing/sqrl-testing-integration/src/test/java/com/datasqrl/flinkrunner/AbstractITSupport.java
@@ -46,7 +46,7 @@ public class AbstractITSupport {
   void startFlink() {
     var imgRepo = System.getProperty("flinkrunner.image.repo", "ghcr.io");
     var tag = System.getProperty("flinkrunner.version", "latest");
-    if (!tag.equals("latest")) {
+    if (!tag.equals("latest") && !tag.toLowerCase().endsWith("snapshot")) {
       tag += "-flink-2.1";
     }
 

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public class AbstractITSupport {`
`46`	`46`	`void startFlink() {`
`47`	`47`	`var imgRepo = System.getProperty("flinkrunner.image.repo", "ghcr.io");`
`48`	`48`	`var tag = System.getProperty("flinkrunner.version", "latest");`
`49`		`- if (!tag.equals("latest")) {`
	`49`	`+ if (!tag.equals("latest") && !tag.toLowerCase().endsWith("snapshot")) {`
`50`	`50`	`tag += "-flink-2.1";`
`51`	`51`	`}`
`52`	`52`