remove logger

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

@@ -34,7 +34,7 @@ object Main extends LazyLogging {
     // val query = ES.generateServiceDiaryRequest(List("光子嫩肤", "水光针"), List("丰胸", "胸部塑身"), -1)
     // println("###############")
     try {
-      // logger.info("UserPortrait Flink Started")
+      logger.info("UserPortrait Flink Started")
       val env = StreamExecutionEnvironment.getExecutionEnvironment
 
       // TODO read from config
@@ -45,9 +45,8 @@ object Main extends LazyLogging {
         "172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092"
       )
 
-      // remove test
       val kafkaConsumer = new FlinkKafkaConsumer[UserInfo](
-        "gm-portrait-update-device-test",
+        "gm-portrait-update-device",
         new UserInfoDeserializationSchema,
         kafkaConsumerProperties
       )

src/main/scala/com.gmei.up/utils/Redis.scala

@@ -99,7 +99,7 @@ object Redis {
     try {
       implicit val formats = Serialization.formats(NoTypeHints)
 
-      val key = s"streaming:candidate:service_diary:device_id:${deviceId}"
+      val key = s"streaming:candidate:str:service_diary:device_id:${deviceId}"
       contentEitherFuture match {
         case Left(e) => e.printStackTrace()
         case Right(contentFuture) =>