Fix backend complier warnings (#1473)

As title. Co-authored-by: Yicong Huang <[email protected]>
Texera · Mar 16, 2022 · c103a3c · c103a3c
1 parent cc1af97
commit c103a3c
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 6 deletions.
diff --git a/...u/uci/ics/amber/engine/architecture/controller/promisehandlers/SkewDetectionHandler.scala b/...u/uci/ics/amber/engine/architecture/controller/promisehandlers/SkewDetectionHandler.scala
@@ -361,7 +361,7 @@ trait SkewDetectionHandler {
       workflowReshapeState.detectionCallCount += 1
 
       workflow.getAllOperators.foreach(opConfig => {
-        if (opConfig.isInstanceOf[HashJoinOpExecConfig[Any]]) {
+        if (opConfig.isInstanceOf[HashJoinOpExecConfig[_]]) {
           // Skew handling is only for hash-join operator for now.
           // 1: Find the skewed and helper worker that need first phase.
           val skewedAndHelperPairsForFirstPhase =

diff --git a/core/amber/src/main/scala/edu/uci/ics/amber/engine/common/client/ClientActor.scala b/core/amber/src/main/scala/edu/uci/ics/amber/engine/common/client/ClientActor.scala
@@ -18,6 +18,7 @@ import edu.uci.ics.amber.engine.common.rpc.AsyncRPCClient.{ControlInvocation, Re
 import edu.uci.ics.amber.engine.common.rpc.AsyncRPCServer.ControlCommand
 
 import scala.collection.mutable
+import scala.util.Success
 
 // TODO: Rename or refactor it since it has mixed duties (send/receive messages, execute callbacks)
 private[client] object ClientActor {
@@ -37,7 +38,7 @@ private[client] class ClientActor extends Actor {
     case InitializeRequest(workflow, controllerConfig) =>
       assert(controller == null)
       controller = context.actorOf(Controller.props(workflow, controllerConfig))
-      sender ! ()
+      sender ! Unit
     case ClosureRequest(closure) =>
       try {
         sender ! closure()

diff --git a/...ber/src/main/scala/edu/uci/ics/texera/workflow/operators/source/sql/SQLSourceOpExec.scala b/...ber/src/main/scala/edu/uci/ics/texera/workflow/operators/source/sql/SQLSourceOpExec.scala
@@ -90,7 +90,7 @@ abstract class SQLSourceOpExec(
                 if (resultSet.next()) {
 
                   // manually skip until the offset position in order to adapt to progressive batches
-                  curOffset.fold()(offset => {
+                  curOffset.foreach(offset => {
                     if (offset > 0) {
                       curOffset = Option(offset - 1)
                       break
@@ -104,7 +104,7 @@ abstract class SQLSourceOpExec(
                     break
 
                   // update the limit in order to adapt to progressive batches
-                  curLimit.fold()(limit => {
+                  curLimit.foreach(limit => {
                     if (limit > 0) {
                       curLimit = Option(limit - 1)
                     }

diff --git a/...la/edu/uci/ics/texera/workflow/operators/source/sql/asterixdb/AsterixDBSourceOpExec.scala b/...la/edu/uci/ics/texera/workflow/operators/source/sql/asterixdb/AsterixDBSourceOpExec.scala
@@ -99,7 +99,7 @@ class AsterixDBSourceOpExec private[asterixdb] (
                 if (resultSet.hasNext) {
 
                   // manually skip until the offset position in order to adapt to progressive batches
-                  curOffset.fold()(offset => {
+                  curOffset.foreach(offset => {
                     if (offset > 0) {
                       curOffset = Option(offset - 1)
                       break
@@ -113,7 +113,7 @@ class AsterixDBSourceOpExec private[asterixdb] (
                     break
 
                   // update the limit in order to adapt to progressive batches
-                  curLimit.fold()(limit => {
+                  curLimit.foreach(limit => {
                     if (limit > 0) {
                       curLimit = Option(limit - 1)
                     }