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();
     }
 

Reply via email to