diff --git a/transport/iowrapper.py b/transport/iowrapper.py
index 88224f9..2f80edd 100644
--- a/transport/iowrapper.py
+++ b/transport/iowrapper.py
@@ -283,7 +283,10 @@ class IETL(BaseIO) :
             if hasattr(writer._agent,'_table'):
                 _input['table'] = writer._agent._table
  
-            
+            for _item in _schema :
+                if _item['type'] in ['INTEGER','BIGINT','INT'] :
+                    _column  = _item['name']
+                    _data[_column] = _data[_column].copy().fillna(0).astype(np.int64)
             writer.write(_data,schema=_schema)
         except Exception as e:
             _action = 'post-error'