Skip to content
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.

Sign up for GitHub

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

[fix][broker] Replication stuck when partitions count between two clusters is not the same #22983

Merged
merged 16 commits into from
Jul 15, 2024
Merged

[fix][broker] Replication stuck when partitions count between two clusters is not the same #22983

Changes from 1 commit
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
0eaf586
[improve][log] Improve replicator's log when partitions count between…
poorbarcode Jun 26, 2024
b61ce17
-
poorbarcode Jun 27, 2024
72a5d75
fix issue
poorbarcode Jun 27, 2024
7254197
add test
poorbarcode Jun 27, 2024
26d3ce5
improve test
poorbarcode Jun 27, 2024
d843f30
fix test
poorbarcode Jun 27, 2024
7c0d811
address comments
poorbarcode Jul 5, 2024
853904a
address comments
poorbarcode Jul 7, 2024
1ceee52
add more tests
poorbarcode Jul 8, 2024
814b678
fix bug
poorbarcode Jul 15, 2024
efccc69
remove unnecessary changes
poorbarcode Jul 15, 2024
7ec9ceb
remove unnecessary changes
poorbarcode Jul 15, 2024
879c1b4
fix log's bug
poorbarcode Jul 15, 2024
9c15498
cleanup the resource that the test created
poorbarcode Jul 15, 2024
6f20dc1
fix test
poorbarcode Jul 15, 2024
ad95488
checkstyle
poorbarcode Jul 15, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
cleanup the resource that the test created
  • Loading branch information
@poorbarcode
poorbarcode committed Jul 15, 2024
commit 9c1549848de8f1133d1973114fef37e473f0d2e1
2 changes: 2 additions & 0 deletions pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1157,5 +1157,7 @@ public void testDifferentTopicCreationRule(ReplicationMode replicationMode) thro
});
admin1.topics().delete(tp, false);
admin2.topics().delete(tp, false);
admin1.namespaces().deleteNamespace(ns);
admin2.namespaces().deleteNamespace(ns);
}
}
Loading