It hangs when attempting to execute an SQL update using the Arrow Flight SQL client

Dremio Cloud
1

Hi,

I created a simple program to test insert query to dremio cloud. But it hangs when attempting to execute an SQL update using the Arrow Flight SQL client. Please advise!

I am using data.dremio.cloud with 443 port.

private static void runFlightCallDirectInsert(Location location,
BufferAllocator allocator,
String token) throws Exception {
try (FlightClient client = FlightClient.builder(allocator, location)
.build();
FlightSqlClient sqlClientA = new FlightSqlClient(client):wink: {
CredentialCallOption credentialCallOption = new CredentialCallOption((callHeaders) → {
callHeaders.insert(“authorization”, "Bearer " + token);
});
int newid = Long.valueOf(Instant.now().getEpochSecond()).intValue();
String insertSqlQuery = String.format(
“INSERT INTO "test-cat-1"."my_folder".people3 (id, name, age) values (%d, ‘%s’, %d)”,
newid, “name_” + newid, 5);

        long insertedCount =
                sqlClientA.executeUpdate(insertSqlQuery, credentialCallOption);

        String querySql = "SELECT * FROM \"test-cat-1\".\"my_folder\".people2 WHERE id >= " + newid;
        FlightInfo flightInfo = sqlClientA.execute(querySql, credentialCallOption);
        System.out.println("printing results within the transaction client A");
        printFlightInfoResults(flightInfo, sqlClientA);

    } catch (Exception ex) {
        ex.printStackTrace();
    }
}