We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 46765ef commit 3fa1a07Copy full SHA for 3fa1a07
1 file changed
core/src/main/java/io/questdb/client/cutlass/qwp/client/QwpWebSocketSender.java
@@ -1344,10 +1344,10 @@ private boolean shouldAutoFlush() {
1344
if (autoFlushBytes > 0 && getPendingBytes() >= autoFlushBytes) {
1345
return true;
1346
}
1347
-// if (autoFlushIntervalNanos > 0) {
1348
-// long ageNanos = System.nanoTime() - firstPendingRowTimeNanos;
1349
-// return ageNanos >= autoFlushIntervalNanos;
1350
-// }
+ if (autoFlushIntervalNanos > 0) {
+ long ageNanos = System.nanoTime() - firstPendingRowTimeNanos;
+ return ageNanos >= autoFlushIntervalNanos;
+ }
1351
return false;
1352
1353
0 commit comments