Skip to content
This repository has been archived by the owner on Sep 18, 2023. It is now read-only.

Commit

Permalink
Following NSE-512, correct class naming and some other issues
Browse files Browse the repository at this point in the history
  • Loading branch information
zhztheplayer committed Oct 11, 2021
1 parent e88fc25 commit 01fdc69
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ private[oap] class GazelleExecutorPlugin extends ExecutorPlugin {
// N/A
}

private[oap] class GazelleSessionsExtensions extends (SparkSessionExtensions => Unit) {
private[oap] class GazelleSessionExtensions extends (SparkSessionExtensions => Unit) {
override def apply(exts: SparkSessionExtensions): Unit = {
GazellePlugin.DEFAULT_INJECTORS.foreach(injector => injector.inject(exts))
}
Expand All @@ -93,7 +93,7 @@ private[oap] object GazellePlugin {
.getCanonicalName)
val SPARK_SESSION_EXTS_KEY: String = StaticSQLConf.SPARK_SESSION_EXTENSIONS.key
val GAZELLE_SESSION_EXTENSION_NAME: String = Objects.requireNonNull(
classOf[GazelleSessionsExtensions].getCanonicalName)
classOf[GazelleSessionExtensions].getCanonicalName)

/**
* Specify all injectors that Gazelle is using in following list.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@ class GazellePluginConfig(conf: SQLConf) extends Logging {
try source.mkString
finally source.close()
//TODO(): check CPU flags to enable/disable AVX512
return true
if (lines.contains("GenuineIntel")) {
return true
} else {
Expand Down

This file was deleted.

0 comments on commit 01fdc69

Please sign in to comment.