diff --git a/airbyte-integrations/connectors/destination-postgres/src/main/java/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java b/airbyte-integrations/connectors/destination-postgres/src/main/java/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java
index 8a6bd4ac4f56..eab5edb5a1c6 100644
--- a/airbyte-integrations/connectors/destination-postgres/src/main/java/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java
+++ b/airbyte-integrations/connectors/destination-postgres/src/main/java/io/airbyte/integrations/destination/postgres/typing_deduping/PostgresSqlGenerator.java
@@ -9,7 +9,6 @@
 import static io.airbyte.cdk.integrations.base.JavaBaseConstants.COLUMN_NAME_AB_META;
 import static io.airbyte.cdk.integrations.base.JavaBaseConstants.COLUMN_NAME_AB_RAW_ID;
 import static io.airbyte.cdk.integrations.base.JavaBaseConstants.COLUMN_NAME_DATA;
-import static java.util.Collections.emptyList;
 import static org.jooq.impl.DSL.array;
 import static org.jooq.impl.DSL.case_;
 import static org.jooq.impl.DSL.cast;
@@ -137,21 +136,6 @@ public Sql createTable(final StreamConfig stream, final String suffix, final boo
     return Sql.concat(statements);
   }
 
-  @Override
-  protected List<String> createIndexSql(final StreamConfig stream, final String suffix) {
-    if (stream.destinationSyncMode() == DestinationSyncMode.APPEND_DEDUP && !stream.primaryKey().isEmpty()) {
-      return List.of(
-          getDslContext().createIndex().on(
-              name(stream.id().finalNamespace(), stream.id().finalName() + suffix),
-              stream.primaryKey().stream()
-                  .map(pk -> quotedName(pk.name()))
-                  .toList())
-              .getSQL());
-    } else {
-      return emptyList();
-    }
-  }
-
   @Override
   protected List<Field<?>> extractRawDataFields(final LinkedHashMap<ColumnId, AirbyteType> columns, final boolean useExpensiveSaferCasting) {
     return columns