This is an automated email from the ASF dual-hosted git repository.
caiconghui pushed a commit to branch branch-2.1-lakehouse
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1-lakehouse by this
push:
new fe8abce4c62 [fix](jdbc catalog): Fix query for different catalog
(#59376)
fe8abce4c62 is described below
commit fe8abce4c62fa892a5ce2b7f3e120818a30b5031
Author: XnY-wei <[email protected]>
AuthorDate: Fri Dec 26 11:25:21 2025 +0800
[fix](jdbc catalog): Fix query for different catalog (#59376)
---
.../org/apache/doris/tablefunction/JdbcQueryTableValueFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/JdbcQueryTableValueFunction.java
b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/JdbcQueryTableValueFunction.java
index a9847c7eadd..bdc78ef33bd 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/JdbcQueryTableValueFunction.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/JdbcQueryTableValueFunction.java
@@ -50,7 +50,7 @@ public class JdbcQueryTableValueFunction extends
QueryTableValueFunction {
@Override
public ScanNode getScanNode(PlanNodeId id, TupleDescriptor desc,
SessionVariable sv) {
JdbcExternalCatalog catalog = (JdbcExternalCatalog) catalogIf;
- JdbcTable jdbcTable = new JdbcTable(1, desc.getTable().getName(),
desc.getTable().getFullSchema(),
+ JdbcTable jdbcTable = new JdbcTable(desc.getId().asInt(),
desc.getTable().getName(), desc.getTable().getFullSchema(),
TableType.JDBC);
catalog.configureJdbcTable(jdbcTable, desc.getTable().getName());
desc.setTable(jdbcTable);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
