This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new d8e9244a2b fix typesense add missing import for
MULTI_TABLE_SINK_REPLICA to pass… (#10898)
d8e9244a2b is described below
commit d8e9244a2b5fa5467c457ff7f7a9612d811cb9f9
Author: zhiwei.niu <[email protected]>
AuthorDate: Mon May 18 20:31:05 2026 +0800
fix typesense add missing import for MULTI_TABLE_SINK_REPLICA to pass…
(#10898)
---
.../connectors/seatunnel/typesense/sink/TypesenseSinkFactory.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/sink/TypesenseSinkFactory.java
b/seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/sink/TypesenseSinkFactory.java
index e6114b10da..395450ff2c 100644
---
a/seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/sink/TypesenseSinkFactory.java
+++
b/seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/sink/TypesenseSinkFactory.java
@@ -19,6 +19,7 @@ package
org.apache.seatunnel.connectors.seatunnel.typesense.sink;
import org.apache.seatunnel.api.configuration.ReadonlyConfig;
import org.apache.seatunnel.api.configuration.util.OptionRule;
+import org.apache.seatunnel.api.options.SinkConnectorCommonOptions;
import org.apache.seatunnel.api.table.catalog.CatalogTable;
import org.apache.seatunnel.api.table.catalog.TableIdentifier;
import org.apache.seatunnel.api.table.connector.TableSink;
@@ -50,6 +51,7 @@ public class TypesenseSinkFactory implements TableSinkFactory
{
.optional(TypesenseSinkOptions.KEY_DELIMITER)
.optional(TypesenseSinkOptions.MAX_BATCH_SIZE)
.optional(TypesenseSinkOptions.MAX_RETRY_COUNT)
+ .optional(SinkConnectorCommonOptions.MULTI_TABLE_SINK_REPLICA)
.build();
}