wip

Author: NguyenHoangSon96

src/test/java/com/influxdb/v3/client/ITQueryWrite.java

@@ -425,7 +425,7 @@ public void queryTimeoutSuperceededByGrpcOptTest() throws URISyntaxException, SS
 
         QueryOptions queryOptions = QueryOptions.defaultQueryOptions();
         queryOptions.setGrpcCallOptions(new GrpcCallOptions.Builder()
-            .withDeadline(Deadline.after(3000, TimeUnit.SECONDS))
+                .withDeadline(Deadline.after(900, TimeUnit.MILLISECONDS))
             .build()
         );
 

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

@@ -89,7 +89,8 @@ void testQueryWithProxy() throws URISyntaxException, SSLException {
         NettyHttpClientConfig nettyHttpClientConfig = new NettyHttpClientConfig();
 
         // Set proxy for write api
-        Supplier<HttpProxyHandler> writeApiProxy = () -> new HttpProxyHandler(new InetSocketAddress("localhost", 10000));
+        Supplier<HttpProxyHandler> writeApiProxy = () ->
+                new HttpProxyHandler(new InetSocketAddress("localhost", 10000), username, password);
         nettyHttpClientConfig.configureChannelProxy(writeApiProxy);
 
         // Set proxy for query api
@@ -251,16 +252,11 @@ public void testQueryRows() throws Exception {
                 testDatas.add(map);
             }
 
-            //fixme Sleep 1s to make sure all data have completely written
-            //fixme check if this because netty still running as NIO
-//            Thread.sleep(1000);
-
             Map<String, Object> parameters = Map.of("testId", uuid);
             // Result set much be ordered by time
             String sql = String.format("Select * from %s where \"testId\"=$testId order by time", measurement);
             try (Stream<Map<String, Object>> stream = client.queryRows(sql, parameters)) {
                 List<Map<String, Object>> results = stream.collect(Collectors.toList());
-                System.out.println("Result Size: " + results.size());
                 for (int i = 0; i <= 9; i++) {
                     Map<String, Object> row = results.get(i);
                     Map<String, Object> testData = testDatas.get(i);
@@ -334,10 +330,6 @@ public void testQueryRowWithOptions() throws Exception {
                 testDatas.add(map);
             }
 
-            //fixme Sleep 1s to make sure all data have completely written
-            //fixme check if this because netty still running as NIO
-//            Thread.sleep(1000);
-
             // Result set much be ordered by time
             String sql = String.format("Select * from %s where \"testId\"='%s' order by time", measurement, uuid);
             try (Stream<Map<String, Object>> stream = client.queryRows(sql, QueryOptions.defaultQueryOptions())) {