From 3cf76a6af8d7799ac5ce27993cb2ca2a027b94cd Mon Sep 17 00:00:00 2001
From: Darin Nee <darin.nee@gmail.com>
Date: Tue, 15 Nov 2016 10:09:21 -0800
Subject: [PATCH] APEXMALHAR-2341: remove vagrant tmp files also when output
 file is in subdirectory

---
 .../com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
index 27a56cdc1e..b706902985 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java
@@ -1309,7 +1309,7 @@ protected void finalizeFile(String fileName) throws IOException
       if (statusName.endsWith(TMP_EXTENSION) && statusName.startsWith(destPath.getName())) {
         //a tmp file has tmp extension always preceded by timestamp
         String actualFileName = statusName.substring(0, statusName.lastIndexOf('.', statusName.lastIndexOf('.') - 1));
-        if (fileName.equals(actualFileName)) {
+        if (destPath.getName().equals(actualFileName)) {
           LOG.debug("deleting stray file {}", statusName);
           fs.delete(status.getPath(), true);
         }