This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit bb5a01a081bc8eebd70470704037471cf8697307
Author: Chesnay Schepler <[email protected]>
AuthorDate: Mon Jun 15 13:05:24 2020 +0200

    [hotfix][e2e] Add 'flink' prefix to flink log backup directory
---
 .../org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java
 
b/flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java
index 6ea327e..d52e6dc 100644
--- 
a/flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java
+++ 
b/flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/LocalStandaloneFlinkResource.java
@@ -112,7 +112,7 @@ public class LocalStandaloneFlinkResource implements 
FlinkResource {
 
        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);

Reply via email to