diff --git a/public/components/datasources/components/manage/data_connection.tsx b/public/components/datasources/components/manage/data_connection.tsx
index f646ea22c..a57c58840 100644
--- a/public/components/datasources/components/manage/data_connection.tsx
+++ b/public/components/datasources/components/manage/data_connection.tsx
@@ -91,7 +91,7 @@ export const DataConnection = (props: { dataSource: string }) => {
 
   useEffect(() => {
     const searchDataSourcePattern = new RegExp(
-      `flint_${_.escapeRegExp(datasourceDetails.name)}_default_.*_mview`
+      `flint_${_.escapeRegExp(datasourceDetails.name)}_default_.*`
     );
     const findIntegrations = async () => {
       // TODO: we just get all results and filter, ideally we send a filtering query to the API
diff --git a/public/components/integrations/components/setup_integration.tsx b/public/components/integrations/components/setup_integration.tsx
index 948ed8440..973267946 100644
--- a/public/components/integrations/components/setup_integration.tsx
+++ b/public/components/integrations/components/setup_integration.tsx
@@ -514,7 +514,7 @@ const addIntegration = async ({
       integration,
       setCalloutLikeToast,
       config.displayName,
-      `flint_${config.connectionDataSource}_default_${config.connectionTableName}_mview`,
+      `flint_${config.connectionDataSource}_default_${config.connectionTableName}__*`,
       config.enabledWorkflows,
       setIsInstalling ? true : false
     );
diff --git a/server/adaptors/integrations/__data__/repository/apache/assets/create_mv-1.0.0.sql b/server/adaptors/integrations/__data__/repository/apache/assets/create_mv-1.0.0.sql
index 9dbe0581a..3a7c04817 100644
--- a/server/adaptors/integrations/__data__/repository/apache/assets/create_mv-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/apache/assets/create_mv-1.0.0.sql
@@ -1,4 +1,4 @@
-CREATE MATERIALIZED VIEW {table_name}_mview AS
+CREATE MATERIALIZED VIEW {table_name}__mview AS
 SELECT
     to_timestamp(trim(BOTH '[]' FROM concat(time_local_1, ' ', time_local_2)), 'dd/MMM/yyyy:HH:mm:ss Z') AS `@timestamp`,
     split_part (request, ' ', 1) as `http.request.method`,
diff --git a/server/adaptors/integrations/__data__/repository/aws_elb/assets/create_mv-1.0.0.sql b/server/adaptors/integrations/__data__/repository/aws_elb/assets/create_mv-1.0.0.sql
index 6f134cd6a..5d96c77c0 100644
--- a/server/adaptors/integrations/__data__/repository/aws_elb/assets/create_mv-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/aws_elb/assets/create_mv-1.0.0.sql
@@ -1,4 +1,4 @@
-CREATE MATERIALIZED VIEW {table_name}_mview AS
+CREATE MATERIALIZED VIEW {table_name}__mview AS
 SELECT
     type as `aws.elb.elb_type`,
     time as `@timestamp`,
diff --git a/server/adaptors/integrations/__data__/repository/aws_s3/assets/create_mv-1.0.0.sql b/server/adaptors/integrations/__data__/repository/aws_s3/assets/create_mv-1.0.0.sql
index 31c750e51..52e9441fe 100644
--- a/server/adaptors/integrations/__data__/repository/aws_s3/assets/create_mv-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/aws_s3/assets/create_mv-1.0.0.sql
@@ -1,4 +1,4 @@
-CREATE MATERIALIZED VIEW {table_name}_mview AS
+CREATE MATERIALIZED VIEW {table_name}__mview AS
 SELECT
   owner_id AS `aws.s3.bucket_owner`,
   bucket_name AS `aws.s3.bucket`,
diff --git a/server/adaptors/integrations/__data__/repository/aws_waf/assets/create_mv-1.0.0.sql b/server/adaptors/integrations/__data__/repository/aws_waf/assets/create_mv-1.0.0.sql
index 3592dafed..9a2560dfc 100644
--- a/server/adaptors/integrations/__data__/repository/aws_waf/assets/create_mv-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/aws_waf/assets/create_mv-1.0.0.sql
@@ -1,4 +1,4 @@
-CREATE MATERIALIZED VIEW {table_name}_mview AS
+CREATE MATERIALIZED VIEW {table_name}__mview AS
 SELECT
     CAST(FROM_UNIXTIME(`timestamp`/ 1000) AS TIMESTAMP) AS `@timestamp`,
     formatVersion AS `aws.waf.formatVersion`,
diff --git a/server/adaptors/integrations/__data__/repository/haproxy/assets/create_mv-1.0.0.sql b/server/adaptors/integrations/__data__/repository/haproxy/assets/create_mv-1.0.0.sql
index 5e2ce8047..0bc493490 100644
--- a/server/adaptors/integrations/__data__/repository/haproxy/assets/create_mv-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/haproxy/assets/create_mv-1.0.0.sql
@@ -1,4 +1,4 @@
-CREATE MATERIALIZED VIEW {table_name}_mview AS
+CREATE MATERIALIZED VIEW {table_name}__mview AS
 SELECT
     regexp_extract(
         record,
diff --git a/server/adaptors/integrations/__data__/repository/nginx/assets/create_mv-1.0.0.sql b/server/adaptors/integrations/__data__/repository/nginx/assets/create_mv-1.0.0.sql
index 6312641b1..25e4d153a 100644
--- a/server/adaptors/integrations/__data__/repository/nginx/assets/create_mv-1.0.0.sql
+++ b/server/adaptors/integrations/__data__/repository/nginx/assets/create_mv-1.0.0.sql
@@ -1,4 +1,4 @@
-CREATE MATERIALIZED VIEW {table_name}_mview AS
+CREATE MATERIALIZED VIEW {table_name}__mview AS
 SELECT
     to_timestamp(trim(BOTH '[]' FROM concat(time_local_1, ' ', time_local_2)), 'dd/MMM/yyyy:HH:mm:ss Z') AS `@timestamp`,
     split_part (request, ' ', 1) as `http.request.method`,