(hive) branch master updated: HIVE-27850: Iceberg: Addendum: Use fully qualified table name in compaction query (Dmitriy Fingerman, reviewed by Denys Kuzmenko)

[dkuzmenko]

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

dkuzmenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git


The following commit(s) were added to refs/heads/master by this push:
     new 32a79270c33 HIVE-27850: Iceberg: Addendum: Use fully qualified table 
name in compaction query (Dmitriy Fingerman, reviewed by Denys Kuzmenko)
32a79270c33 is described below

commit 32a79270c33e151826b43eec0daa985b159fc568
Author: Dmitriy Fingerman <dmitriy.finger...@gmail.com>
AuthorDate: Fri Feb 9 08:28:49 2024 -0500

    HIVE-27850: Iceberg: Addendum: Use fully qualified table name in compaction 
query (Dmitriy Fingerman, reviewed by Denys Kuzmenko)
    
    Closes #5074
---
 .../iceberg/mr/hive/compaction/IcebergMajorQueryCompactor.java     | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergMajorQueryCompactor.java
 
b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergMajorQueryCompactor.java
index 96141e50494..e3dba519dc9 100644
--- 
a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergMajorQueryCompactor.java
+++ 
b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/compaction/IcebergMajorQueryCompactor.java
@@ -29,6 +29,7 @@ import org.apache.hadoop.hive.ql.metadata.HiveException;
 import org.apache.hadoop.hive.ql.session.SessionState;
 import org.apache.hadoop.hive.ql.txn.compactor.CompactorContext;
 import org.apache.hadoop.hive.ql.txn.compactor.QueryCompactor;
+import org.apache.hive.iceberg.org.apache.orc.storage.common.TableName;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -39,12 +40,12 @@ public class IcebergMajorQueryCompactor extends 
QueryCompactor  {
   @Override
   public boolean run(CompactorContext context) throws IOException, 
HiveException, InterruptedException {
 
-    String compactTableName = context.getTable().getTableName();
+    String compactTableName = 
TableName.getDbTable(context.getTable().getDbName(), 
context.getTable().getTableName());
     Map<String, String> tblProperties = context.getTable().getParameters();
     LOG.debug("Initiating compaction for the {} table", compactTableName);
 
-    String compactionQuery = String.format("insert overwrite table %s select * 
from %s",
-        compactTableName, compactTableName);
+    String compactionQuery = String.format("insert overwrite table %s select * 
from %<s",
+        compactTableName);
 
     SessionState sessionState = setupQueryCompactionSession(context.getConf(),
         context.getCompactionInfo(), tblProperties);