diff --git a/models/mapping_tables/_eth__decoded_logs.sql b/models/mapping_tables/_eth__decoded_logs.sql
index 6afcf20..f3090d8 100644
--- a/models/mapping_tables/_eth__decoded_logs.sql
+++ b/models/mapping_tables/_eth__decoded_logs.sql
@@ -3,7 +3,23 @@
     grants = {'+select': fromyaml(var('ROLES'))}
 ) }}
 
-SELECT *
+SELECT 
+    BLOCK_NUMBER,
+	BLOCK_TIMESTAMP,
+	TX_HASH,
+	EVENT_INDEX,
+	CONTRACT_ADDRESS,
+	CONTRACT_NAME,
+	EVENT_NAME,
+	DECODED_LOG,
+	FULL_DECODED_LOG,
+	ORIGIN_FUNCTION_SIGNATURE,
+	ORIGIN_FROM_ADDRESS,
+	ORIGIN_TO_ADDRESS,
+	TOPICS,
+	DATA,
+	EVENT_REMOVED,
+	TX_STATUS
 FROM
     {{ source(
         'ethereum_core',
diff --git a/models/mapping_tables/_eth__logs.sql b/models/mapping_tables/_eth__logs.sql
index f430b00..7de3896 100644
--- a/models/mapping_tables/_eth__logs.sql
+++ b/models/mapping_tables/_eth__logs.sql
@@ -3,7 +3,20 @@
     grants = {'+select': fromyaml(var('ROLES'))}
 ) }}
 
-SELECT *
+SELECT 
+    BLOCK_NUMBER,
+    BLOCK_TIMESTAMP,
+    TX_HASH,
+    ORIGIN_FUNCTION_SIGNATURE,
+    ORIGIN_FROM_ADDRESS,
+    ORIGIN_TO_ADDRESS,
+    EVENT_INDEX,
+	CONTRACT_ADDRESS,
+	TOPICS,
+	DATA,
+	EVENT_REMOVED,
+	TX_STATUS,
+	_LOG_ID
 FROM
     {{ source(
         'ethereum_core',