Skip to content

Commit

Permalink
Fix view result (#3176)
Browse files Browse the repository at this point in the history
This PR fixes an issue where operators marked for viewing results did
not display the expected results due to a mismatch caused by
string-based comparison instead of using operator identities. By
updating the matching logic to rely on operator identities, this change
ensures accurate identification of marked operators and correct display
of their results.
  • Loading branch information
Yicong-Huang authored Dec 27, 2024
1 parent 8a97cbb commit 5267fec
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ class WorkflowCompiler(
errorList: Option[ArrayBuffer[(OperatorIdentity, Throwable)]]
): PhysicalPlan = {
val terminalLogicalOps = logicalPlan.getTerminalOperatorIds
val toAddSink = (terminalLogicalOps ++ logicalOpsToViewResult).toSet
val toAddSink = (terminalLogicalOps ++ logicalOpsToViewResult.map(OperatorIdentity(_))).toSet
var physicalPlan = PhysicalPlan(operators = Set.empty, links = Set.empty)
// create a JSON object that holds pointers to the workflow's results in Mongo
val resultsJSON = objectMapper.createObjectNode()
Expand Down

0 comments on commit 5267fec

Please sign in to comment.