Fixed the return type for matcher

epiphanous · Nov 30, 2022 · fb692b9 · fb692b9
1 parent ce18f40
commit fb692b9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/scala/io/epiphanous/flinkrunner/model/sink/JdbcSinkConfig.scala b/src/main/scala/io/epiphanous/flinkrunner/model/sink/JdbcSinkConfig.scala
@@ -624,10 +624,10 @@ case class JdbcSinkConfig[ADT <: FlinkEvent](
     }
   }
 
-  def _matcher(value : Any): Unit ={
-    val encoder = new JsonRowEncoder[Map[String,Any]]()
+  def _matcher(value: Any) = {
+    val encoder = new JsonRowEncoder[Map[String, Any]]()
     value match {
-      case ts: Instant       => Timestamp.from(ts)
+      case ts: Instant => Timestamp.from(ts)
       case m: Map[String, Any] => encoder.encode(m) match {
         case Success(jsonString) => jsonString
         case Failure(e) => {