remove replaceTablePlaceholder.

BruceWong96 · Aug 30, 2024 · f50654f · f50654f
1 parent 9e95dfe
commit f50654f
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/.../src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkFactory.java b/.../src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSinkFactory.java
@@ -28,8 +28,6 @@
 
 import com.google.auto.service.AutoService;
 
-import java.util.Collections;
-
 import static org.apache.seatunnel.connectors.seatunnel.hbase.config.HbaseConfig.ENCODING;
 import static org.apache.seatunnel.connectors.seatunnel.hbase.config.HbaseConfig.FAMILY_NAME;
 import static org.apache.seatunnel.connectors.seatunnel.hbase.config.HbaseConfig.HBASE_EXTRA_CONFIG;
@@ -70,11 +68,6 @@ public OptionRule optionRule() {
 
     @Override
     public TableSink createSink(TableSinkFactoryContext context) {
-        TableSinkFactoryContext.replacePlaceholderAndCreate(
-                context.getCatalogTable(),
-                context.getOptions(),
-                Thread.currentThread().getContextClassLoader(),
-                Collections.emptyList());
         HbaseParameters hbaseParameters = HbaseParameters.buildWithConfig(context.getOptions());
         CatalogTable catalogTable = context.getCatalogTable();
         return () -> new HbaseSink(hbaseParameters, catalogTable);