Skip to content

Commit 4574dfb

Browse files
authored
[AURON #1523] Fix CheckStyle Violations in Auron Codebase. (#1523)
* Fix CheckStyle Violations in Auron Codebase. Signed-off-by: slfan1989 <slfan1989@apache.org> * Fix CheckStyle Violations in Auron Codebase. Signed-off-by: slfan1989 <slfan1989@apache.org> --------- Signed-off-by: slfan1989 <slfan1989@apache.org>
1 parent 91ff79a commit 4574dfb

6 files changed

Lines changed: 7 additions & 7 deletions

File tree

spark-extension-shims-spark/src/test/scala/org/apache/spark/sql/auron/EmptyNativeRddSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ class EmptyNativeRddSuite
2828
assert(empty.collect().size === 0)
2929

3030
val thrown = intercept[UnsupportedOperationException] {
31-
empty.reduce((row1, row2) => {
31+
empty.reduce((row1, _) => {
3232
row1
3333
})
3434
}

spark-extension/src/main/scala/org/apache/spark/sql/auron/AuronConverters.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1099,7 +1099,7 @@ object AuronConverters extends Logging {
10991099
rddPartitioner = None,
11001100
rddDependencies = Nil,
11011101
false,
1102-
(_partition, _taskContext) => {
1102+
(_, _) => {
11031103
val nativeEmptyExec = EmptyPartitionsExecNode
11041104
.newBuilder()
11051105
.setNumPartitions(outputPartitioning.numPartitions)

spark-extension/src/main/scala/org/apache/spark/sql/auron/NativeRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ class NativePlanWrapper(var p: (Partition, TaskContext) => PhysicalPlanNode)
104104
@throws[IOException]
105105
@throws[ClassNotFoundException]
106106
private def readObject(in: ObjectInputStream): Unit = {
107-
val _init: Unit = NativePlanWrapper.changeProtobufDefaultRecursionLimit
107+
NativePlanWrapper.changeProtobufDefaultRecursionLimit
108108
p = in.readObject.asInstanceOf[(Partition, TaskContext) => PhysicalPlanNode]
109109
}
110110
}

spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/plan/NativeParquetScanBase.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ abstract class NativeParquetScanBase(basedFileScan: FileSourceScanExec)
6363
None,
6464
Nil,
6565
rddShuffleReadFull = true,
66-
(partition, _context) => {
66+
(partition, _) => {
6767
val resourceId = s"NativeParquetScanExec:${UUID.randomUUID().toString}"
6868
putJniBridgeResource(resourceId, broadcastedHadoopConf)
6969

spark-extension/src/main/scala/org/apache/spark/sql/execution/auron/shuffle/AuronBlockStoreShuffleReaderBase.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ object AuronBlockStoreShuffleReaderBase extends Logging {
162162

163163
case in: InputStreamToByteBuffer =>
164164
Some(in.toByteBuffer)
165-
case in =>
165+
case _ =>
166166
None
167167
}
168168
}

spark-version-annotation-macros/src/main/scala/org/apache/auron/sparkver.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,9 +62,9 @@ object sparkver {
6262

6363
impl(c)(annottees: _*) {
6464
val head = annottees.head.tree match {
65-
case ClassDef(mods, name, tparams, Template(parents, self, _body)) =>
65+
case ClassDef(mods, name, tparams, Template(parents, self, _)) =>
6666
ClassDef(mods, name, tparams, Template(parents, self, List(EmptyTree)))
67-
case ModuleDef(mods, name, Template(parents, self, _body)) =>
67+
case ModuleDef(mods, name, Template(parents, self, _)) =>
6868
ModuleDef(mods, name, Template(parents, self, List(EmptyTree)))
6969
}
7070
c.Expr(q"$head; ..${annottees.tail}")

0 commit comments

Comments
 (0)