Commit d26d5800 authored by 赵威's avatar 赵威

remove logger

parent 8969f8aa
package com.gmei.up
import java.util.Properties
import com.typesafe.scalalogging.LazyLogging
// TODO remove
// import com.typesafe.scalalogging.LazyLogging
import org.apache.flink.api.scala._
import org.apache.flink.streaming.api.scala.{ StreamExecutionEnvironment, DataStream }
import org.apache.flink.streaming.connectors.kafka.{
......@@ -28,7 +29,7 @@ class UserInfoDeserializationSchema extends KafkaDeserializationSchema[UserInfo]
Types.GENERIC(classOf[UserInfo])
}
// TODO
// TODO remove
// extends LazyLogging
object Main {
def main(args: Array[String]): Unit =
......
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