template store . #2881

apache · Aug 1, 2023 · 71b086d · 71b086d
1 parent 56f4d4e
commit 71b086d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...c/main/scala/org/apache/streampark/flink/kubernetes/v2/httpfs/FileServerPeerAddress.scala b/...c/main/scala/org/apache/streampark/flink/kubernetes/v2/httpfs/FileServerPeerAddress.scala
@@ -36,7 +36,7 @@ object FileServerPeerAddress {
   infer
     .map(Some(_))
     .tap(address.set)
-    .tap(addr => ZIO.logInfo(s"Embedded HTTP file server K8s peer address: $addr"))
+    .tap(addr => ZIO.logInfo(s"Embedded HTTP file server K8s peer address: ${addr.getOrElse("unknown")}"))
     .forkDaemon
     .runUIO
 

diff --git a/...est/scala/org/apache/streampark/flink/kubernetes/v2/example/UsingEmbeddedFileServer.scala b/...est/scala/org/apache/streampark/flink/kubernetes/v2/example/UsingEmbeddedFileServer.scala
@@ -28,7 +28,7 @@ import zio.ZIO
  * Example of using an embedded file server.
  * Tips: Please uncomment the @Ignore tag to execute the example code.
  */
-@Ignore
+ @Ignore
 class UsingEmbeddedFileServer extends AnyWordSpecLike with BeforeAndAfterAll {
 
   "Launch embedded http file server and mirror files" in unsafeRun {