Skip to content

Commit

Permalink
Update PropertyAnalyzer.java
Browse files Browse the repository at this point in the history
  • Loading branch information
xiedeyantu authored Mar 23, 2024
1 parent 2d09478 commit 2016542
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -1256,7 +1256,7 @@ private static ReplicaAllocation analyzeReplicaAllocationImpl(Map<String, String
Short replicaNum = analyzeReplicationNum(properties, prefix, (short) 0);
if (replicaNum > 0) {
ReplicaAllocation replicaAlloc = new ReplicaAllocation(replicaNum);
if (properties.get(propKey).equals(replicaAlloc.toString())) {
if (properties.containsKey(propKey) && properties.get(propKey).equals(replicaAlloc.toString())) {
throw new AnalysisException("Invalid replication parameter: replication_num and "
+ "replication_allocation can not be used together");
}
Expand Down

0 comments on commit 2016542

Please sign in to comment.