(flink) 01/03: [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all flink configurations copy in the form of map.

[guoweijie]

This is an automated email from the ASF dual-hosted git repository.

guoweijie pushed a commit to branch FLINK-31223-rest-ssl-fix
in repository https://gitbox.apache.org/repos/asf/flink.git

commit d3123fd43c6c97d6061cb4f9fc38be452d5e7f8f
Author: Weijie Guo <res...@163.com>
AuthorDate: Sun Feb 26 22:23:45 2023 +0800

    [FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to get all 
flink configurations copy in the form of map.
---
 .../table/gateway/api/endpoint/SqlGatewayEndpointFactory.java     | 8 ++++++++
 .../gateway/api/endpoint/SqlGatewayEndpointFactoryUtils.java      | 5 +++++
 2 files changed, 13 insertions(+)

diff --git 
a/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactory.java
 
b/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactory.java
index 03d7c1e44dd..e48fe153451 100644
--- 
a/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactory.java
+++ 
b/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactory.java
@@ -50,6 +50,14 @@ public interface SqlGatewayEndpointFactory extends Factory {
         /** Gives read-only access to the configuration of the current 
session. */
         ReadableConfig getFlinkConfiguration();
 
+        /**
+         * Get a map contains all flink configurations.
+         *
+         * @return The copy of flink configurations in the form of map, modify 
this map will not
+         *     influence the original configuration object.
+         */
+        Map<String, String> getFlinkConfigurationOptions();
+
         /**
          * Returns the options with which the endpoint is created. All options 
that are prefixed
          * with the endpoint identifier are included in the map.
diff --git 
a/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactoryUtils.java
 
b/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactoryUtils.java
index 7ba59f609e0..3063cf89b3c 100644
--- 
a/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactoryUtils.java
+++ 
b/flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/endpoint/SqlGatewayEndpointFactoryUtils.java
@@ -141,6 +141,11 @@ public class SqlGatewayEndpointFactoryUtils {
             return flinkConfiguration;
         }
 
+        @Override
+        public Map<String, String> getFlinkConfigurationOptions() {
+            return flinkConfiguration.toMap();
+        }
+
         @Override
         public Map<String, String> getEndpointOptions() {
             return endpointConfig;