[hotfix][e2e] Add 'flink' prefix to flink log backup directory

is · Jun 17, 2020 · 0c4c461 · 0c4c461
1 parent 03a8ef6
commit 0c4c461
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java b/...-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java
@@ -113,7 +113,7 @@ private void shutdownCluster() {
 
  private void backupLogs() {
  if (logBackupDirectory != null) {
- final Path targetDirectory = logBackupDirectory.resolve(UUID.randomUUID().toString());
+ final Path targetDirectory = logBackupDirectory.resolve("flink-" + UUID.randomUUID().toString());
  try {
  distribution.copyLogsTo(targetDirectory);
  LOG.info("Backed up logs to {}.", targetDirectory);