You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2025/10/28 03:53:23 UTC
(iotdb) 01/01: Clarify the non-ssl client connects the ssl server error log information
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch clear_ssl_error_message
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9a16eb23dfefc8ba7f8df81af432c56545a8d589
Author: HTHou <ha...@apache.org>
AuthorDate: Tue Oct 28 11:52:58 2025 +0800
Clarify the non-ssl client connects the ssl server error log information
---
.../main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java
index 0ff58f71e12..e9f36a8780e 100644
--- a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java
+++ b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java
@@ -25,6 +25,7 @@ import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TTransportFactory;
import org.apache.thrift.transport.layered.TFramedTransport;
+import javax.net.ssl.SSLException;
import javax.net.ssl.SSLHandshakeException;
import java.io.EOFException;
@@ -136,6 +137,14 @@ public class TElasticFramedTransport extends TTransport {
&& e.getCause().getCause() instanceof EOFException) {
throw new TTransportException(TTransportException.END_OF_FILE, e.getCause());
}
+ if (e.getCause() instanceof SSLException
+ && e.getMessage().contains("Unsupported or unrecognized SSL message")) {
+ throw new TTransportException(
+ TTransportException.CORRUPTED_DATA,
+ "You may be sending "
+ + "non-SSL requests to the SSL-enabled Thrift-RPC port, please confirm that you are "
+ + "using the right configuration");
+ }
throw e;
}
return readBuffer.read(buf, off, len);