Skip to content

Commit b49c049

Browse files
committed
debug
1 parent 26a1927 commit b49c049

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessorTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -660,6 +660,9 @@ void testRestartResumeDropPartition() throws Exception {
660660

661661
// verify partition2 is dropped
662662
verifyPartitionDropped(tableId, partition2Id);
663+
Optional<PartitionAssignment> partitionAssignment1 =
664+
zookeeperClient.getPartitionAssignment(partition1Id);
665+
System.out.println("partitionAssignment1 = " + partitionAssignment1);
663666
// verify the status of partition1
664667
verifyPartitionCreated(
665668
new TablePartition(tableId, partition1Id),

0 commit comments

Comments
 (0)