Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-12 04:55:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-11345 Adjusted Iceberg test to avoid expensive duplicative runs

Browse Source 
This closes #7086

Signed-off-by: Nandor Soma Abonyi <nsabonyi@apache.org>
This commit is contained in:
exceptionfactory 2023-03-27 11:07:44 -05:00 committed by Nandor Soma Abonyi
parent d2fdff7b93
commit 588e0d74ab
No known key found for this signature in database
GPG Key ID: AFFFD8C3A1A88ED7
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
nifi-nar-bundles/nifi-iceberg-bundle/nifi-iceberg-processors/src/test/java/org/apache/nifi/processors/iceberg/TestPutIcebergWithHiveCatalog.java
View File

@ -129,7 +129,7 @@ public class TestPutIcebergWithHiveCatalog {
@DisabledOnOs(WINDOWS) @DisabledOnOs(WINDOWS)
@ParameterizedTest @ParameterizedTest
@ValueSource(strings = {"avro", "orc", "parquet"}) @ValueSource(strings = {"avro"})
public void onTriggerPartitioned(String fileFormat) throws Exception { public void onTriggerPartitioned(String fileFormat) throws Exception {
PartitionSpec spec = PartitionSpec.builderFor(USER_SCHEMA) PartitionSpec spec = PartitionSpec.builderFor(USER_SCHEMA)
.bucket("department", 3) .bucket("department", 3)
@ -167,7 +167,7 @@ public class TestPutIcebergWithHiveCatalog {
@DisabledOnOs(WINDOWS) @DisabledOnOs(WINDOWS)
@ParameterizedTest @ParameterizedTest
@ValueSource(strings = {"avro", "orc", "parquet"}) @ValueSource(strings = {"orc"})
public void onTriggerIdentityPartitioned(String fileFormat) throws Exception { public void onTriggerIdentityPartitioned(String fileFormat) throws Exception {
PartitionSpec spec = PartitionSpec.builderFor(USER_SCHEMA) PartitionSpec spec = PartitionSpec.builderFor(USER_SCHEMA)
.identity("department") .identity("department")
@ -205,7 +205,7 @@ public class TestPutIcebergWithHiveCatalog {
@DisabledOnOs(WINDOWS) @DisabledOnOs(WINDOWS)
@ParameterizedTest @ParameterizedTest
@ValueSource(strings = {"avro", "orc", "parquet"}) @ValueSource(strings = {"parquet"})
public void onTriggerMultiLevelIdentityPartitioned(String fileFormat) throws Exception { public void onTriggerMultiLevelIdentityPartitioned(String fileFormat) throws Exception {
PartitionSpec spec = PartitionSpec.builderFor(USER_SCHEMA) PartitionSpec spec = PartitionSpec.builderFor(USER_SCHEMA)
.identity("name") .identity("name")
@ -248,7 +248,7 @@ public class TestPutIcebergWithHiveCatalog {
@DisabledOnOs(WINDOWS) @DisabledOnOs(WINDOWS)
@ParameterizedTest @ParameterizedTest
@ValueSource(strings = {"avro", "orc", "parquet"}) @ValueSource(strings = {"avro"})
public void onTriggerUnPartitioned(String fileFormat) throws Exception { public void onTriggerUnPartitioned(String fileFormat) throws Exception {
runner = TestRunners.newTestRunner(processor); runner = TestRunners.newTestRunner(processor);
initRecordReader(); initRecordReader();