You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2020/05/18 17:36:18 UTC
[flink] 02/03: [FLINK-17687][tests] Collect log files before
tearing down Mesos
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 12d662c9da2dc3e18fdd3d752ddeeb07df1f5945
Author: Gary Yao <ga...@apache.org>
AuthorDate: Thu May 14 17:12:08 2020 +0200
[FLINK-17687][tests] Collect log files before tearing down Mesos
---
flink-jepsen/src/jepsen/flink/mesos.clj | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/flink-jepsen/src/jepsen/flink/mesos.clj b/flink-jepsen/src/jepsen/flink/mesos.clj
index e944089..c104158 100644
--- a/flink-jepsen/src/jepsen/flink/mesos.clj
+++ b/flink-jepsen/src/jepsen/flink/mesos.clj
@@ -22,6 +22,7 @@
[util :as util :refer [meh]]]
[jepsen.control.util :as cu]
[jepsen.os.debian :as debian]
+ [jepsen.flink.utils :as fu]
[jepsen.flink.utils :refer [create-supervised-service! stop-supervised-service!]]
[jepsen.flink.zookeeper :refer [zookeeper-uri]]))
@@ -195,4 +196,6 @@
(stop-marathon! test node))
db/LogFiles
(log-files [_ test node]
- (if (cu/exists? log-dir) (cu/ls-full log-dir) []))))
+ (concat
+ (if (cu/exists? log-dir) (cu/ls-full log-dir) [])
+ (fu/find-files! slave-dir "*.log")))))