如何解决 scala trait 中的成员冲突 (org.slf4j.Logger/com.typesafe.scalalogging.Logger)

问题描述

我使用的是 Spark 2.1.1。这是我的问题：

我在同一个目录中有 2 个名为 tools 的文件。一个是ma​​in_process.scala，另一个是ma​​in_process_fun.scala。这些文件基本上是这样的：

1.- main_process.scala：

package mod.pack.tools

import x.y.spark.InitSpark
import com.typesafe.config.Config

trait main_process extends InitSpark with main_process_fun {
  this: InitSpark  =>
  /**
    * @param spark  Initialized SparkSession
    * @param config Config retrieved from args
    */
  override def run(spark: SparkSession,config: Config): Int = {
    logger.info("LOG")
    implicit val sparkSes = spark

    pre_defined_f1(config).flatMap(cfg => pre_defined_f2(cfg).flatMap(pre_defined_f3(_,cfg))) match {
      case Success(_) =>
        logger.info("OK")
      case Failure(e) =>
        logger.info("ERROR")
    }
  }
}

2.- main_process_fun.scala：

package mod.pack.tools

import mod.pack.tools.another_folder.another_trait
import com.typesafe.config.Config

trait main_process_fun extends another_trait with com.typesafe.scalalogging.LazyLogging {

  def pre_defined_f1(conf: Config): Try[Config] = Try {
    blablabla
  }

  def pre_defined_f2(conf: Config)(implicit spark: SparkSession): Try[DataFrame] = Try {
    blablabla
    logger.info("LOG")
  }

  def pre_defined_f3(conf: Config): Column = {
    blablabla
    logger.info("LOG")
  }
}

我在尝试编译项目时出错。错误说：

trait main_process inherits conflicting members
lazy value logger in trait LazyLogging of type org.slf4j.Logger and
lazy value logger in trait LazyLogging of type com.typesafe.scalalogging.Logger
(Note: this can be resolved by declaring an override in trait main_process.)
trait main_process extends InitSpark with main_process_fun {

我已经尝试覆盖记录器，但收到此错误消息：

lazy value logger has incompatible type

我也尝试导入 main_process_fun 而不是从 main_process 扩展它，但是没有成功，我不知道是我做错了还是这个想法本身不好解决这个问题。

非常感谢您帮助解决这个继承冲突！

顺便说一下，logger 定义为：

package com.typesafe.scalalogging
trait LazyLogging extends scala.AnyRef {
 @scala.transient
 protected lazy val logger : com.typesafe.scalalogging.Logger = { /* compiled code */ }
}

解决方法

错误消息说明 logger 有两个版本，一个在 org.slf4j.Logger 中，另一个在 com.typesafe.scalalogging.Logger 中。这些相互冲突，所以你需要放弃一个。 InitSpark 似乎使用了第一个，因此在第二个特征中也使用相同的类型：

trait main_process_fun extends another_trait with org.slf4j.Logger {

,

我在 Tim 的帮助下找到了解决方案！

首先：

trait main_process_fun extends another_trait {

然后我导入：

import org.slf4j.LoggerFactory

最后，在每个使用记录器值的方法中，我声明：

val logger = LoggerFactory.getLogger(classOf[main_process_fun])

谢谢！