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 32400264ae3 HIVE-28153: Flaky test 
TestConflictingDataFiles.testMultiFiltersUpdate (Simhadri Govindappa, reviewed 
by Butao Zhang, Denys Kuzmenko)
32400264ae3 is described below

commit 32400264ae3c0d9859f6644d818b204f6a4e555a
Author: Simhadri Govindappa <[email protected]>
AuthorDate: Sun Apr 14 00:07:38 2024 +0530

    HIVE-28153: Flaky test TestConflictingDataFiles.testMultiFiltersUpdate 
(Simhadri Govindappa, reviewed by Butao Zhang, Denys Kuzmenko)
    
    Closes #5193
---
 .../java/org/apache/iceberg/mr/hive/TestConflictingDataFiles.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/iceberg/iceberg-handler/src/test/java/org/apache/iceberg/mr/hive/TestConflictingDataFiles.java
 
b/iceberg/iceberg-handler/src/test/java/org/apache/iceberg/mr/hive/TestConflictingDataFiles.java
index d89a9099984..1ac1a74eb3f 100644
--- 
a/iceberg/iceberg-handler/src/test/java/org/apache/iceberg/mr/hive/TestConflictingDataFiles.java
+++ 
b/iceberg/iceberg-handler/src/test/java/org/apache/iceberg/mr/hive/TestConflictingDataFiles.java
@@ -24,6 +24,7 @@ import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.Executors;
 import org.apache.hadoop.hive.conf.HiveConf;
+import org.apache.iceberg.FileFormat;
 import org.apache.iceberg.PartitionSpec;
 import org.apache.iceberg.catalog.TableIdentifier;
 import org.apache.iceberg.data.Record;
@@ -33,6 +34,7 @@ import 
org.apache.iceberg.relocated.com.google.common.base.Throwables;
 import org.apache.iceberg.util.Tasks;
 import org.junit.After;
 import org.junit.Assert;
+import org.junit.Assume;
 import org.junit.Before;
 import org.junit.Test;
 
@@ -62,6 +64,12 @@ public class TestConflictingDataFiles extends 
HiveIcebergStorageHandlerWithEngin
     TestUtilPhaser.destroyInstance();
   }
 
+  @Override
+  protected void validateTestParams() {
+    Assume.assumeTrue(fileFormat.equals(FileFormat.PARQUET) && isVectorized &&
+        testTableType.equals(TestTables.TestTableType.HIVE_CATALOG));
+  }
+
   @Test
   public void testSingleFilterUpdate() {
     String[] singleFilterQuery = new String[] { "UPDATE customers SET 
first_name='Changed' WHERE  last_name='Taylor'",

Reply via email to