Skip to content

Commit 291382b

Browse files
swuferhongswuferhong
committed
1111
1 parent 232627f commit 291382b

File tree

13 files changed

+35
-35
lines changed

13 files changed

+35
-35
lines changed

‎fluss-client/src/main/java/org/apache/fluss/client/admin/Admin.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,11 @@
2222
import org.apache.fluss.client.metadata.KvSnapshots;
2323
import org.apache.fluss.client.metadata.LakeSnapshot;
2424
import org.apache.fluss.cluster.ServerNode;
25-
import org.apache.fluss.config.ConfigOptions;
26-
import org.apache.fluss.exception.AuthorizationException;
2725
import org.apache.fluss.cluster.maintencance.GoalType;
2826
import org.apache.fluss.cluster.maintencance.RebalancePlanForBucket;
2927
import org.apache.fluss.cluster.maintencance.ServerTag;
28+
import org.apache.fluss.config.ConfigOptions;
29+
import org.apache.fluss.exception.AuthorizationException;
3030
import org.apache.fluss.exception.DatabaseAlreadyExistException;
3131
import org.apache.fluss.exception.DatabaseNotEmptyException;
3232
import org.apache.fluss.exception.DatabaseNotExistException;
@@ -36,11 +36,11 @@
3636
import org.apache.fluss.exception.InvalidTableException;
3737
import org.apache.fluss.exception.KvSnapshotNotExistException;
3838
import org.apache.fluss.exception.LakeTableSnapshotNotExistException;
39-
import org.apache.fluss.exception.RebalanceFailureException;
40-
import org.apache.fluss.exception.NonPrimaryKeyTableException;
4139
import org.apache.fluss.exception.NoRebalanceInProgressException;
40+
import org.apache.fluss.exception.NonPrimaryKeyTableException;
4241
import org.apache.fluss.exception.PartitionAlreadyExistsException;
4342
import org.apache.fluss.exception.PartitionNotExistException;
43+
import org.apache.fluss.exception.RebalanceFailureException;
4444
import org.apache.fluss.exception.SchemaNotExistException;
4545
import org.apache.fluss.exception.ServerNotExistException;
4646
import org.apache.fluss.exception.ServerTagAlreadyExistException;

‎fluss-client/src/main/java/org/apache/fluss/client/admin/FlussAdmin.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@
2424
import org.apache.fluss.client.utils.ClientRpcMessageUtils;
2525
import org.apache.fluss.cluster.Cluster;
2626
import org.apache.fluss.cluster.ServerNode;
27-
import org.apache.fluss.exception.LeaderNotAvailableException;
2827
import org.apache.fluss.cluster.maintencance.GoalType;
2928
import org.apache.fluss.cluster.maintencance.RebalancePlanForBucket;
3029
import org.apache.fluss.cluster.maintencance.ServerTag;
30+
import org.apache.fluss.exception.LeaderNotAvailableException;
3131
import org.apache.fluss.metadata.DatabaseDescriptor;
3232
import org.apache.fluss.metadata.DatabaseInfo;
3333
import org.apache.fluss.metadata.PartitionInfo;

fluss-common/src/main/java/com/alibaba/fluss/cluster/maintencance/GoalType.java renamed to fluss-common/src/main/java/org/apache/fluss/cluster/maintencance/GoalType.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.alibaba.fluss.cluster.maintencance;
18+
package org.apache.fluss.cluster.maintencance;
1919

20-
import com.alibaba.fluss.annotation.PublicEvolving;
20+
import org.apache.fluss.annotation.PublicEvolving;
2121

2222
import java.util.Arrays;
2323

fluss-common/src/main/java/com/alibaba/fluss/cluster/maintencance/RebalancePlanForBucket.java renamed to fluss-common/src/main/java/org/apache/fluss/cluster/maintencance/RebalancePlanForBucket.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.alibaba.fluss.cluster.maintencance;
18+
package org.apache.fluss.cluster.maintencance;
1919

20-
import com.alibaba.fluss.annotation.PublicEvolving;
20+
import org.apache.fluss.annotation.PublicEvolving;
2121

2222
import java.util.List;
2323
import java.util.Objects;

fluss-common/src/main/java/com/alibaba/fluss/cluster/maintencance/RebalanceStatus.java renamed to fluss-common/src/main/java/org/apache/fluss/cluster/maintencance/RebalanceStatus.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.alibaba.fluss.cluster.maintencance;
18+
package org.apache.fluss.cluster.maintencance;
1919

20-
import com.alibaba.fluss.annotation.PublicEvolving;
20+
import org.apache.fluss.annotation.PublicEvolving;
2121

2222
/**
2323
* Rebalance status for the rebalance task.

fluss-common/src/main/java/com/alibaba/fluss/cluster/maintencance/RebalanceStatusForBucket.java renamed to fluss-common/src/main/java/org/apache/fluss/cluster/maintencance/RebalanceStatusForBucket.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.alibaba.fluss.cluster.maintencance;
18+
package org.apache.fluss.cluster.maintencance;
1919

20-
import com.alibaba.fluss.annotation.PublicEvolving;
20+
import org.apache.fluss.annotation.PublicEvolving;
2121

2222
/**
2323
* Rebalance status for single bucket.

fluss-common/src/main/java/com/alibaba/fluss/cluster/maintencance/ServerTag.java renamed to fluss-common/src/main/java/org/apache/fluss/cluster/maintencance/ServerTag.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.alibaba.fluss.cluster.maintencance;
18+
package org.apache.fluss.cluster.maintencance;
1919

20-
import com.alibaba.fluss.annotation.PublicEvolving;
20+
import org.apache.fluss.annotation.PublicEvolving;
2121

2222
import java.util.Arrays;
2323

‎fluss-rpc/src/main/java/org/apache/fluss/rpc/gateway/AdminGateway.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,8 +41,8 @@
4141
import org.apache.fluss.rpc.messages.ListRebalanceProcessResponse;
4242
import org.apache.fluss.rpc.messages.RebalanceRequest;
4343
import org.apache.fluss.rpc.messages.RebalanceResponse;
44-
import com.alibaba.fluss.rpc.messages.RemoveServerTagRequest;
45-
import com.alibaba.fluss.rpc.messages.RemoveServerTagResponse;
44+
import org.apache.fluss.rpc.messages.RemoveServerTagRequest;
45+
import org.apache.fluss.rpc.messages.RemoveServerTagResponse;
4646
import org.apache.fluss.rpc.protocol.ApiKeys;
4747
import org.apache.fluss.rpc.protocol.RPC;
4848

‎fluss-rpc/src/main/java/org/apache/fluss/rpc/protocol/Errors.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,9 +63,9 @@
6363
import org.apache.fluss.exception.SchemaNotExistException;
6464
import org.apache.fluss.exception.SecurityDisabledException;
6565
import org.apache.fluss.exception.SecurityTokenException;
66-
import org.apache.fluss.exception.StorageException;
6766
import org.apache.fluss.exception.ServerNotExistException;
6867
import org.apache.fluss.exception.ServerTagAlreadyExistException;
68+
import org.apache.fluss.exception.StorageException;
6969
import org.apache.fluss.exception.TableAlreadyExistException;
7070
import org.apache.fluss.exception.TableNotExistException;
7171
import org.apache.fluss.exception.TableNotPartitionedException;

‎fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorService.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -40,10 +40,10 @@
4040
import org.apache.fluss.metadata.TablePartition;
4141
import org.apache.fluss.metadata.TablePath;
4242
import org.apache.fluss.rpc.gateway.CoordinatorGateway;
43-
import org.apache.fluss.rpc.messages.AdjustIsrRequest;
44-
import org.apache.fluss.rpc.messages.AdjustIsrResponse;
4543
import org.apache.fluss.rpc.messages.AddServerTagRequest;
4644
import org.apache.fluss.rpc.messages.AddServerTagResponse;
45+
import org.apache.fluss.rpc.messages.AdjustIsrRequest;
46+
import org.apache.fluss.rpc.messages.AdjustIsrResponse;
4747
import org.apache.fluss.rpc.messages.CancelRebalanceRequest;
4848
import org.apache.fluss.rpc.messages.CancelRebalanceResponse;
4949
import org.apache.fluss.rpc.messages.CommitKvSnapshotRequest;
@@ -70,10 +70,10 @@
7070
import org.apache.fluss.rpc.messages.DropTableResponse;
7171
import org.apache.fluss.rpc.messages.LakeTieringHeartbeatRequest;
7272
import org.apache.fluss.rpc.messages.LakeTieringHeartbeatResponse;
73-
import org.apache.fluss.rpc.messages.MetadataRequest;
74-
import org.apache.fluss.rpc.messages.MetadataResponse;
7573
import org.apache.fluss.rpc.messages.ListRebalanceProcessRequest;
7674
import org.apache.fluss.rpc.messages.ListRebalanceProcessResponse;
75+
import org.apache.fluss.rpc.messages.MetadataRequest;
76+
import org.apache.fluss.rpc.messages.MetadataResponse;
7777
import org.apache.fluss.rpc.messages.PbHeartbeatReqForTable;
7878
import org.apache.fluss.rpc.messages.PbHeartbeatRespForTable;
7979
import org.apache.fluss.rpc.messages.RebalanceRequest;

0 commit comments

Comments
 (0)