You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2019/07/11 14:24:57 UTC
[flink] branch master updated: [hotfix][FLINK-12348][table-api]
Remove setConf(String, String) method in TableConfig
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new f19cb14 [hotfix][FLINK-12348][table-api] Remove setConf(String, String) method in TableConfig
f19cb14 is described below
commit f19cb148f5fa94e7640dfe1b96d665be95a2de58
Author: Jark Wu <im...@gmail.com>
AuthorDate: Thu Jul 11 16:25:42 2019 +0800
[hotfix][FLINK-12348][table-api] Remove setConf(String, String) method in TableConfig
---
flink-python/pyflink/table/table_config.py | 9 ---------
.../src/main/java/org/apache/flink/table/api/TableConfig.java | 10 ----------
2 files changed, 19 deletions(-)
diff --git a/flink-python/pyflink/table/table_config.py b/flink-python/pyflink/table/table_config.py
index 73b4e97..62b00ba 100644
--- a/flink-python/pyflink/table/table_config.py
+++ b/flink-python/pyflink/table/table_config.py
@@ -38,15 +38,6 @@ class TableConfig(object):
else:
self._j_table_config = j_table_config
- def set_conf(self, key, value):
- """
- Adds the given key/value pair.
-
- :param key: the key of the key/value pair to be added.
- :param value: the value of the key/value pair to be added.
- """
- self._j_table_config.setConf(key, value)
-
def get_local_timezone(self):
"""
Returns the local timezone id for timestamp with local time zone, either an abbreviation
diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java
index 7633495..be7a3f6 100644
--- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java
+++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java
@@ -94,16 +94,6 @@ public class TableConfig {
}
/**
- * Adds the given key/value pair.
- *
- * @param key the key of the key/value pair to be added
- * @param value the value of the key/value pair to be added
- */
- public void setConf(String key, String value) {
- configuration.setString(key, value);
- }
-
- /**
* Returns the zone id for timestamp with local time zone.
*/
public ZoneId getLocalTimeZone() {