Commit 66563e8e authored by 赵威's avatar 赵威

update logger

parent dd6c4b88
package com.gmei.up package com.gmei.up
import java.util.Properties import java.util.Properties
import com.typesafe.scalalogging.Logger import com.typesafe.scalalogging.LazyLogging
import org.apache.flink.api.scala._ import org.apache.flink.api.scala._
import org.apache.flink.streaming.api.scala.{ StreamExecutionEnvironment, DataStream } import org.apache.flink.streaming.api.scala.{ StreamExecutionEnvironment, DataStream }
import org.apache.flink.streaming.connectors.kafka.{ import org.apache.flink.streaming.connectors.kafka.{
...@@ -28,14 +28,14 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo] ...@@ -28,14 +28,14 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo]
Types.GENERIC(classOf[UserInfo]) Types.GENERIC(classOf[UserInfo])
} }
object Main { object Main extends LazyLogging {
def main(args: Array[String]): Unit = def main(args: Array[String]): Unit =
// println("###############") // println("###############")
// val query = ES.generateServiceDiaryRequest(List("光子嫩肤", "水光针"), List("丰胸", "胸部塑身"), -1) // val query = ES.generateServiceDiaryRequest(List("光子嫩肤", "水光针"), List("丰胸", "胸部塑身"), -1)
// println("###############") // println("###############")
try { try {
val logger = Logger("Root")
val env = StreamExecutionEnvironment.getExecutionEnvironment val env = StreamExecutionEnvironment.getExecutionEnvironment
logger.info("hello") logger.info("hello")
// // TODO read from config // // TODO read from config
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment