Skip to content

Commit 45a4e15

Browse files
authored
[Fix][KuduCatalogFactory]: Fix KuduCatalogFactory.optionRule() will throw an Exception (#6787)
* fix(KuduCatalogFactory): Fix KuduCatalogFactory.optionRule() will throw an Exception Fix `KuduCatalogFactory.optionRule()` will throw an Exception because conditional OptionRule should be in the optinal or required options. * [Feat][KuduFactoryTest]: Add a Test On KuduFactory 1. Add a Test On KuduFactory
1 parent 4d9287f commit 45a4e15

File tree

2 files changed

+3
-0
lines changed

2 files changed

+3
-0
lines changed

seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/catalog/KuduCatalogFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ public OptionRule optionRule() {
6060
.optional(OPERATION_TIMEOUT)
6161
.optional(ADMIN_OPERATION_TIMEOUT)
6262
.optional(KERBEROS_KRB5_CONF)
63+
.optional(ENABLE_KERBEROS)
6364
.conditional(ENABLE_KERBEROS, true, KERBEROS_PRINCIPAL, KERBEROS_KEYTAB)
6465
.build();
6566
}

seatunnel-connectors-v2/connector-kudu/src/test/java/org/apache/seatunnel/connectors/seatunnel/kudu/KuduFactoryTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.seatunnel.connectors.seatunnel.kudu;
1919

20+
import org.apache.seatunnel.connectors.seatunnel.kudu.catalog.KuduCatalogFactory;
2021
import org.apache.seatunnel.connectors.seatunnel.kudu.sink.KuduSinkFactory;
2122
import org.apache.seatunnel.connectors.seatunnel.kudu.source.KuduSourceFactory;
2223

@@ -29,5 +30,6 @@ class KuduFactoryTest {
2930
void optionRule() {
3031
Assertions.assertNotNull((new KuduSourceFactory()).optionRule());
3132
Assertions.assertNotNull((new KuduSinkFactory()).optionRule());
33+
Assertions.assertNotNull((new KuduCatalogFactory()).optionRule());
3234
}
3335
}

0 commit comments

Comments
 (0)