當前節點可直接通過OSS REF的方式引用OSS資源，在運行EMR節點時，DataWorks會自動加載代碼中的OSS資源至本地使用。該方式常用于“需要在EMR任務中運行JAR依賴”、“EMR任務需依賴腳本”等場景。

1. 開發JAR資源。

   1. 代碼依賴準備。

      您可前往EMR集群，在集群master節點的/usr/lib/emr/spark-current/jars/路徑下查看您所需的代碼依賴。下面以Spark3.4.2版本為例，您需在打開已創建的IDEA項目添加pom依賴并引用相關插件。

      添加pom依賴

      <dependencies>
              <dependency>
                  <groupId>org.apache.spark</groupId>
                  <artifactId>spark-core_2.12</artifactId>
                  <version>3.4.2</version>
              </dependency>
              <!-- Apache Spark SQL -->
              <dependency>
                  <groupId>org.apache.spark</groupId>
                  <artifactId>spark-sql_2.12</artifactId>
                  <version>3.4.2</version>
              </dependency>
      </dependencies>

      引用相關插件

      <build>
              <sourceDirectory>src/main/scala</sourceDirectory>
              <testSourceDirectory>src/test/scala</testSourceDirectory>
              <plugins>
                  <plugin>
                      <groupId>org.apache.maven.plugins</groupId>
                      <artifactId>maven-compiler-plugin</artifactId>
                      <version>3.7.0</version>
                      <configuration>
                          <source>1.8</source>
                          <target>1.8</target>
                      </configuration>
                  </plugin>
                  <plugin>
                      <artifactId>maven-assembly-plugin</artifactId>
                      <configuration>
                          <descriptorRefs>
                              <descriptorRef>jar-with-dependencies</descriptorRef>
                          </descriptorRefs>
                      </configuration>
                      <executions>
                          <execution>
                              <id>make-assembly</id>
                              <phase>package</phase>
                              <goals>
                                  <goal>single</goal>
                              </goals>
                          </execution>
                      </executions>
                  </plugin>
                  <plugin>
                      <groupId>net.alchim31.maven</groupId>
                      <artifactId>scala-maven-plugin</artifactId>
                      <version>3.2.2</version>
                      <configuration>
                          <recompileMode>incremental</recompileMode>
                      </configuration>
                      <executions>
                          <execution>
                              <goals>
                                  <goal>compile</goal>
                                  <goal>testCompile</goal>
                              </goals>
                              <configuration>
                                  <args>
                                      <arg>-dependencyfile</arg>
                                      <arg>${project.build.directory}/.scala_dependencies</arg>
                                  </args>
                              </configuration>
                          </execution>
                      </executions>
                  </plugin>
              </plugins>
          </build>

   2. 編寫代碼示例。

      package com.aliyun.emr.example.spark
      
      import org.apache.spark.sql.SparkSession
      
      object SparkMaxComputeDemo {
        def main(args: Array[String]): Unit = {
          // 創建 SparkSession
          val spark = SparkSession.builder()
            .appName("HelloDataWorks")
            .getOrCreate()
      
          // 打印Spark版本
          println(s"Spark version: ${spark.version}")
        }
      }

   3. 將代碼打包成JAR文件。

      編輯保存Scala代碼后，將Scala代碼打包成JAR文件。示例生成的JAR包為SparkWorkOSS-1.0-SNAPSHOT-jar-with-dependencies.jar。

2. 上傳JAR資源。

   1. 完成代碼開發后，您需登錄OSS管理控制臺，單擊所在地域左側導航欄的Bucket列表。

   2. 單擊目標Bucket名稱，進入文件管理頁面。

      本文示例使用的Bucket為onaliyun-bucket-2。

   3. 單擊新建目錄，創建JAR資源的存放目錄。

      配置目錄名為emr/jars，創建JAR資源的存放目錄。

   4. 上傳JAR資源至JAR資源的存放目錄。

      進入存放目錄，單擊上傳文件，在待上傳文件區域單擊掃描文件，添加SparkWorkOSS-1.0-SNAPSHOT-jar-with-dependencies.jar文件至Bucket，單擊上傳文件。

3. 引用JAR資源。

   1. 編輯引用JAR資源代碼。

      在已創建的EMR Spark節點編輯頁面，編輯引用JAR資源代碼。

      spark-submit --class com.aliyun.emr.example.spark.SparkMaxComputeDemo --master yarn ossref://onaliyun-bucket-2/emr/jars/SparkWorkOSS-1.0-SNAPSHOT-jar-with-dependencies.jar

      引用參數說明：

      參數	參數說明
      class	運行的主類全名稱。
      master	Spark應用程序的運行模式。
      ossref文件路徑	格式為ossref://{endpoint}/{bucket}/{object} endpoint：OSS對外服務的訪問域名。Endpoint為空時，僅支持使用與當前訪問的EMR集群同地域的OSS，即OSS的Bucket需要與EMR集群所在地域相同。 Bucket：OSS用于存儲對象的容器，每一個Bucket有唯一的名稱，登錄OSS管理控制臺，可查看當前登錄賬號下所有Bucket。 object：存儲在Bucket中的一個具體的對象（文件名稱或路徑）。

   2. 運行EMR Spark節點任務。

      編輯完成后您可單擊圖標，選擇您所創建的Serverless資源組運行EMR Spark節點。待任務執行完成后，記錄控制臺打印的applicationIds，例如application_1730367929285_xxxx。

   3. 結果查看。

      創建EMR Shell節點并在EMR Shell節點執行yarn logs -applicationId application_1730367929285_xxxx命令查看運行結果：