Add FileSystem#initialize in SqrlRunner#run (#185)

Author: ferenc-csaky

flink-sql-runner/pom.xml

@@ -37,6 +37,13 @@
       <scope>provided</scope>
     </dependency>
 
+    <dependency>
+      <groupId>org.apache.flink</groupId>
+      <artifactId>flink-core</artifactId>
+      <version>${flink.version}</version>
+      <scope>provided</scope>
+    </dependency>
+
     <dependency>
       <groupId>org.apache.flink</groupId>
       <artifactId>flink-table-api-java-bridge</artifactId>

flink-sql-runner/src/main/java/com/datasqrl/flinkrunner/SqrlRunner.java

@@ -18,6 +18,7 @@
 import javax.annotation.Nullable;
 import org.apache.flink.api.common.RuntimeExecutionMode;
 import org.apache.flink.configuration.Configuration;
+import org.apache.flink.core.fs.FileSystem;
 import org.apache.flink.table.api.TableResult;
 
 /** Runner class specifically for SQRL test environments. */
@@ -34,6 +35,7 @@ public SqrlRunner(
   }
 
   public TableResult run() throws Exception {
+    FileSystem.initialize(config, null);
     var sqlExecutor = SqlExecutor.withUdfClassLoader(config, udfPath);
 
     return run(() -> sqlExecutor);