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