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 ff62a64442 update
ff62a64442 is described below
commit ff62a6444289c42829a533810d78b593f4ccb404
Author: Xinyuan Lin <[email protected]>
AuthorDate: Fri Apr 10 02:01:37 2026 -0700
update
---
.../amber/operator/source/dataset/DatasetSelectorSourceOpExec.scala | 3 +--
1 file changed, 1 insertion(+), 2 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 51da8ffd0b..eee7bc4051 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
@@ -29,8 +29,7 @@ import
org.apache.texera.dao.jooq.generated.tables.DatasetVersion.DATASET_VERSIO
import org.apache.texera.dao.jooq.generated.tables.User.USER
class DatasetSelectorSourceOpExec private[dataset] (descString: String)
extends SourceOperatorExecutor {
- private val desc: DatasetSelectorSourceOpDesc =
- objectMapper.readValue(descString, classOf[DatasetSelectorSourceOpDesc])
+ private val desc: DatasetSelectorSourceOpDesc =
objectMapper.readValue(descString, classOf[DatasetSelectorSourceOpDesc])
override def produceTuple(): Iterator[TupleLike] = {
val Seq(_, ownerEmail, datasetName, versionName) =
