-
Notifications
You must be signed in to change notification settings - Fork 11.8k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[ISSUE #8058] Support for upgrading metadata in json to rocksdb #8081
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I wonder know why this command was deleted?
Suggest adding a feature switch to broker config |
@@ -370,6 +378,7 @@ private void supportAttributes(List<Attribute> supportAttributes) { | |||
} | |||
|
|||
private boolean notToBeExecuted() { | |||
return MixAll.isMac(); | |||
// return MixAll.isMac(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Suggest fix it
public class ConfigRocksDBStorage extends AbstractRocksDBStorage { | ||
|
||
private static final byte[] KV_DATA_VERSION_COLUMN_FAMILY_NAME = "kvDataVersion".getBytes(StandardCharsets.UTF_8); | ||
private static final byte[] KV_DATA_VERSION_KEY = "dataVersion".getBytes(StandardCharsets.UTF_8); | ||
protected ColumnFamilyHandle kvDataVersionFamilyHandle; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
为什么有两个版本
} finally { | ||
iterator.close(); | ||
} | ||
this.flushOptions = new FlushOptions(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
和上面重复了
Which Issue(s) This PR Fixes
Fixes #8058
Brief Description
How Did You Test This Change?