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'",