Adding default to Neptune port (8182)

awslabs · Jan 11, 2024 · 01d7997 · 01d7997
1 parent da3f8c4
commit 01d7997
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...a-neptune/src/main/java/com/amazonaws/athena/connectors/neptune/NeptuneRecordHandler.java b/...a-neptune/src/main/java/com/amazonaws/athena/connectors/neptune/NeptuneRecordHandler.java
@@ -74,12 +74,12 @@ private static NeptuneConnection createConnection(java.util.Map<String, String>
         switch(graphType){
             case PROPERTYGRAPH: 
                 return new NeptuneGremlinConnection(configOptions.get(Constants.CFG_ENDPOINT),
-                configOptions.get(Constants.CFG_PORT), Boolean.parseBoolean(configOptions.getOrDefault(Constants.CFG_IAM, "false")),
+                configOptions.getOrDefault(Constants.CFG_PORT, "8182"), Boolean.parseBoolean(configOptions.getOrDefault(Constants.CFG_IAM, "false")),
                 configOptions.get(Constants.CFG_REGION));
 
             case RDF:
                 return new NeptuneSparqlConnection(configOptions.get(Constants.CFG_ENDPOINT),
-                        configOptions.get(Constants.CFG_PORT), Boolean.parseBoolean(configOptions.getOrDefault(Constants.CFG_IAM, "false")),
+                        configOptions.getOrDefault(Constants.CFG_PORT, "8182"), Boolean.parseBoolean(configOptions.getOrDefault(Constants.CFG_IAM, "false")),
                         configOptions.get(Constants.CFG_REGION));
         }
         return null;