From fa5eb7f0427fa372f23ee03b1a8ca4d16eae707a Mon Sep 17 00:00:00 2001
From: Shide Foo <shide.foo@gojek.com>
Date: Thu, 7 Aug 2025 15:06:52 +0800
Subject: [PATCH] Add ExecuteProject parameter in for MaxCompute source

---
 .../caraml/spark/sources/maxCompute/MaxComputeReader.scala  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/caraml-store-spark/src/main/scala/dev/caraml/spark/sources/maxCompute/MaxComputeReader.scala b/caraml-store-spark/src/main/scala/dev/caraml/spark/sources/maxCompute/MaxComputeReader.scala
index 246c09d..19d8919 100644
--- a/caraml-store-spark/src/main/scala/dev/caraml/spark/sources/maxCompute/MaxComputeReader.scala
+++ b/caraml-store-spark/src/main/scala/dev/caraml/spark/sources/maxCompute/MaxComputeReader.scala
@@ -18,17 +18,19 @@ object MaxComputeReader {
   ): DataFrame = {
     val maxComputeAccessID  = sys.env("CARAML_SPARK_MAXCOMPUTE_ACCESS_ID")
     val maxComputeAccessKey = sys.env("CARAML_SPARK_MAXCOMPUTE_ACCESS_KEY")
+    val maxComputeExecuteProject = sys.env("CARAML_SPARK_MAXCOMPUTE_EXECUTE_PROJECT")
 
     val config = maxComputeConfig.getOrElse(MaxComputeConfig())
 
     val maxComputeJDBCConnectionURL =
-      "jdbc:odps:%s/?project=%s&interactiveMode=%s&enableLimit=%s&autoSelectLimit=%s&enableOdpsLogger=true&alwaysFallback=true"
+      "jdbc:odps:%s/?project=%s&interactiveMode=%s&enableLimit=%s&autoSelectLimit=%s&enableOdpsLogger=true&alwaysFallback=true&executeProject=%s"
         .format(
           config.endpoint,
           source.project,
           config.interactiveMode,
           config.enableLimit,
-          config.autoSelectLimit
+          config.autoSelectLimit,
+          maxComputeExecuteProject
         )
 
     val sqlQuery =