Skip to content

Commit cd7f618

Browse files
committed
kqp_write_table fix
1 parent e684b85 commit cd7f618

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

ydb/core/kqp/runtime/kqp_write_table.cpp

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -61,15 +61,13 @@ TVector<TSysTables::TTableColumnInfo> BuildColumns(const TConstArrayRef<NKikimrK
6161
result.reserve(inputColumns.size());
6262
i32 number = 0;
6363
for (const auto& column : inputColumns) {
64+
NScheme::TTypeInfo typeInfo = (column.GetTypeId() == NScheme::NTypeIds::Pg) ?
65+
NScheme::TTypeInfo(column.GetTypeId(), NPg::TypeDescFromPgTypeId(column.GetTypeInfo().GetPgTypeId())) :
66+
NScheme::TTypeInfo(column.GetTypeId());
6467
result.emplace_back(
6568
column.GetName(),
6669
column.GetId(),
67-
NScheme::TTypeInfo {
68-
static_cast<NScheme::TTypeId>(column.GetTypeId()),
69-
column.GetTypeId() == NScheme::NTypeIds::Pg
70-
? NPg::TypeDescFromPgTypeId(column.GetTypeInfo().GetPgTypeId())
71-
: nullptr
72-
},
70+
std::move(typeInfo),
7371
column.GetTypeInfo().GetPgTypeMod(),
7472
number++
7573
);

0 commit comments

Comments
 (0)