Skip to content

Commit 08a0f52

Browse files
wenyanshi-123shiwenyan
andauthored
Include the TSStatus code in Mqtt's error logs to facilitate troubleshooting. (#17025)
Co-authored-by: shiwenyan <wenyan.shi@timecho.com>
1 parent ae2793d commit 08a0f52

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -194,8 +194,11 @@ private void insertTable(TableMessage message, MqttClientSession session) {
194194
LOG.debug("process result: {}", tsStatus);
195195
}
196196
if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
197-
|| tsStatus.getCode() != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
198-
LOG.warn("mqtt line insert error , message = {}", tsStatus.message);
197+
&& tsStatus.getCode() != TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()) {
198+
LOG.warn(
199+
"mqtt json insert error, code={}, message={}",
200+
tsStatus.getCode(),
201+
tsStatus.getMessage());
199202
}
200203
} catch (Exception e) {
201204
LOG.warn(

0 commit comments

Comments
 (0)