Fix leftovers flink-jar-runner references

Signed-off-by: Marvin Froeder <[email protected]>

Author: velo

flink-sql-runner/pom.xml

@@ -215,7 +215,7 @@
             </goals>
             <phase>package</phase>
             <configuration>
-              <finalName>flink-jar-runner.uber</finalName>
+              <finalName>flink-sql-runner.uber</finalName>
               <shadedArtifactAttached>true</shadedArtifactAttached>
               <shadedClassifierName>flink${flink.version}</shadedClassifierName>
               <artifactSet>
@@ -433,7 +433,7 @@
                   <skip>${skipTests}</skip>
                   <arguments>
                     <argument>logs</argument>
-                    <argument>flink-jar-runner-jobmanager-1</argument>
+                    <argument>flink-sql-runner-jobmanager-1</argument>
                   </arguments>
                 </configuration>
               </execution>

flink-sql-runner/src/main/docker/Dockerfile

@@ -16,6 +16,6 @@
 
 FROM flink:${flink-base-image}
 
-RUN mkdir -p /opt/flink/plugins/flink-jar-runner
-COPY flink-jar-runner.uber.jar /opt/flink/plugins/flink-jar-runner
+RUN mkdir -p /opt/flink/plugins/flink-sql-runner
+COPY flink-sql-runner.uber.jar /opt/flink/plugins/flink-sql-runner
 COPY system-functions-discovery-${project.version}.jar /opt/flink/lib/system-functions-discovery.jar

flink-sql-runner/src/main/docker/docker-compose.yml

@@ -14,7 +14,7 @@
 # limitations under the License.
 #
 
-name: flink-jar-runner
+name: flink-sql-runner
 
 networks:
   datasqrl_network:
@@ -50,7 +50,7 @@ services:
         taskmanager.slot.timeout: 30000ms
         jobmanager.rpc.address: jobmanager
         state.savepoints-storage: filesystem
-        state.savepoints.dir: file:///tmp/flink-jar-runner
+        state.savepoints.dir: file:///tmp/flink-sql-runner
     command: jobmanager
     ports:
       - "8081:8081"  # Flink JobManager REST port
@@ -89,7 +89,7 @@ services:
         taskmanager.slot.timeout: 30000ms
         jobmanager.rpc.address: jobmanager
         state.savepoints-storage: filesystem
-        state.savepoints.dir: file:///tmp/flink-jar-runner
+        state.savepoints.dir: file:///tmp/flink-sql-runner
     command: taskmanager
     depends_on:
       jobmanager:

flink-sql-runner/src/main/java/com/datasqrl/FlinkMain.java

@@ -76,7 +76,7 @@ public Void call() throws Exception {
   private final String udfPath;
 
   public static void main(String[] args) throws Exception {
-    System.out.printf("\n\nExecuting flink-jar-runner: %s\n\n", Arrays.toString(args));
+    System.out.printf("\n\nExecuting flink-sql-runner: %s\n\n", Arrays.toString(args));
 
     CommandLine cl = new CommandLine(new SqlRunner());
     cl.execute(args);
@@ -88,7 +88,7 @@ public static void main(String[] args) throws Exception {
     }
 
     new FlinkMain(runner.sqlFile, runner.planFile, runner.configDir, runner.udfPath).run();
-    System.out.println("Finished flink-jar-runner");
+    System.out.println("Finished flink-sql-runner");
   }
 
   public int run() throws Exception {

flink-sql-runner/src/test/java/com/datasqrl/FlinkMainIT.java

@@ -154,12 +154,12 @@ void givenPlanScript_whenCheckPoint_thenResumeSuccessfulySuccess() throws Except
     // test if initial change to compilation plan took effect
     assertThat(transactionDao.getDoubleTA()).isEqualTo(3);
 
-    Path savePoint = Path.of("/tmp/flink-jar-runner/" + System.currentTimeMillis());
+    Path savePoint = Path.of("/tmp/flink-sql-runner/" + System.currentTimeMillis());
 
     // take a savepoint
     CommandLineUtil.execute(
         Path.of("."),
-        "docker exec -t flink-jar-runner-jobmanager-1 bin/flink stop "
+        "docker exec -t flink-sql-runner-jobmanager-1 bin/flink stop "
             + jobResponse.getJobid()
             + " --savepointPath "
             + savePoint);
@@ -245,7 +245,7 @@ JarRunResponseBody execute(String... arguments) {
 
   @SneakyThrows
   JarRunResponseBody restoreAndExecute(String savepointPath, String... arguments) {
-    var jarFile = new File("target/flink-jar-runner.uber.jar");
+    var jarFile = new File("target/flink-sql-runner.uber.jar");
 
     var uploadResponse = client.uploadJar(jarFile);