Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
Signed-off-by: gengjun-git <[email protected]>
  • Loading branch information
gengjun-git committed Sep 10, 2024
1 parent 8a9fe83 commit 9c6a614
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -189,11 +189,11 @@ public EncryptionKey create(EncryptionKeyPB pb) {
public void load(SRMetaBlockReader reader) throws IOException, SRMetaBlockException, SRMetaBlockEOFException {
keysLock.writeLock().lock();
try {
LOG.info("loading keys");
reader.readCollection(EncryptionKeyPB.class, pb -> {
EncryptionKey key = create(pb);
idToKey.put(key.id, key);
});
LOG.info("loaded {} keys", idToKey.size());

if (MetricRepo.hasInit) {
MetricRepo.GAUGE_ENCRYPTION_KEY_NUM.setValue((long) idToKey.size());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@
import com.starrocks.catalog.EsTable;
import com.starrocks.catalog.ExpressionRangePartitionInfo;
import com.starrocks.catalog.ExpressionRangePartitionInfoV2;
import com.starrocks.catalog.ExternalOlapTable;
import com.starrocks.catalog.FileTable;
import com.starrocks.catalog.Function;
import com.starrocks.catalog.HashDistributionInfo;
Expand Down Expand Up @@ -304,6 +305,7 @@ public class GsonUtils {
private static final RuntimeTypeAdapterFactory<com.starrocks.catalog.Table> TABLE_TYPE_ADAPTER_FACTORY
= RuntimeTypeAdapterFactory.of(com.starrocks.catalog.Table.class, "clazz")
.registerSubtype(EsTable.class, "EsTable")
.registerSubtype(ExternalOlapTable.class, "ExternalOlapTable")
.registerSubtype(FileTable.class, "FileTable")
.registerSubtype(HiveTable.class, "HiveTable")
.registerSubtype(HudiTable.class, "HudiTable")
Expand Down

0 comments on commit 9c6a614

Please sign in to comment.