From 4c6fc2aaf3a3ff83438608200a9ece59df06ff0f Mon Sep 17 00:00:00 2001
From: Robert Metzger <rmetzger@apache.org>
Date: Fri, 28 Feb 2020 09:18:53 +0100
Subject: [PATCH] [FLINK-16292][e2e] Improve debugging of schema registry test

---
 flink-end-to-end-tests/test-scripts/kafka-common.sh | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/flink-end-to-end-tests/test-scripts/kafka-common.sh b/flink-end-to-end-tests/test-scripts/kafka-common.sh
index d25ce015fbe..e0b73804886 100644
--- a/flink-end-to-end-tests/test-scripts/kafka-common.sh
+++ b/flink-end-to-end-tests/test-scripts/kafka-common.sh
@@ -76,7 +76,7 @@ function start_kafka_cluster {
 
     if [ $time_diff -ge $MAX_RETRY_SECONDS ]; then
         echo "Kafka cluster did not start after $MAX_RETRY_SECONDS seconds. Printing Kafka logs:"
-        cat $KAFKA_DIR/logs/*
+        debug_error
         exit 1
     else
         echo "Waiting for broker..."
@@ -166,6 +166,7 @@ function start_confluent_schema_registry {
 
   if ! get_and_verify_schema_subjects_exist; then
       echo "Could not start confluent schema registry"
+      debug_error
       return 1
   fi
 }
@@ -183,3 +184,13 @@ function get_and_verify_schema_subjects_exist {
 function stop_confluent_schema_registry {
     $CONFLUENT_DIR/bin/schema-registry-stop
 }
+
+function debug_error {
+    echo "Debugging test failure. Currently running JVMs:"
+    jps -v
+    echo "Kafka logs:"
+    find $KAFKA_DIR/logs/ -type f -exec printf "\n===\ncontents of {}:\n===\n" \; -exec cat {} \;
+
+    echo "Kafka config:"
+    find $KAFKA_DIR/config/ -type f -exec printf "\n===\ncontents of {}:\n===\n" \; -exec cat {} \;
+}
-- 
GitLab