3.3.11和3.4.1读取paimon表结构报错

【详述】
【背景】从 3.4.0 升级到 3.4.1 或降级到 3.3.11
【业务影响】flink 使用 alter table 命令给表增加列,starrocks 无法反应 paimon 表结构变化,无法查询新的列
【是否存算分离】否
【StarRocks版本】3.3.11和3.4.1
【集群规模】例如:3fe(1 follower+2observer)+3be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡 48C/64G/万兆
【附件】

  • fe.log
    2025-03-13 13:34:08.054+08:00 ERROR (starrocks-mysql-nio-pool-16|1540) [PaimonMetadata.getTableCreateTime():365] Failed to get update_time of paimon table raw_data.xxxx.
    java.lang.ClassCastException: class java.lang.Integer cannot be cast to class java.lang.Long (java.lang.Integer and java.lang.Long are in module java.base of loader ‘bootstrap’)
    at org.apache.paimon.table.system.SchemasTable$SchemasRead.handleLeafPredicate(SchemasTable.java:215) ~[paimon-bundle-1.0.1.jar:1.0.1]
    at org.apache.paimon.table.system.SchemasTable$SchemasRead.withFilter(SchemasTable.java:204) ~[paimon-bundle-1.0.1.jar:1.0.1]
    at org.apache.paimon.table.source.ReadBuilderImpl.newRead(ReadBuilderImpl.java:175) ~[paimon-bundle-1.0.1.jar:1.0.1]
    at com.starrocks.connector.paimon.PaimonMetadata.getTableCreateTime(PaimonMetadata.java:353) ~[starrocks-fe.jar:?]
    at com.starrocks.connector.paimon.PaimonMetadata.getTable(PaimonMetadata.java:228) ~[starrocks-fe.jar:?]
    at com.starrocks.connector.CatalogConnectorMetadata.getTable(CatalogConnectorMetadata.java:150) ~[starrocks-fe.jar:?]
    at com.starrocks.server.MetadataMgr.lambda$getTable$5(MetadataMgr.java:511) ~[starrocks-fe.jar:?]
    at java.util.Optional.map(Optional.java:260) ~[?:?]
    at com.starrocks.server.MetadataMgr.getTable(MetadataMgr.java:511) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer.resolveTable(QueryAnalyzer.java:1426) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.resolveTableRef(QueryAnalyzer.java:492) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitSelect(QueryAnalyzer.java:366) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitSelect(QueryAnalyzer.java:286) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.ast.SelectRelation.accept(SelectRelation.java:232) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.process(QueryAnalyzer.java:291) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.analyzeSetOperation(QueryAnalyzer.java:1077) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitUnion(QueryAnalyzer.java:1055) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitUnion(QueryAnalyzer.java:286) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.ast.UnionRelation.accept(UnionRelation.java:31) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.process(QueryAnalyzer.java:291) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitQueryRelation(QueryAnalyzer.java:306) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitQueryStatement(QueryAnalyzer.java:296) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.visitQueryStatement(QueryAnalyzer.java:286) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.ast.QueryStatement.accept(QueryStatement.java:72) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer$Visitor.process(QueryAnalyzer.java:291) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.QueryAnalyzer.analyze(QueryAnalyzer.java:128) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.ExpressionAnalyzer$Visitor.visitSubquery(ExpressionAnalyzer.java:1378) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.ExpressionAnalyzer$Visitor.visitSubquery(ExpressionAnalyzer.java:376) ~[starrocks-fe.jar:?]
    at com.starrocks.analysis.Subquery.accept(Subquery.java:134) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.ast.AstVisitor.visit(AstVisitor.java:84) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.ExpressionAnalyzer.bottomUpAnalyze(ExpressionAnalyzer.java:372) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.ExpressionAnalyzer.bottomUpAnalyze(ExpressionAnalyzer.java:370) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.ExpressionAnalyzer.bottomUpAnalyze(ExpressionAnalyzer.java:370) ~[starrocks-fe.jar:?]
    at com.starrocks.sql.analyzer.ExpressionAnalyzer.bottomUpAnalyze(ExpressionAnalyzer.java:370) ~[starrocks-fe.jar:?]