diff --git a/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala b/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala
index c680177e28c..cb77ae266aa 100644
--- a/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala
+++ b/core/amber/src/test/scala/edu/uci/ics/texera/workflow/SchemaPropagationSpec.scala
@@ -4,7 +4,6 @@ import edu.uci.ics.amber.core.tuple.{AttributeType, Schema}
 import edu.uci.ics.amber.core.workflow.{PhysicalOp, WorkflowContext}
 import edu.uci.ics.amber.operator.LogicalOp
 import edu.uci.ics.amber.operator.metadata.OperatorInfo
-import edu.uci.ics.amber.operator.sink.SinkOpDesc
 import edu.uci.ics.amber.operator.source.SourceOperatorDescriptor
 import edu.uci.ics.amber.virtualidentity.{ExecutionIdentity, OperatorIdentity, WorkflowIdentity}
 import edu.uci.ics.amber.workflow.{InputPort, OutputPort, PortIdentity}
@@ -24,7 +23,7 @@ class SchemaPropagationSpec extends AnyFlatSpec with BeforeAndAfter {
       OperatorInfo("", "", "", List(InputPort()), List(OutputPort()))
   }
 
-  private class TempTestSinkOpDesc extends SinkOpDesc {
+  private class TempTestSinkOpDesc extends LogicalOp {
     override def getPhysicalOp(
         workflowId: WorkflowIdentity,
         executionId: ExecutionIdentity
diff --git a/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala b/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala
deleted file mode 100644
index da190bcb7e4..00000000000
--- a/core/workflow-operator/src/main/scala/edu/uci/ics/amber/operator/sink/SinkOpDesc.scala
+++ /dev/null
@@ -1,5 +0,0 @@
-package edu.uci.ics.amber.operator.sink
-
-import edu.uci.ics.amber.operator.LogicalOp
-
-abstract class SinkOpDesc extends LogicalOp