File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
ydb/core/kqp/session_actor Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -1292,7 +1292,8 @@ class TKqpSessionActor : public TActorBootstrapped<TKqpSessionActor> {
1292
1292
LOG_D (" Sending to Executer TraceId: " << request.TraceId .GetTraceId () << " " << request.TraceId .GetSpanIdSize ());
1293
1293
1294
1294
const bool useEvWrite = ((HasOlapTable && Settings.TableService .GetEnableOlapSink ()) || (!HasOlapTable && Settings.TableService .GetEnableOltpSink ()))
1295
- && (request.QueryType == NKikimrKqp::EQueryType::QUERY_TYPE_SQL_GENERIC_QUERY
1295
+ && (request.QueryType == NKikimrKqp::EQueryType::QUERY_TYPE_UNDEFINED
1296
+ || request.QueryType == NKikimrKqp::EQueryType::QUERY_TYPE_SQL_GENERIC_QUERY
1296
1297
|| request.QueryType == NKikimrKqp::EQueryType::QUERY_TYPE_SQL_GENERIC_CONCURRENT_QUERY
1297
1298
|| (!HasOlapTable && request.QueryType == NKikimrKqp::EQueryType::QUERY_TYPE_SQL_DML)
1298
1299
|| (!HasOlapTable && request.QueryType == NKikimrKqp::EQueryType::QUERY_TYPE_PREPARED_DML));
You can’t perform that action at this time.
0 commit comments