diff --git a/airflow/contrib/hooks/sqoop_hook.py b/airflow/contrib/hooks/sqoop_hook.py
index e8e2feb3e62e83..ea9ad430129906 100644
--- a/airflow/contrib/hooks/sqoop_hook.py
+++ b/airflow/contrib/hooks/sqoop_hook.py
@@ -147,11 +147,12 @@ def _prepare_command(self, export=False):
         if self.hcatalog_table:
             connection_cmd += ["--hcatalog-table", self.hcatalog_table]
 
-        connection_cmd += ["--connect", "{}:{}/{}".format(
-            self.conn.host,
-            self.conn.port,
-            self.conn.schema
-        )]
+        connect_str = self.conn.host
+        if self.conn.port:
+            connect_str += ":{}".format(self.conn.port)
+        if self.conn.schema:
+            connect_str += "/{}".format(self.conn.schema)
+        connection_cmd += ["--connect", connect_str]
 
         return connection_cmd