Skip to content

Commit 818473e

Browse files
authored
Merge pull request apache#31 from saxenapranav/ABFS_3.3.2_dev_rename_added_tests
Abfs 3.3.2 dev rename added tests for explicit/implicit cases. Abfs 3.3.2 dev rename added tests for explicit/implicit cases. Added discussed testcases made azCopyHelper sh file to work in parallelism.
2 parents c430e6f + 1b4ee9b commit 818473e

3 files changed

Lines changed: 1058 additions & 8 deletions

File tree

hadoop-tools/hadoop-azure/src/test/java/org/apache/hadoop/fs/azurebfs/AzcopyHelper.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ public class AzcopyHelper {
3535

3636
File hadoopAzureDir;
3737
String azcopyDirPath;
38-
3938
private String accountName;
4039
private String fileSystemName;
4140
private Configuration configuration;
@@ -137,18 +136,18 @@ public void createFileOrFolder(String pathFromContainerRoot, boolean isFile) thr
137136
String configuredFixedToken = configuration.get(FS_AZURE_SAS_FIXED_TOKEN, null);
138137
if (configuredFixedToken != null) {
139138
if (isFile) {
140-
createFileCreationScript(azcopyDirPath, "createFile.sh", azcopyDirPath, configuredFixedToken, url);
139+
createFileCreationScript(azcopyDirPath, "createFile" + Thread.currentThread().getName() + ".sh", azcopyDirPath, configuredFixedToken, url);
141140
} else {
142-
createFolderCreationScript(azcopyDirPath, "createFolder.sh", azcopyDirPath, configuredFixedToken, url);
141+
createFolderCreationScript(azcopyDirPath, "createFolder" + Thread.currentThread().getName() + ".sh", azcopyDirPath, configuredFixedToken, url);
143142
}
144143
} else {
145144
throw new Exception("The SAS token provided is null");
146145
}
147146
String path;
148147
if (isFile) {
149-
path = azcopyDirPath + "/createFile.sh";
148+
path = azcopyDirPath + "/createFile" + Thread.currentThread().getName() + ".sh";
150149
} else {
151-
path = azcopyDirPath + "/createFolder.sh";
150+
path = azcopyDirPath + "/createFolder" + Thread.currentThread().getName() + ".sh";
152151
}
153152
try {
154153
ProcessBuilder pb = new ProcessBuilder(path);

0 commit comments

Comments
 (0)