diff --git a/nmc_met_io/retrieve_cassandraDB.py b/nmc_met_io/retrieve_cassandraDB.py
index 4362b8d..28915be 100644
--- a/nmc_met_io/retrieve_cassandraDB.py
+++ b/nmc_met_io/retrieve_cassandraDB.py
@@ -1645,7 +1645,8 @@ def get_swan_radar(directory, filename=None, suffix="*.000", scale=[0.1, 0],
             if byteArray == '':
                 print('There is no data ' + filename + ' in ' + directory)
                 return None
-
+            if filename.endswith(('.BZ2','.bz2')):
+                byteArray = bz2.decompress(byteArray)
             # define head structure
             head_dtype = [
                 ('ZonName', 'S12'),