[hotfix] [test] Also trap INT signal in Kafka end-to-end test This allows the test to perform the cleanup procedure (as well as printing any error logs) if an interruption occurred while waiting for the test data to be written to Kafka, therefore increasing visibility of reasons to why the test was stalling.
This closes #5568. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0396fc8c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0396fc8c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0396fc8c Branch: refs/heads/release-1.4 Commit: 0396fc8c03a64f1281f2a535b2702188c5234f5c Parents: 59169d0 Author: Tzu-Li (Gordon) Tai <[email protected]> Authored: Mon Feb 26 19:01:32 2018 +0800 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Mon Feb 26 23:16:57 2018 +0800 ---------------------------------------------------------------------- test-infra/end-to-end-test/test_streaming_kafka010.sh | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0396fc8c/test-infra/end-to-end-test/test_streaming_kafka010.sh ---------------------------------------------------------------------- diff --git a/test-infra/end-to-end-test/test_streaming_kafka010.sh b/test-infra/end-to-end-test/test_streaming_kafka010.sh index c7564ea..a6a9a8e 100755 --- a/test-infra/end-to-end-test/test_streaming_kafka010.sh +++ b/test-infra/end-to-end-test/test_streaming_kafka010.sh @@ -51,6 +51,7 @@ function kafka_cleanup { # make sure to run regular cleanup as well cleanup } +trap kafka_cleanup INT trap kafka_cleanup EXIT # zookeeper outputs the "Node does not exist" bit to stderr
