We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1cf8473 commit f296d75Copy full SHA for f296d75
ydb/core/kqp/executer_actor/kqp_partitioned_executer.cpp
@@ -361,13 +361,14 @@ class TKqpPartitionedExecuter : public TActorBootstrapped<TKqpPartitionedExecute
361
YQL_ENSURE(sink.GetInternalSink().GetSettings().UnpackTo(&settings), "Failed to unpack settings");
362
363
switch (settings.GetType()) {
364
- case NKikimrKqp::TKqpTableSinkSettings::MODE_UPDATE:
+ case NKikimrKqp::TKqpTableSinkSettings::MODE_UPSERT:
365
OperationType = TKeyDesc::ERowOperation::Update;
366
break;
367
case NKikimrKqp::TKqpTableSinkSettings::MODE_DELETE:
368
OperationType = TKeyDesc::ERowOperation::Erase;
369
370
default:
371
+ YQL_ENSURE(false);
372
373
}
374
0 commit comments