diff --git hplsql/src/main/java/org/apache/hive/hplsql/Udf.java hplsql/src/main/java/org/apache/hive/hplsql/Udf.java index 9c29eeb..b5cc76b 100644 --- hplsql/src/main/java/org/apache/hive/hplsql/Udf.java +++ hplsql/src/main/java/org/apache/hive/hplsql/Udf.java @@ -95,6 +95,11 @@ void setParameters(DeferredObject[] arguments) throws HiveException { else if (argumentsOI[i] instanceof IntObjectInspector) { Integer value = (Integer)((IntObjectInspector)argumentsOI[i]).getPrimitiveJavaObject(arguments[i].get()); if (value != null) { + // By default, exec.currentScope is null. + if (exec.currentScope == null) { + exec.globalScope = new Scope(Scope.Type.GLOBAL); + exec.currentScope = exec.globalScope; + } exec.setVariable(name, new Var(new Long(value))); } }