compile

Author: morningman

fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/source/JdbcScanNode.java

@@ -92,7 +92,8 @@ public class JdbcScanNode extends FileQueryScanNode {
     private long catalogId;
 
     public JdbcScanNode(PlanNodeId id, TupleDescriptor desc, boolean isJdbcExternalTable, ScanContext scanContext) {
-        super(id, desc, "JdbcScanNode", scanContext, false);
+        super(id, desc, "JdbcScanNode", scanContext, false,
+                ConnectContext.get() != null ? ConnectContext.get().getSessionVariable() : new SessionVariable());
         if (isJdbcExternalTable) {
             JdbcExternalTable jdbcExternalTable = (JdbcExternalTable) (desc.getTable());
             tbl = jdbcExternalTable.getJdbcTable();
@@ -105,7 +106,8 @@ public JdbcScanNode(PlanNodeId id, TupleDescriptor desc, boolean isJdbcExternalT
 
     public JdbcScanNode(PlanNodeId id, TupleDescriptor desc, boolean isTableValuedFunction, String query,
             ScanContext scanContext) {
-        super(id, desc, "JdbcScanNode", scanContext, false);
+        super(id, desc, "JdbcScanNode", scanContext, false,
+                ConnectContext.get() != null ? ConnectContext.get().getSessionVariable() : new SessionVariable());
         this.isTableValuedFunction = isTableValuedFunction;
         this.query = query;
         tbl = (JdbcTable) desc.getTable();