diff --git a/java/driver/flight-sql/src/main/java/org/apache/arrow/adbc/driver/flightsql/FlightSqlDriver.java b/java/driver/flight-sql/src/main/java/org/apache/arrow/adbc/driver/flightsql/FlightSqlDriver.java index 2f2c42a5f0..d1a1464dd4 100644 --- a/java/driver/flight-sql/src/main/java/org/apache/arrow/adbc/driver/flightsql/FlightSqlDriver.java +++ b/java/driver/flight-sql/src/main/java/org/apache/arrow/adbc/driver/flightsql/FlightSqlDriver.java @@ -39,7 +39,7 @@ public FlightSqlDriver(BufferAllocator allocator) { public AdbcDatabase open(Map parameters) throws AdbcException { String uri = PARAM_URI.get(parameters); if (uri == null) { - Object target = parameters.get("adbc.url"); + Object target = parameters.get(AdbcDriver.PARAM_URL); if (!(target instanceof String)) { throw AdbcException.invalidArgument( "[Flight SQL] Must provide String " + PARAM_URI + " parameter"); @@ -69,7 +69,7 @@ public AdbcDatabase open(Map parameters) throws AdbcException { allocator, location, (SqlQuirks) quirks, - (String) parameters.get("adbc.username"), - (String) parameters.get("adbc.password")); + PARAM_USERNAME.get(parameters), + PARAM_PASSWORD.get(parameters)); } }