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 <[email protected]> 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);
