APEX-36: calling tmp file '_tmp' instead of '._COPYING_' which is reserved by hadoop
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/7560cefd Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/7560cefd Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/7560cefd Branch: refs/heads/master Commit: 7560cefd9cc5bd0a0463b59d83ad26ce5a11d70d Parents: 9d08532 Author: Chandni Singh <[email protected]> Authored: Mon Aug 17 11:20:57 2015 -0700 Committer: Chandni Singh <[email protected]> Committed: Mon Aug 17 12:29:59 2015 -0700 ---------------------------------------------------------------------- .../src/main/java/com/datatorrent/common/util/FSStorageAgent.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/7560cefd/common/src/main/java/com/datatorrent/common/util/FSStorageAgent.java ---------------------------------------------------------------------- diff --git a/common/src/main/java/com/datatorrent/common/util/FSStorageAgent.java b/common/src/main/java/com/datatorrent/common/util/FSStorageAgent.java index 14275fa..feb9ae2 100644 --- a/common/src/main/java/com/datatorrent/common/util/FSStorageAgent.java +++ b/common/src/main/java/com/datatorrent/common/util/FSStorageAgent.java @@ -42,7 +42,7 @@ import com.datatorrent.netlet.util.DTThrowable; */ public class FSStorageAgent implements StorageAgent, Serializable { - public static final String TMP_FILE = "._COPYING_"; + public static final String TMP_FILE = "_tmp"; protected static final String STATELESS_CHECKPOINT_WINDOW_ID = Long.toHexString(Stateless.WINDOW_ID); public final String path; protected final transient FileContext fileContext;
