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 7719f55 commit c2c1424Copy full SHA for c2c1424
ydb/core/kqp/runtime/kqp_write_table.cpp
@@ -1084,6 +1084,7 @@ class TShardedWriteController : public IShardedWriteController {
1084
}
1085
1086
void Close() override {
1087
+ auto allocGuard = TypeEnv.BindAllocator();
1088
YQL_ENSURE(Serializer);
1089
Closed = true;
1090
Serializer->Close();
@@ -1189,6 +1190,12 @@ class TShardedWriteController : public IShardedWriteController {
1189
1190
, TypeEnv(typeEnv) {
1191
1192
1193
+ ~TShardedWriteController() {
1194
1195
+ ShardsInfo.Clear();
1196
+ Serializer = nullptr;
1197
+ }
1198
+
1199
private:
1200
void FlushSerializer(bool force) {
1201
if (force) {
0 commit comments