Skip to content

Commit 1cecf30

Browse files
committed
fix
1 parent 18ff8ba commit 1cecf30

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

fluss-server/src/main/java/org/apache/fluss/server/zk/ZooKeeperClient.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -306,16 +306,6 @@ public void updatePartitionAssignment(long partitionId, PartitionAssignment part
306306
partitionId);
307307
}
308308

309-
public void updatePartitionAssignment(long partitionId, PartitionAssignment partitionAssignment)
310-
throws Exception {
311-
String path = PartitionIdZNode.path(partitionId);
312-
zkClient.setData().forPath(path, PartitionIdZNode.encode(partitionAssignment));
313-
LOG.info(
314-
"Update partition assignment {} for partition id {}.",
315-
partitionAssignment,
316-
partitionId);
317-
}
318-
319309
public void deleteTableAssignment(long tableId) throws Exception {
320310
String path = TableIdZNode.path(tableId);
321311
zkClient.delete().deletingChildrenIfNeeded().forPath(path);

0 commit comments

Comments
 (0)