Skip to content

Commit 7e83d45

Browse files
committed
chore: fix typos
1 parent f40a69f commit 7e83d45

20 files changed

Lines changed: 37 additions & 37 deletions

File tree

broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ public void updateLockFreeTimestamp(String topic, String group, int queueId, Lon
9999
}
100100
});
101101
} catch (Exception e) {
102-
POP_LOGGER.error("unexpect error when updateLockFreeTimestamp. topic:{}, group:{}, queueId:{}, lockFreeTimestamp:{}",
102+
POP_LOGGER.error("unexpected error when updateLockFreeTimestamp. topic:{}, group:{}, queueId:{}, lockFreeTimestamp:{}",
103103
topic, group, queueId, lockFreeTimestamp, e);
104104
}
105105
}
@@ -108,7 +108,7 @@ protected void notifyLockIsFree(Key key) {
108108
try {
109109
this.brokerController.getPopMessageProcessor().notifyLongPollingRequestIfNeed(key.topic, key.group, key.queueId);
110110
} catch (Exception e) {
111-
POP_LOGGER.error("unexpect error when notifyLockIsFree. key:{}", key, e);
111+
POP_LOGGER.error("unexpected error when notifyLockIsFree. key:{}", key, e);
112112
}
113113
}
114114

client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -731,10 +731,10 @@ public boolean removeUnnecessaryPopMessageQueue(final MessageQueue mq, final Pop
731731
public void removeProcessQueue(final MessageQueue mq) {
732732
ProcessQueue prev = this.processQueueTable.remove(mq);
733733
if (prev != null) {
734-
boolean droped = prev.isDropped();
734+
boolean dropped = prev.isDropped();
735735
prev.setDropped(true);
736736
this.removeUnnecessaryMessageQueue(mq, prev);
737-
log.info("Fix Offset, {}, remove unnecessary mq, {} Droped: {}", consumerGroup, mq, droped);
737+
log.info("Fix Offset, {}, remove unnecessary mq, {} Dropped: {}", consumerGroup, mq, dropped);
738738
}
739739
}
740740

common/src/main/java/org/apache/rocketmq/common/fastjson/GenericMapSuperclassDeserializer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public class GenericMapSuperclassDeserializer implements ObjectDeserializer {
3434

3535
@SuppressWarnings({"unchecked", "rawtypes"})
3636
@Override
37-
public <T> T deserialze(DefaultJSONParser parser, Type type, Object fieldName) {
37+
public <T> T deserialize(DefaultJSONParser parser, Type type, Object fieldName) {
3838
Class<?> clz = (Class<?>) type;
3939
Type genericSuperclass = clz.getGenericSuperclass();
4040
Map map;

docs/cn/operation.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -780,7 +780,7 @@ RocketMQ 5.0 开始支持自动主从切换的模式,可参考以下文档
780780
</tr>
781781
<tr height=23 style='height:17.0pt'>
782782
<td height=23 class=xl67 width=87 style='height:17.0pt;width:65pt'>-i</td>
783-
<td class=xl67 width=87 style='width:65pt'>uniqe msg id</td>
783+
<td class=xl67 width=87 style='width:65pt'>unique msg id</td>
784784
</tr>
785785
<tr height=36 style='height:27.0pt'>
786786
<td height=36 class=xl67 width=87 style='height:27.0pt;width:65pt'>-g</td>

docs/en/Operations_Trace.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111

1212
## 2 Support for Message Trace Cluster Deployment
1313

14-
### 2.1 Broker Configuration Fille
14+
### 2.1 Broker Configuration File
1515

1616
The properties profile content of the Broker side enabled message trace feature is pasted here:
1717

filter/src/main/java/org/apache/rocketmq/filter/expression/ComparisonExpression.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -473,7 +473,7 @@ public static void checkLessThanOperand(Expression expr) {
473473

474474
/**
475475
* Validates that the expression can be used in == or <> expression. Cannot
476-
* not be NULL TRUE or FALSE litterals.
476+
* not be NULL TRUE or FALSE literals.
477477
*/
478478
public static void checkEqualOperand(Expression expr) {
479479
if (expr instanceof ConstantExpression) {

filter/src/main/java/org/apache/rocketmq/filter/expression/UnaryExpression.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,7 @@ private static Number negate(Number left) {
206206
} else if (clazz == Double.class) {
207207
return new Double(-left.doubleValue());
208208
} else if (clazz == BigDecimal.class) {
209-
// We ussually get a big deciamal when we have Long.MIN_VALUE
209+
// We usually get a big decimal when we have Long.MIN_VALUE
210210
// constant in the
211211
// Selector. Long.MIN_VALUE is too big to store in a Long as a
212212
// positive so we store it

filter/src/main/java/org/apache/rocketmq/filter/parser/ParseException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public ParseException(String message) {
7777
/**
7878
* This is the last token that has been consumed successfully. If
7979
* this object has been created due to a parse error, the token
80-
* followng this token will (therefore) be the first error token.
80+
* following this token will (therefore) be the first error token.
8181
*/
8282
public Token currentToken;
8383

filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -469,7 +469,7 @@ final public String stringLitteral() throws ParseException {
469469
StringBuffer rc = new StringBuffer();
470470
boolean first = true;
471471
t = jj_consume_token(STRING_LITERAL);
472-
// Decode the sting value.
472+
// Decode the string value.
473473
String image = t.image;
474474
for (int i = 1; i < image.length() - 1; i++) {
475475
char c = image.charAt(i);

proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ public static void main(String[] args) {
109109
}));
110110
} catch (Exception e) {
111111
e.printStackTrace();
112-
log.error("find an unexpect err.", e);
112+
log.error("find an unexpected err.", e);
113113
System.exit(1);
114114
}
115115

0 commit comments

Comments
 (0)