DatabaseClient fetch all rows never completes #592
Labels
for: external-project
For an external project and not something we can fix
Comments
spring-projects-issues
added
the
status: waiting-for-triage
|
Does the same happen when using R2DBC SPI directly? That is something like: Flux.usingWhen(connectionFactory.create(),
connection -> {
return Flux.from(connection.createStatement("select userId, attr1, attr2, attr3, " +
"attr4, attr5 from test_r2dbc.users limit 1200")
.execute()).flatMap(result -> result.map(…));
}, Connection::close); |
mp911de
added
the
status: waiting-for-feedback
|
@mp911de The same thing happens with the above code. By changing it to the following, the issue does not appear but a memory leak is occurred as described here pgjdbc/r2dbc-postgresql#396 (comment). I have run many tests with the Spring Data and the memory leak does not happen. return Flux.usingWhen(
conFactory.create(),
conn -> Mono.from(conn.createStatement(config.getQuery()).execute())
.flatMapMany(result -> result.map(this::toProfile)),
Connection::close); |
|
Thanks a lot. In that case, I'm closing this issue here as the problem originates in the driver. |
mp911de
added
for: external-project
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
I'am using Spring Data R2DBC with PostgreSQL R2DBC driver. I have created the following method that fetches some rows from database and returns a
Fluxof objects. When the number of rows returned by the query are e.g. 1200 or 15.000.000,Fluxnever emits theonCompletesignal. Here's a sample code:When adding a
.log()call to the chain I see 256request(1)before the stream stops. I would expect to see theonCompletesignal:Logs
If I change the limit to 1201 instead of 1200, flux emits the onComplete signal as expected:
Logs
Full Code Sample
Versions
The text was updated successfully, but these errors were encountered: