This is an automated email from the ASF dual-hosted git repository.

linxinyuan pushed a commit to branch xinyuan-source-port
in repository https://gitbox.apache.org/repos/asf/texera.git


The following commit(s) were added to refs/heads/xinyuan-source-port by this 
push:
     new 9a7e09d7f6 update
9a7e09d7f6 is described below

commit 9a7e09d7f6e4c0783abfbd07072e9c7bcd919c68
Author: Xinyuan Lin <[email protected]>
AuthorDate: Thu Apr 9 18:14:48 2026 -0700

    update
---
 .../dataset/DatasetSelectorSourceOpExec.scala      | 27 +---------------------
 .../dataset-version-selector.component.html        |  6 -----
 2 files changed, 1 insertion(+), 32 deletions(-)

diff --git 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/dataset/DatasetSelectorSourceOpExec.scala
 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/dataset/DatasetSelectorSourceOpExec.scala
index ac6515b376..6cb426f3a2 100644
--- 
a/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/dataset/DatasetSelectorSourceOpExec.scala
+++ 
b/common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/source/dataset/DatasetSelectorSourceOpExec.scala
@@ -44,21 +44,7 @@ class DatasetSelectorSourceOpExec private[dataset] 
(descString: String) extends
 }
 
 object DatasetSelectorSourceOpExec {
-  def parseDatasetVersionPath(path: String): (String, String, String) = {
-    val parts = Option(path)
-      .map(_.trim)
-      .getOrElse("")
-      .split("/")
-      .filter(_.nonEmpty)
 
-    if (parts.length != 3) {
-      throw new IllegalArgumentException(
-        "Dataset version path must be in the format 
/ownerEmail/datasetName/versionName."
-      )
-    }
-
-    (parts(0), parts(1), parts(2))
-  }
 
   private def isRealFile(obj: ObjectStats): Boolean = {
     val path = Option(obj.getPath).getOrElse("").trim
@@ -66,7 +52,7 @@ object DatasetSelectorSourceOpExec {
   }
 
   def listFileNames(datasetVersionPath: String): Seq[String] = {
-    val (ownerEmail, datasetName, versionName) = 
parseDatasetVersionPath(datasetVersionPath)
+    val Array(ownerEmail, datasetName, versionName) = 
datasetVersionPath.trim.split("/")
     val (dataset, datasetVersion) = resolveDatasetVersion(ownerEmail, 
datasetName, versionName)
     val versionPrefix = s"/$ownerEmail/$datasetName/$versionName"
     LakeFSStorageClient
@@ -93,11 +79,6 @@ object DatasetSelectorSourceOpExec {
         .and(DATASET.NAME.eq(datasetName))
         .fetchOneInto(classOf[Dataset])
 
-      if (dataset == null) {
-        throw new IllegalArgumentException(
-          s"Dataset '$datasetName' owned by '$ownerEmail' was not found."
-        )
-      }
 
       val datasetVersion = ctx
         .selectFrom(DATASET_VERSION)
@@ -105,12 +86,6 @@ object DatasetSelectorSourceOpExec {
         .and(DATASET_VERSION.NAME.eq(versionName))
         .fetchOneInto(classOf[DatasetVersion])
 
-      if (datasetVersion == null) {
-        throw new IllegalArgumentException(
-          s"Dataset version '$versionName' for dataset '$datasetName' was not 
found."
-        )
-      }
-
       (dataset, datasetVersion)
     }
 }
diff --git 
a/frontend/src/app/workspace/component/dataset-version-selector/dataset-version-selector.component.html
 
b/frontend/src/app/workspace/component/dataset-version-selector/dataset-version-selector.component.html
index 27aa4b2530..ae4152d230 100644
--- 
a/frontend/src/app/workspace/component/dataset-version-selector/dataset-version-selector.component.html
+++ 
b/frontend/src/app/workspace/component/dataset-version-selector/dataset-version-selector.component.html
@@ -48,12 +48,6 @@
       [nzLabel]="version.name">
     </nz-option>
   </nz-select>
-
-  <input
-    nz-input
-    [readOnly]="true"
-    [value]="formControl.value || ''"
-    [formlyAttributes]="field" />
 </div>
 
 <div

Reply via email to