[FIX] NKGlobalParameters map serializable in 2.11 (#900)

TouK · Apr 28, 2020 · 2c23739 · 2c23739
1 parent 6fe4860
commit 2c23739
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/...ne/flink/api/src/main/scala/pl/touk/nussknacker/engine/flink/api/NkGlobalParameters.scala b/...ne/flink/api/src/main/scala/pl/touk/nussknacker/engine/flink/api/NkGlobalParameters.scala
@@ -21,12 +21,13 @@ case class NkGlobalParameters(buildInfo: String,
   //For now it will be only deployment information
   //NOTE: this information is used in FlinkRestManager - any changes here should be reflected there
   override def toMap: util.Map[String, String] = {
-    Map[String, String](
+    //we wrap in HashMap because .asJava creates not-serializable map in 2.11
+    new util.HashMap(Map[String, String](
       "buildInfo" -> buildInfo,
       "versionId" -> processVersion.versionId.toString,
       "modelVersion" -> processVersion.modelVersion.map(_.toString).orNull,
       "user" -> processVersion.user
-    ).filterNot(_._2 == null).asJava
+    ).filterNot(_._2 == null).asJava)
   }
 }
 

diff --git a/...la/pl/touk/nussknacker/engine/management/streaming/FlinkStreamingProcessManagerSpec.scala b/...la/pl/touk/nussknacker/engine/management/streaming/FlinkStreamingProcessManagerSpec.scala
@@ -169,8 +169,6 @@ class FlinkStreamingProcessManagerSpec extends FunSuite with Matchers with Strea
 
     eventually {
       val status = processManager.findJobStatus(ProcessName(processId)).futureValue
-      //TODO: logging to debug flaky test on travis, remove after correcting...
-      logger.info(s"Status for stop process: $status")
       status.map(_.status) shouldBe Some(FlinkStateStatus.Finished)
     }