update

googleapis · Apr 2, 2021 · 165ee80 · 165ee80
1 parent 2c3a87d
commit 165ee80
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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);
   }
 }