diff --git a/src/java/com/cloudera/sqoop/manager/DirectPostgresqlManager.java b/src/java/com/cloudera/sqoop/manager/DirectPostgresqlManager.java index a2fd06fb..6df102f1 100644 --- a/src/java/com/cloudera/sqoop/manager/DirectPostgresqlManager.java +++ b/src/java/com/cloudera/sqoop/manager/DirectPostgresqlManager.java @@ -349,9 +349,12 @@ public void importTable(ImportJobContext context) } } - if (!DirectImportUtils.isLocalhost(hostname) || port != -1) { + if (!DirectImportUtils.isLocalhost(hostname)) { args.add("--host"); args.add(hostname); + } + + if (port != -1) { args.add("--port"); args.add(Integer.toString(port)); }