-
Notifications
You must be signed in to change notification settings - Fork 253
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
[build] Enable ci #149
[build] Enable ci #149
Conversation
// less value will be popped first | ||
int res = Integer.compare(req2.getPriority(), req1.getPriority()); | ||
// if priority is same, we want to keep FIFO | ||
if (res == 0 && req1 != req2) { |
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.
The previous implementation is not FIFO, we need to change it to FIFO
@@ -116,7 +116,7 @@ void testRestore() throws Exception { | |||
final int leaderServer = FLUSS_CLUSTER_EXTENSION.waitAndGetLeader(tableBucket); | |||
Replica replica = FLUSS_CLUSTER_EXTENSION.waitAndGetLeaderReplica(tableBucket); | |||
|
|||
int recordsNum = 3000; | |||
int recordsNum = 10000; |
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.
3000 may not enough
@@ -142,6 +144,11 @@ public void afterEach(ExtensionContext extensionContext) { | |||
for (String database : databases) { | |||
if (!database.equals(defaultDb)) { | |||
metaDataManager.dropDatabase(database, true, true); | |||
// delete the data dirs | |||
for (int serverId : tabletServers.keySet()) { |
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.
need to delete data dirs, otherwise, restart a server will meet problem since the metadata is dropped.
@wuchong enable ci pr ready |
@@ -101,6 +102,7 @@ void testAppendOnly() throws Exception { | |||
|
|||
@ParameterizedTest | |||
@ValueSource(booleans = {true, false}) | |||
@Disabled("TODO, fix me in #116") |
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.
Will this be fixed in followup PR?
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.
Yes, and there're still some unstable tests need to be fixed in followup pr
List<RpcRequest> rpcRequests = new ArrayList<>(); | ||
// push rpc requests | ||
for (int i = 0; i < 100; i++) { | ||
RpcRequest rocRequest = |
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.
rpcRequest
?
Ci pass...Merging.... |
Purpose
Enable ci for fluss
Tests
N/A
API and Format
N/A
Documentation
N/A