This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e0c2676 [FLINK-24481][docs] Translate buffer debloat documenation to
chinese
add 11f74d8 [FLINK-25173][table][hive] Introduce CatalogLock and
implement HiveCatalogLock
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HiveDynamicTableFactory.java | 41 ++++--
.../flink/table/catalog/hive/HiveCatalogLock.java | 161 +++++++++++++++++++++
.../flink/table/catalog/hive/HiveConfOptions.java | 47 ++++++
.../hive/client/HiveMetastoreClientWrapper.java | 20 +++
.../flink/connectors/hive/HiveRunnerITCase.java | 35 ++++-
.../hive/factories/TestLockTableSinkFactory.java | 147 +++++++++++++++++++
.../org.apache.flink.table.factories.Factory | 2 +-
.../apache/flink/table/catalog/CatalogLock.java | 20 +--
.../flink/table/connector/RequireCatalogLock.java | 10 +-
9 files changed, 447 insertions(+), 36 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalogLock.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveConfOptions.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/factories/TestLockTableSinkFactory.java
copy flink-connectors/{flink-connector-hbase-1.4/src/main =>
flink-connector-hive/src/test}/resources/META-INF/services/org.apache.flink.table.factories.Factory
(91%)
copy
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/compact/CompactReader.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogLock.java
(63%)
copy
flink-core/src/main/java/org/apache/flink/api/common/operators/IterationOperator.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/RequireCatalogLock.java
(72%)
