add port parameter when authenticate with username and password

gianlucaborello · Aug 4, 2016 · d1230a5 · d1230a5
1 parent f43e736
commit d1230a5
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))