diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/writer/AzureTransactionLogSynchronizer.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/writer/AzureTransactionLogSynchronizer.java index 253d7121c7ba..a6651f7986e3 100644 --- a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/writer/AzureTransactionLogSynchronizer.java +++ b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/writer/AzureTransactionLogSynchronizer.java @@ -53,7 +53,7 @@ public void write(ConnectorSession session, String clusterId, Path newLogEntryPa outputStream.write(entryContents); } try { - fileSystem.renameFile(tmpFileName, newLogEntryPath.toString()); + fileSystem.renameFile(tmpFilePath, newLogEntryPath.toString()); } catch (IOException e) { conflict = true;