You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2019/08/06 12:51:25 UTC

[flink] 02/03: [hotfix] Print Flink logs from YARN in test_yarn_kerberos_docker.sh

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

aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 4f4c4b8f1b1a6486196ec9bc982fb0132c6f4045
Author: Aljoscha Krettek <al...@apache.org>
AuthorDate: Fri Aug 2 14:48:24 2019 +0200

    [hotfix] Print Flink logs from YARN in test_yarn_kerberos_docker.sh
---
 flink-end-to-end-tests/test-scripts/test_yarn_kerberos_docker.sh | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/flink-end-to-end-tests/test-scripts/test_yarn_kerberos_docker.sh b/flink-end-to-end-tests/test-scripts/test_yarn_kerberos_docker.sh
index 6a170b5..de64083 100755
--- a/flink-end-to-end-tests/test-scripts/test_yarn_kerberos_docker.sh
+++ b/flink-end-to-end-tests/test-scripts/test_yarn_kerberos_docker.sh
@@ -162,6 +162,13 @@ function copy_and_show_logs {
     done
     echo "Docker logs:"
     docker logs master
+
+    echo "Flink logs:"
+    docker exec -it master bash -c "kinit -kt /home/hadoop-user/hadoop-user.keytab hadoop-user"
+    application_id=`docker exec -it master bash -c "yarn application -list -appStates ALL" | grep "Flink session cluster" | awk '{print \$1}'`
+    echo "Application ID: $application_id"
+    docker exec -it master bash -c "yarn logs -applicationId $application_id"
+    docker exec -it master bash -c "kdestroy"
 }
 
 start_time=$(date +%s)