Commit 3d56c888 authored by 赵威's avatar 赵威

add logger

parent 66563e8e
...@@ -28,6 +28,7 @@ lazy val root = (project in file(".")) ...@@ -28,6 +28,7 @@ lazy val root = (project in file("."))
.settings( .settings(
name := "streamingUserPortrait", name := "streamingUserPortrait",
libraryDependencies += "ch.qos.logback" % "logback-classic" % "1.2.3",
libraryDependencies += "com.typesafe.scala-logging" %% "scala-logging" % "3.9.2", libraryDependencies += "com.typesafe.scala-logging" %% "scala-logging" % "3.9.2",
libraryDependencies += "com.alibaba" % "fastjson" % "1.2.75", libraryDependencies += "com.alibaba" % "fastjson" % "1.2.75",
......
...@@ -36,7 +36,7 @@ object Main extends LazyLogging { ...@@ -36,7 +36,7 @@ object Main extends LazyLogging {
try { try {
val env = StreamExecutionEnvironment.getExecutionEnvironment val env = StreamExecutionEnvironment.getExecutionEnvironment
logger.info("hello") logger.info("UserPortrait Flink Started")
// // TODO read from config // // TODO read from config
// val kafkaConsumerProperties = new Properties // val kafkaConsumerProperties = new Properties
......
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