diff --git a/jOOQ-examples/jOOQ-r2dbc-example/src/test/java/org/jooq/example/r2dbc/test/R2dbcTest.java b/jOOQ-examples/jOOQ-r2dbc-example/src/test/java/org/jooq/example/r2dbc/test/R2dbcTest.java
index 8eb3e7998d..b48c8ac15a 100644
--- a/jOOQ-examples/jOOQ-r2dbc-example/src/test/java/org/jooq/example/r2dbc/test/R2dbcTest.java
+++ b/jOOQ-examples/jOOQ-r2dbc-example/src/test/java/org/jooq/example/r2dbc/test/R2dbcTest.java
@@ -2,8 +2,12 @@ package org.jooq.example.r2dbc.test;
 
 import static org.jooq.example.r2dbc.db.Tables.AUTHOR;
 import static org.jooq.example.r2dbc.db.Tables.BOOK;
+import static org.junit.Assert.assertEquals;
+
+import java.util.List;
 
 import org.jooq.DSLContext;
+import org.jooq.Record3;
 import org.jooq.RowCountQuery;
 import org.jooq.Source;
 import org.jooq.impl.DSL;
@@ -42,6 +46,7 @@ public class R2dbcTest {
 
     @Test
     public void test() {
+        Record3<String, String, String> r =
         Flux.from(ctx
                 .insertInto(AUTHOR)
                 .columns(AUTHOR.FIRST_NAME, AUTHOR.LAST_NAME)
@@ -54,7 +59,10 @@ public class R2dbcTest {
             .thenMany(ctx
                 .select(BOOK.author().FIRST_NAME, BOOK.author().LAST_NAME, BOOK.TITLE)
                 .from(BOOK))
-            .doOnNext(System.out::println)
-            .subscribe();
+            .blockFirst();
+        
+        assertEquals("John", r.value1());
+        assertEquals("Doe", r.value2());
+        assertEquals("Fancy Book", r.value3());
     }
 }
diff --git a/jOOQ/src/main/java/org/jooq/impl/SelectQueryImpl.java b/jOOQ/src/main/java/org/jooq/impl/SelectQueryImpl.java
index 41c77258e2..39bf0ce6ee 100644
--- a/jOOQ/src/main/java/org/jooq/impl/SelectQueryImpl.java
+++ b/jOOQ/src/main/java/org/jooq/impl/SelectQueryImpl.java
@@ -2178,8 +2178,8 @@ final class SelectQueryImpl<R extends Record> extends AbstractResultQuery<R> imp
 
 
 
-
-
+        if (TRUE.equals(context.data(BooleanDataKey.DATA_RENDERING_DATA_CHANGE_DELTA_TABLE)))
+            context.qualify(false);
 
         context.declareFields(true);
 
@@ -2195,10 +2195,8 @@ final class SelectQueryImpl<R extends Record> extends AbstractResultQuery<R> imp
         else
             context.visit(getSelectResolveUnsupportedAsterisks(context.configuration()));
 
-
-
-
-
+        if (TRUE.equals(context.data(BooleanDataKey.DATA_RENDERING_DATA_CHANGE_DELTA_TABLE)))
+            context.qualify(qualify);
 
         context.declareFields(false)
                .end(SELECT_SELECT);