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

jxue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/helix.git


The following commit(s) were added to refs/heads/master by this push:
     new 4b180a555 Fix the ToT broken build (#2570)
4b180a555 is described below

commit 4b180a55590a5ee5e105a116d00a7b5c7421a7d9
Author: Komal Desai <[email protected]>
AuthorDate: Fri Jul 21 15:14:18 2023 -0700

    Fix the ToT broken build (#2570)
---
 .../src/main/java/org/apache/helix/task/Workflow.java       | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/helix-core/src/main/java/org/apache/helix/task/Workflow.java 
b/helix-core/src/main/java/org/apache/helix/task/Workflow.java
index bdb88e7a4..05fb982ac 100644
--- a/helix-core/src/main/java/org/apache/helix/task/Workflow.java
+++ b/helix-core/src/main/java/org/apache/helix/task/Workflow.java
@@ -35,8 +35,11 @@ import java.util.TreeMap;
 import org.apache.helix.HelixException;
 import org.apache.helix.task.beans.JobBean;
 import org.apache.helix.task.beans.WorkflowBean;
+import org.yaml.snakeyaml.LoaderOptions;
 import org.yaml.snakeyaml.Yaml;
 import org.yaml.snakeyaml.constructor.Constructor;
+import org.yaml.snakeyaml.inspector.TagInspector;
+import org.yaml.snakeyaml.nodes.Tag;
 
 /**
  * Houses a job dag and config set to fully describe a job workflow
@@ -137,7 +140,15 @@ public class Workflow {
    * Helper function to parse workflow from a generic {@link Reader}
    */
   private static Workflow parse(Reader reader) throws Exception {
-    Yaml yaml = new Yaml(new Constructor(WorkflowBean.class));
+    LoaderOptions options = new LoaderOptions();
+    TagInspector tagInspector = new TagInspector() {
+      @Override
+      public boolean isGlobalTagAllowed(Tag tag) {
+        return false;
+      }
+    };
+    options.setTagInspector(tagInspector);
+    Yaml yaml = new Yaml(new Constructor(WorkflowBean.class, options));
     WorkflowBean wf = (WorkflowBean) yaml.load(reader);
     Builder workflowBuilder = new Builder(wf.name);
 

Reply via email to