Merge pull request #22 from thiago/bugfix/auth

add port parameter when authenticate with username and password
gianlucaborello · Aug 4, 2016 · d4ad418 · d4ad418
2 parents 4a64742 + d1230a5
commit d4ad418
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cassandradump.py b/cassandradump.py
@@ -303,7 +303,7 @@ def setup_cluster():
             elif args.protocol_version > 1:
                 auth = PlainTextAuthProvider(username=args.username, password=args.password)
 
-        cluster = Cluster(contact_points=nodes, protocol_version=args.protocol_version, auth_provider=auth, load_balancing_policy=cassandra.policies.WhiteListRoundRobinPolicy(nodes))
+        cluster = Cluster(contact_points=nodes, port=port, protocol_version=args.protocol_version, auth_provider=auth, load_balancing_policy=cassandra.policies.WhiteListRoundRobinPolicy(nodes))
     else:
         cluster = Cluster(contact_points=nodes, port=port, load_balancing_policy=cassandra.policies.WhiteListRoundRobinPolicy(nodes))