comment logger

build.sbt

@@ -27,8 +27,8 @@ lazy val root = (project in file("."))
   .settings(
     name := "streamingUserPortrait",
 
-    libraryDependencies += "ch.qos.logback" % "logback-classic" % "1.2.3",
-    libraryDependencies += "com.typesafe.scala-logging" %% "scala-logging" % "3.9.2",
+    // libraryDependencies += "ch.qos.logback" % "logback-classic" % "1.2.3",
+    // libraryDependencies += "com.typesafe.scala-logging" %% "scala-logging" % "3.9.2",
 
     libraryDependencies += "com.alibaba" % "fastjson" % "1.2.75",
     libraryDependencies += jsonNative,

src/main/scala/com.gmei.up/Main.scala

@@ -34,7 +34,8 @@ object Main extends LazyLogging {
     // val query = ES.generateServiceDiaryRequest(List("光子嫩肤", "水光针"), List("丰胸", "胸部塑身"), -1)
     // println("###############")
     try {
-      logger.info("UserPortrait Flink Started")
+      // TODO logger
+      // logger.info("UserPortrait Flink Started")
       val env = StreamExecutionEnvironment.getExecutionEnvironment
 
       // TODO read from config
@@ -108,7 +109,8 @@ object Main extends LazyLogging {
           Redis.save(ES.request(serviceDiaryReq), deviceId, "service_diary", streamTimeBegin)
 
           // current time
-          logger.info(s"${user.eventCn} ${deviceId}")
+          // TODO logger
+          // logger.info(s"${user.eventCn} ${deviceId}")
 
           val cost = streamTimeBegin - user.sendTimestamp
           if (cost > 1000) {
@@ -136,7 +138,8 @@ object Main extends LazyLogging {
               Map("Main.main" -> "stream.map", "error" -> e.getStackTrace.mkString("\n")),
               contentType = "exception"
             )
-            logger.error(e.getStackTrace.mkString("\n"))
+            // TODO logger
+            // logger.error(e.getStackTrace.mkString("\n"))
             e.printStackTrace()
             ""
         }
@@ -151,7 +154,8 @@ object Main extends LazyLogging {
           Map("method" -> "main", "error" -> e.getStackTrace.mkString("\n")),
           contentType = "exception"
         )
-        logger.error(e.getStackTrace.mkString("\n"))
+        // TODO logger
+        // logger.error(e.getStackTrace.mkString("\n"))
         e.printStackTrace()
     }
 }