diff --git a/flow/connectors/postgres/qrep.go b/flow/connectors/postgres/qrep.go
index df82fb5bf4..041c3ceb6c 100644
--- a/flow/connectors/postgres/qrep.go
+++ b/flow/connectors/postgres/qrep.go
@@ -497,15 +497,6 @@ func (c *PostgresConnector) SetupQRepMetadataTables(ctx context.Context, config
 	}
 	c.logger.Info("Setup metadata table.")
 
-	if config.WriteMode != nil &&
-		config.WriteMode.WriteType == protos.QRepWriteType_QREP_WRITE_MODE_OVERWRITE {
-		_, err = c.conn.Exec(ctx,
-			"TRUNCATE TABLE "+config.DestinationTableIdentifier)
-		if err != nil {
-			return fmt.Errorf("failed to TRUNCATE table before query replication: %w", err)
-		}
-	}
-
 	return nil
 }
 
diff --git a/ui/app/mirrors/create/handlers.ts b/ui/app/mirrors/create/handlers.ts
index 450a5ad98d..01c8a11b8f 100644
--- a/ui/app/mirrors/create/handlers.ts
+++ b/ui/app/mirrors/create/handlers.ts
@@ -205,6 +205,7 @@ export const handleCreateQRep = async (
   }
 
   if (config.sourcePeer?.snowflakeConfig) {
+    config.query = 'SELECT * FROM ' + config.watermarkTable;
     if (config.watermarkTable == '') {
       notify('Please fill in the source table');
       return;
diff --git a/ui/app/mirrors/create/qrep/snowflakeQrep.tsx b/ui/app/mirrors/create/qrep/snowflakeQrep.tsx
index daf812c2a6..1a83420eb9 100644
--- a/ui/app/mirrors/create/qrep/snowflakeQrep.tsx
+++ b/ui/app/mirrors/create/qrep/snowflakeQrep.tsx
@@ -13,7 +13,6 @@ import { MirrorSetter } from '../../types';
 import { fetchAllTables } from '../handlers';
 import { MirrorSetting, blankSnowflakeQRepSetting } from '../helpers/common';
 import { snowflakeQRepSettings } from '../helpers/qrep';
-import QRepQuery from './query';
 
 interface SnowflakeQRepProps {
   mirrorConfig: QRepConfig;
@@ -82,20 +81,6 @@ export default function SnowflakeQRepForm({
   }, [setter]);
   return (
     <>
-      <Label>
-        Snowflake to PostgreSQL Query Replication currently only supports
-        full-table streaming replication with overwrite mode. More features
-        coming soon!
-      </Label>
-      <QRepQuery
-        query={mirrorConfig.query}
-        setter={(val: string) => {
-          setter((curr) => ({
-            ...curr,
-            query: val,
-          }));
-        }}
-      />
       {mirrorConfig.sourcePeer?.name ? (
         snowflakeQRepSettings.map((setting, id) => {
           return (