[FLINK-19706][table-runtime] Add WARN logs when hive table partition …

…has existed before commit This closes apache#13716
is · Oct 23, 2020 · 7b04b29 · 7b04b29
1 parent ae4080c
commit 7b04b29
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...-runtime-blink/src/main/java/org/apache/flink/table/filesystem/MetastoreCommitPolicy.java b/...-runtime-blink/src/main/java/org/apache/flink/table/filesystem/MetastoreCommitPolicy.java
@@ -44,6 +44,10 @@ public void setMetastore(TableMetaStore metaStore) {
  @Override
  public void commit(Context context) throws Exception {
  LinkedHashMap<String, String> partitionSpec = context.partitionSpec();
+ metaStore.getPartition(partitionSpec).ifPresent(path ->
+ LOG.warn("The partition {} has existed before current commit," +
+ " the path is {}, this partition will be altered instead of being created",
+ partitionSpec, path));
  metaStore.createOrAlterPartition(partitionSpec, context.partitionPath());
  LOG.info("Committed partition {} to metastore", partitionSpec);
  }