Merge pull request #1619 from byzer-org/master

fix variable with session scope fails when visibility is not set
byzer-org · Dec 14, 2021 · 31c132e · 31c132e
2 parents d6a5305 + 19c0ae2
commit 31c132e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streamingpro-core/src/main/java/streaming/dsl/ScriptSQLExec.scala b/streamingpro-core/src/main/java/streaming/dsl/ScriptSQLExec.scala
@@ -221,7 +221,7 @@ class ScriptSQLExecListener(val _sparkSession: SparkSession, val _defaultPathPre
       case Some(items) =>
         items.collect().foreach { item =>
           addEnv(item.k, item.v)
-          addEnvVisibility(item.k, SetVisibilityParameter(item.v, getVisibility(item.config("visibility"))))
+          addEnvVisibility(item.k, SetVisibilityParameter(item.v, getVisibility(item.config.getOrElse("visibility","all"))))
         }
       case None =>
     }