diff options
author | ulya-sidorina <yulia@ydb.tech> | 2023-11-16 16:38:01 +0300 |
---|---|---|
committer | ulya-sidorina <yulia@ydb.tech> | 2023-11-16 18:08:40 +0300 |
commit | 447abbfdb8731a4173604d359559f9149f54f56b (patch) | |
tree | 1e22ae7e74ae50bf8e796d7b02ff677c1ced752f | |
parent | 46f0c0079bb50609d2eeb6586642bcf114fc5239 (diff) | |
download | ydb-447abbfdb8731a4173604d359559f9149f54f56b.tar.gz |
KIKIMR-20139: invalidate query cache after StreamLookupJoin flag changing
fix(kqp): invalidate query cache after stream lookup flag changing
-rw-r--r-- | ydb/core/kqp/compile_service/kqp_compile_service.cpp | 18 |
1 files changed, 7 insertions, 11 deletions
diff --git a/ydb/core/kqp/compile_service/kqp_compile_service.cpp b/ydb/core/kqp/compile_service/kqp_compile_service.cpp index 9ebb183fb0..eb2b7d2e10 100644 --- a/ydb/core/kqp/compile_service/kqp_compile_service.cpp +++ b/ydb/core/kqp/compile_service/kqp_compile_service.cpp @@ -457,6 +457,7 @@ private: bool enableKqpDataQueryStreamLookup = TableServiceConfig.GetEnableKqpDataQueryStreamLookup(); bool enableKqpScanQueryStreamLookup = TableServiceConfig.GetEnableKqpScanQueryStreamLookup(); + bool enableKqpDataQueryStreamIdxLookupJoin = TableServiceConfig.GetEnableKqpDataQueryStreamIdxLookupJoin(); bool enableKqpScanQueryStreamIdxLookupJoin = TableServiceConfig.GetEnableKqpScanQueryStreamIdxLookupJoin(); bool enableKqpDataQuerySourceRead = TableServiceConfig.GetEnableKqpDataQuerySourceRead(); @@ -485,6 +486,7 @@ private: TableServiceConfig.GetEnableKqpDataQueryStreamLookup() != enableKqpDataQueryStreamLookup || TableServiceConfig.GetEnableKqpScanQueryStreamLookup() != enableKqpScanQueryStreamLookup || TableServiceConfig.GetEnableKqpScanQueryStreamIdxLookupJoin() != enableKqpScanQueryStreamIdxLookupJoin || + TableServiceConfig.GetEnableKqpDataQueryStreamIdxLookupJoin() != enableKqpDataQueryStreamIdxLookupJoin || TableServiceConfig.GetEnableKqpDataQuerySourceRead() != enableKqpDataQuerySourceRead || TableServiceConfig.GetEnableKqpScanQuerySourceRead() != enableKqpScanQuerySourceRead || TableServiceConfig.GetEnablePredicateExtractForDataQueries() != enableKqpDataQueryPredicateExtract || @@ -492,20 +494,14 @@ private: TableServiceConfig.GetPredicateExtract20() != predicateExtract20 || TableServiceConfig.GetEnableSequentialReads() != enableSequentialReads || TableServiceConfig.GetEnableKqpImmediateEffects() != enableKqpImmediateEffects || - TableServiceConfig.GetIndexAutoChooseMode() != indexAutoChooser || - TableServiceConfig.GetEnableSequences() != enableSequences || + TableServiceConfig.GetIndexAutoChooseMode() != indexAutoChooser || + TableServiceConfig.GetEnableSequences() != enableSequences || TableServiceConfig.GetEnableColumnsWithDefault() != enableColumnsWithDefault) { - LOG_NOTICE_S(*TlsActivationContext, NKikimrServices::KQP_COMPILE_SERVICE, - "Iterator read flags was changed. StreamLookup from " << enableKqpDataQueryStreamLookup << - " to " << TableServiceConfig.GetEnableKqpDataQueryStreamLookup() << " for data queries, from " << - enableKqpScanQueryStreamLookup << " to " << TableServiceConfig.GetEnableKqpScanQueryStreamLookup() << ", from " - << enableKqpScanQueryStreamIdxLookupJoin << " to " << TableServiceConfig.GetEnableKqpScanQueryStreamIdxLookupJoin() - << " scan queries. Sources for data queries from " << enableKqpDataQuerySourceRead << " to " - << TableServiceConfig.GetEnableKqpDataQuerySourceRead() << "for scan queries from " << enableKqpScanQuerySourceRead - << " to " << TableServiceConfig.GetEnableKqpScanQuerySourceRead()); - QueryCache.Clear(); + + LOG_NOTICE_S(*TlsActivationContext, NKikimrServices::KQP_COMPILE_SERVICE, + "Query cache was invalidated due to config change"); } } |