chore: clean up lint issues

Author: karel-rehor

src/main/java/com/influxdb/v3/client/internal/FlightSqlClient.java

@@ -74,8 +74,8 @@
 final class FlightSqlClient implements AutoCloseable {
 
     private static final Logger LOG = LoggerFactory.getLogger(FlightSqlClient.class);
-    private static int AUTOCLOSEABLE_CHECK_LIMIT = 10;
-    private static Map<AutoCloseable, Boolean> CLOSEABLE_CLOSED_LEDGER = new ConcurrentHashMap<>();
+    private static final int AUTOCLOSEABLE_CHECK_LIMIT = 10;
+    private static final Map<AutoCloseable, Boolean> CLOSEABLE_CLOSED_LEDGER = new ConcurrentHashMap<>();
 
     private final FlightClient client;
 
@@ -144,16 +144,16 @@ Stream<VectorSchemaRoot> execute(@Nonnull final String query,
         return StreamSupport.stream(spliterator, false).onClose(iterator::close);
     }
 
-    private void addToAutoCloseable(AutoCloseable closeable) {
+    private void addToAutoCloseable(@Nonnull final AutoCloseable closeable) {
         // need to occasionally clean up references to closed streams
         // in order to ensure memory can get freed.
-        if(autoCloseables.size() > AUTOCLOSEABLE_CHECK_LIMIT) {
+        if (autoCloseables.size() > AUTOCLOSEABLE_CHECK_LIMIT) {
             LOG.info("checking to cleanup stale flight streams from {} known streams", autoCloseables.size());
 
             ListIterator<AutoCloseable> iter = autoCloseables.listIterator();
-            while(iter.hasNext()){
+            while (iter.hasNext()) {
                 AutoCloseable autoCloseable = iter.next();
-                if(CLOSEABLE_CLOSED_LEDGER.get(autoCloseable)){
+                if (CLOSEABLE_CLOSED_LEDGER.get(autoCloseable)) {
                     LOG.info("removing closed stream {}", autoCloseable);
                     CLOSEABLE_CLOSED_LEDGER.keySet().remove(autoCloseable);
                     iter.remove();

src/test/java/com/influxdb/v3/client/integration/E2ETest.java

@@ -471,7 +471,7 @@ public void testMultipleQueries() throws Exception {
             String query = "SELECT * FROM " + measurement;
 
             // TODO just checking FlightStream cleanup should be test in FlightSqlClient
-            for(int i = 0; i < 20; i++) {
+            for (int i = 0; i < 20; i++) {
                 try (Stream<PointValues> stream = client.queryPoints(query)) {
                     stream.forEach(pointValues -> {
                         Assertions.assertThat(pointValues.getField("life")).isEqualTo(42L);