执行UDF,在客户端报错 rpc failed, host: 172.22.20.7

【详述】问题详细描述
执行UDF,在客户端报错 rpc failed, host: 172.22.20.7
【背景】做过哪些操作?
注册udf 返回成功:

CREATE FUNCTION slide_window_rollup(STRING,STRING,INT,INT)
RETURNS STRING
PROPERTIES
(
“symbol” = “com.digitforce.bigdata.hme.starrocks.udf.SlideWindowRollup”,
“type” = “StarrocksJar”,
“file” = " "
);

CREATE FUNCTION date_window_until_rollup(STRING,STRING)
RETURNS STRING
PROPERTIES
(
“symbol” = “com.digitforce.bigdata.hme.starrocks.udf.DateWindowUntilRollup”,
“type” = “StarrocksJar”,
“file” = " "
);

查询显示失败
rpc failed, host: 172.22.20.7
select date_window_until_rollup(‘2022-10-15’,‘MONDAY_TO_NOW’)
, date_window_until_rollup(‘2022-10-15’,‘MONTH_TO_NOW’)
, date_window_until_rollup(‘2022-10-15’,‘YEAR_TO_NOW’)
, slide_window_rollup(‘year’,‘2000’,3,1)
, slide_window_rollup(‘quarter’,‘2000Q1’,3,1)
, slide_window_rollup(‘month’,‘2000-01’,3,1)
, slide_window_rollup(‘week’,‘2000-24’,3,1)
, slide_window_rollup(‘day’,‘2000-04-01’,3,1)
;

同样的udf,在dev环境注册和使用成功

【业务影响】
【StarRocks版本】例如:2.3.3-164799c
JDK:FE:1.8.0-openjdk-1.8.0.332.b09-1.el7_9.x86_64
BE: jdk1.8.0_202

【集群规模】例如:3fe(1 follower+2observer)+5be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【附件】
FE 日志


补充一下 fe warn.log
com.starrocks.rpc.RpcException: rpc failed, host: 172.23.0.25
at com.starrocks.qe.Coordinator.prepareResultSink(Coordinator.java:643) ~[starrocks-fe.jar:?]
at com.starrocks.qe.Coordinator.exec(Coordinator.java:434) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.handleQueryStmt(StmtExecutor.java:704) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:397) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:322) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:440) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:676) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.nio.ReadListener.lambda$handleEvent$0(ReadListener.java:55) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_332]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_332]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_332]
2022-11-01 15:21:07,849 WARN (REPLICA 172.23.0.6_9010_1658819758118(4)|51) [GlobalStateMgr.notifyNewFETypeTransfer():1590] notify new FE type transfer: UNKNOWN
2022-11-01 15:21:07,849 WARN (stateListener|64) [GlobalStateMgr.transferToNonMaster():1063] FOLLOWER to UNKNOWN, still offer read service
2022-11-01 15:21:07,996 WARN (starrocks-mysql-nio-pool-392|1172) [FrontendServiceProxy.call():29] call frontend thrift rpc failed, addr: TNetworkAddress(hostname:172.23.0.5, port:9020), retried: 0
org.apache.thrift.transport.TTransportException: Socket is closed by peer.
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:130) ~[libthrift-0.13.0.jar:0.13.0]
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) ~[libthrift-0.13.0.jar:0.13.0]
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:455) ~[libthrift-0.13.0.jar:0.13.0]
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:354) ~[libthrift-0.13.0.jar:0.13.0]
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:243) ~[libthrift-0.13.0.jar:0.13.0]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77) ~[libthrift-0.13.0.jar:0.13.0]
at com.starrocks.thrift.FrontendService$Client.recv_forward(FrontendService.java:444) ~[starrocks-fe.jar:?]
at com.starrocks.thrift.FrontendService$Client.forward(FrontendService.java:431) ~[starrocks-fe.jar:?]
at com.starrocks.qe.MasterOpExecutor.lambda$forward$0(MasterOpExecutor.java:138) ~[starrocks-fe.jar:?]
at com.starrocks.rpc.FrontendServiceProxy.call(FrontendServiceProxy.java:25) ~[starrocks-fe.jar:?]
at com.starrocks.qe.MasterOpExecutor.forward(MasterOpExecutor.java:135) ~[starrocks-fe.jar:?]
at com.starrocks.qe.MasterOpExecutor.execute(MasterOpExecutor.java:73) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.forwardToMaster(StmtExecutor.java:566) ~[starrocks-fe.jar:?]
at com.starrocks.qe.StmtExecutor.execute(StmtExecutor.java:365) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.handleQuery(ConnectProcessor.java:322) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.dispatch(ConnectProcessor.java:440) ~[starrocks-fe.jar:?]
at com.starrocks.qe.ConnectProcessor.processOnce(ConnectProcessor.java:676) ~[starrocks-fe.jar:?]
at com.starrocks.mysql.nio.ReadListener.lambda$handleEvent$0(ReadListener.java:55) ~[starrocks-fe.jar:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_332]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_332]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_332]

补充日志


be.out:


同时在be节点执行 java -version
javac 都能正常

换成oracle JDK

是因为 使用了openJdk的问题吗?

另外JAVA_HOME也配置一下

换成 oracle jdk 设置好JAVA_HOME 就ok了
不能使用openjdk
谢啦谢啦