[FLINK-11516][table-common] Port and move catalog transitive classes to flink-table-common
This closes #7642.
diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java
index 63e9b34..f52de79 100644
--- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java
+++ b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java
@@ -113,7 +113,7 @@
final List<String> properties = new ArrayList<>();
// streaming properties
- properties.add(UPDATE_MODE());
+ properties.add(UPDATE_MODE);
// Elasticsearch
properties.add(CONNECTOR_HOSTS + ".#." + CONNECTOR_HOSTS_HOSTNAME);
@@ -150,7 +150,7 @@
final DescriptorProperties descriptorProperties = getValidatedProperties(properties);
return createElasticsearchUpsertTableSink(
- descriptorProperties.isValue(UPDATE_MODE(), UPDATE_MODE_VALUE_APPEND()),
+ descriptorProperties.isValue(UPDATE_MODE, UPDATE_MODE_VALUE_APPEND),
descriptorProperties.getTableSchema(SCHEMA()),
getHosts(descriptorProperties),
descriptorProperties.getString(CONNECTOR_INDEX),
