idea（本地写入sr） sr部署在容器内，采用nodePort 方式暴露端口了，但连接是，报错

💬 StarRocks 用户问答
#1

idea（本地写入sr） sr部署在容器内，采用nodePort 方式暴露端口了，但连接是报错,报svc名。

Caused by: java.lang.RuntimeException: java.net.UnknownHostException: starrocks-fe-v2-2.starrocks-fe-v2.starrocks-v2.svc.cluster.local
at com.starrocks.data.load.stream.TransactionStreamLoader.doBegin(TransactionStreamLoader.java:157) ~[flink-connector-starrocks-1.2.9_flink-1.16.jar:?]
at com.starrocks.data.load.stream.TransactionStreamLoader.begin(TransactionStreamLoader.java:99) ~[flink-connector-starrocks-1.2.9_flink-1.16.jar:?]
at com.starrocks.data.load.stream.DefaultStreamLoader.send(DefaultStreamLoader.java:169) ~[flink-connector-starrocks-1.2.9_flink-1.16.jar:?]
at com.starrocks.data.load.stream.v2.TransactionTableRegion.streamLoad(TransactionTableRegion.java:331) ~[flink-connector-starrocks-1.2.9_flink-1.16.jar:?]
at com.starrocks.data.load.stream.v2.TransactionTableRegion.flush(TransactionTableRegion.java:228) ~[flink-connector-starrocks-1.2.9_flink-1.16.jar:?]
at com.starrocks.data.load.stream.v2.StreamLoadManagerV2.lambda$init$0(StreamLoadManagerV2.java:179) ~[flink-connector-starrocks-1.2.9_flink-1.16.jar:?]
… 1 more

#2

apiVersion: v1
kind: Service
metadata:
name: starrocks-fe-v2-2
spec:
selector:
app: starrocks-fe-v2
ports:
- name: http
protocol: TCP
port: 8030
targetPort: 8030
nodePort: 30901
- name: http-proxy
protocol: TCP
port: 8080
targetPort: 8080
nodePort: 30903
- name: query
protocol: TCP
port: 9030
targetPort: 9030
nodePort: 30902
type: NodePort

#3

starrocks.jdbc.url=jdbc:mysql://xxxxx.cn:30903
starrocks.jdbc.load.url:30903=xxxxx.cn 去连接starrcoks ，报错：
Caused by: com.mysql.jdbc.PacketTooBigException: Packet for query is too large (1179648 > 1048576). You can change this value on the server by setting the max_allowed_packet’ variable.
at com.mysql.jdbc.MysqlIO.readPacket(MysqlIO.java:571)
at com.mysql.jdbc.MysqlIO.doHandshake(MysqlIO.java:1007)
at com.mysql.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2189)
at com.mysql.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2220)
at com.mysql.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2015)
at com.mysql.jdbc.ConnectionImpl.(ConnectionImpl.java:768)
at com.mysql.jdbc.JDBC4Connection.(JDBC4Connection.java:47)
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:403)
at com.mysql.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:385)
at com.mysql.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:323)
at java.sql.DriverManager.getConnection(DriverManager.java:664)
at java.sql.DriverManager.getConnection(DriverManager.java:247)
at com.starrocks.connector.flink.connection.StarRocksJdbcConnectionProvider.getConnection(StarRocksJdbcConnectionProvider.java:53)
at com.starrocks.connector.flink.manager.StarRocksQueryVisitor.executeQuery(StarRocksQueryVisitor.java:98)
at com.starrocks.connector.flink.manager.StarRocksQueryVisitor.getTableColumnsMetaData(StarRocksQueryVisitor.java:56)
… 7 more

#4

max_allowed_packet 默认值33554432

京ICP备2022026421号-1