Avoid setting fetch_size for v1 protocol

2014-07-25 12:14:08 -05:00
parent bcde7c1553
commit 0fc4dd3c7d
1 changed files with 1 additions and 1 deletions
--- a/cassandra/cluster.py
+++ b/cassandra/cluster.py
@@ -1324,7 +1324,7 @@ class Session(object):
        fetch_size = query.fetch_size
        if fetch_size is FETCH_SIZE_UNSET and self._protocol_version >= 2:
            fetch_size = self.default_fetch_size
-        else:
+        elif self._protocol_version == 1:
            fetch_size = None

        if self._protocol_version >= 3 and self.use_client_timestamp: