diff --git a/amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/WorkerSpec.scala b/amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/WorkerSpec.scala index 7093dbfe8ef..6527243921f 100644 --- a/amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/WorkerSpec.scala +++ b/amber/src/test/scala/org/apache/texera/amber/engine/architecture/worker/WorkerSpec.scala @@ -173,7 +173,7 @@ class WorkerSpec ) val addPort1 = AsyncRPCClient.ControlInvocation( METHOD_ASSIGN_PORT, - AssignPortRequest(mockPortId, input = true, mkSchema(1).toRawSchema, List(""), List()), + AssignPortRequest(mockPortId, input = true, mkSchema(1).toRawSchema, List(), List()), AsyncRPCContext(COORDINATOR, identifier1), 1 )