[FLINK-36406]: Log exceptions in SchemaRegistryRequestHandler#close()

Author: morozov

flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/coordinator/SchemaRegistryRequestHandler.java

@@ -45,7 +45,6 @@
 import org.slf4j.LoggerFactory;
 
 import java.io.Closeable;
-import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -343,16 +342,21 @@ public void getSchemaChangeResult(CompletableFuture<CoordinationResponse> respon
         }
     }
 
+    /**
+     * As at Flink 1.20, the runtime (<code>
+     * DefaultOperatorCoordinatorHandler#disposeAllOperatorCoordinators</code>) will ignore the
+     * exception thrown by this method. Thus, it should report errors by logging them.
+     */
     @Override
-    public void close() throws IOException {
+    public void close() {
         if (schemaChangeThreadPool != null) {
             schemaChangeThreadPool.shutdown();
         }
 
         try {
             metadataApplier.close();
         } catch (Exception e) {
-            throw new IOException("Failed to close metadata applier.", e);
+            LOG.error("Failed to close metadata applier.", e);
         }
     }