You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:13:04 UTC
[33/50] incubator-apex-core git commit: APEX-36: calling tmp file
'_tmp' instead of '._COPYING_' which is reserved by hadoop
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 <ch...@datatorrent.com>
Authored: Mon Aug 17 11:20:57 2015 -0700
Committer: Chandni Singh <ch...@datatorrent.com>
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;