diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSourcesTest.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSourcesTest.java
index 679227a11dc0..28d351670021 100644
--- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSourcesTest.java
+++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSourcesTest.java
@@ -152,6 +152,7 @@ public class WorkerCustomSourcesTest {
   @Rule public ExpectedLogs logged = ExpectedLogs.none(WorkerCustomSources.class);
 
   private static final String COMPUTATION_ID = "computationId";
+  private static final String SYSTEM_NAME = "systemName";
 
   private DataflowPipelineOptions options;
 
@@ -1019,7 +1020,7 @@ public void testFailedWorkItemsAbort() throws Exception {
             new HotKeyLogger(),
             /*hotKeyLoggingEnabled=*/ false,
             /*stepName=*/ "stepName",
-            /*systemName=*/ "systemName",
+            /*systemName=*/ SYSTEM_NAME,
             StreamingCounters.create(),
             mock(FailureTracker.class),
             "sourceBytesProcessCounterName",