Github user zentol commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5062#discussion_r153793789
  
    --- Diff: 
flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/NonHAAbstractQueryableStateTestBase.java
 ---
    @@ -68,11 +68,14 @@ public static void setup(int proxyPortRangeStart, int 
serverPortRangeStart) {
        @AfterClass
        public static void tearDown() {
                try {
    +                   client.shutdownAndWait();
    +
                        cluster.stop();
    -           } catch (Exception e) {
    +                   cluster.awaitTermination();
    +
    +           } catch (Throwable e) {
    --- End diff --
    
    try-catch block is unnecessary


---

Reply via email to