diff --git a/fix_system_distributed_tables.py b/fix_system_distributed_tables.py
index 0ca1f9ac15..f0bf86aa0e 100755
--- a/fix_system_distributed_tables.py
+++ b/fix_system_distributed_tables.py
@@ -43,7 +43,9 @@ sessions_cols = {
     'duration'      : 'int',
     'parameters'    : 'map<text, text>',
     'request'       : 'text',
-    'started_at'    : 'timestamp'
+    'started_at'    : 'timestamp',
+    'request_size'  : 'int',
+    'response_size' : 'int'
 }
 
 slow_query_log_cols = {