Skip to content

Commit ea2bf97

Browse files
committed
Make schem agreement query pull only columns that are used
Currently schema agreement logic run `select * from system.peers`, while only `schema_version` is used, it creates excessive load on cluster and driver side.
1 parent cf9f8f0 commit ea2bf97

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/com/datastax/oss/driver/internal/core/metadata/SchemaAgreementChecker.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ private void sendQueries() {
108108
} else {
109109
CompletionStage<AdminResult> localQuery =
110110
query("SELECT schema_version FROM system.local WHERE key='local'");
111-
CompletionStage<AdminResult> peersQuery = query("SELECT * FROM system.peers");
111+
CompletionStage<AdminResult> peersQuery = query("SELECT schema_version FROM system.peers");
112112

113113
localQuery
114114
.thenCombine(peersQuery, this::extractSchemaVersions)

0 commit comments

Comments
 (0)