[flink] default null job manager address (OpenLineage#3486)

* flink: set default job manager address; pre-commit: use configured JAVA_HOME Signed-off-by: Marquis Chamberlain <[email protected]> * flink: gradle spotlessApply executed Signed-off-by: Marquis Chamberlain <[email protected]> --------- Signed-off-by: Marquis Chamberlain <[email protected]>
AKJUS · Feb 12, 2025 · fffad48 · fffad48
1 parent c97e4d8
commit fffad48
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/.pre_commit/set-java-version.sh b/.pre_commit/set-java-version.sh
@@ -20,6 +20,11 @@ set_java_version_ubuntu() {
 # Function to set Java version on macOS
 set_java_version_macos() {
   local version="$1"
+
+  if [[ -n "$JAVA_HOME" && "$JAVA_HOME" =~ $version ]]; then
+    echo "JAVA_HOME is already set to a compatible version: $JAVA_HOME"
+    return 0
+  fi
 
   echo "Setting Java version to $version on macOS..."
 

diff --git a/.../flink/app/src/main/java/io/openlineage/flink/tracker/OpenLineageContinousJobTracker.java b/.../flink/app/src/main/java/io/openlineage/flink/tracker/OpenLineageContinousJobTracker.java
@@ -52,7 +52,7 @@ public void startTracking(FlinkExecutionContext context) {
     String checkpointApiUrl =
         String.format(
             "http://%s:%s/jobs/%s/checkpoints",
-            config.get(RestOptions.ADDRESS),
+            Optional.ofNullable(config.get(RestOptions.ADDRESS)).orElse("localhost"),
             config.get(RestOptions.PORT),
             context.getJobId().toString());
     HttpGet request = new HttpGet(checkpointApiUrl);