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

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);
  }
  }