Skip to content

Commit 1cde959

Browse files
committed
fix call ReplicatedMergeTreeSinkWithAsyncDeduplicate
1 parent 0d77722 commit 1cde959

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Storages/StorageReplicatedMergeTree.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5984,7 +5984,7 @@ SinkToStoragePtr StorageReplicatedMergeTree::write(const ASTPtr & /*query*/, con
59845984
query_settings[Setting::insert_quorum_timeout].totalMilliseconds(),
59855985
query_settings[Setting::max_partitions_per_insert_block],
59865986
query_settings[Setting::insert_quorum_parallel],
5987-
deduplicate,
5987+
async_deduplicate,
59885988
query_settings[Setting::insert_quorum].is_auto,
59895989
local_context);
59905990

0 commit comments

Comments
 (0)