Repository: flink Updated Branches: refs/heads/master d63bc75ff -> 0ae7364bd
[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/2886a417 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2886a417 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2886a417 Branch: refs/heads/master Commit: 2886a41728c0c13b3d01221c502a3e2a7014605d Parents: 246507a 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:12:16 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/2886a417/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
