diff --git a/src/main/java/com/google/cloud/pubsublite/spark/PslDataWriterFactory.java b/src/main/java/com/google/cloud/pubsublite/spark/PslDataWriterFactory.java
index 51713c3d..12d95921 100644
--- a/src/main/java/com/google/cloud/pubsublite/spark/PslDataWriterFactory.java
+++ b/src/main/java/com/google/cloud/pubsublite/spark/PslDataWriterFactory.java
@@ -39,7 +39,7 @@ public PslDataWriterFactory(StructType inputSchema, PslWriteDataSourceOptions wr
 
   @Override
   public DataWriter<InternalRow> createDataWriter(int partitionId, long taskId, long epochId) {
-    PublisherFactory pg = () -> CACHED_PUBLISHERS.getOrCreate(writeOptions);
-    return new PslDataWriter(partitionId, taskId, epochId, inputSchema, pg);
+    PublisherFactory pf = () -> CACHED_PUBLISHERS.getOrCreate(writeOptions);
+    return new PslDataWriter(partitionId, taskId, epochId, inputSchema, pf);
   }
 }