diff --git a/confluent_server/bin/collective b/confluent_server/bin/collective
index 58e5d03a..4ff01615 100644
--- a/confluent_server/bin/collective
+++ b/confluent_server/bin/collective
@@ -3,6 +3,7 @@
 import argparse
 import errno
 import os
+import pwd
 import socket
 import subprocess
 import sys