diff --git a/samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java b/samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java index e3bf633ba2..3cd9e55be0 100644 --- a/samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java +++ b/samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java @@ -62,7 +62,6 @@ class CliEnvironment { * -2: invalid value */ int setEnvironmentVariable(String name, String value) throws ExecutorException{ - name = name.toLowerCase(); if(name.equals(CliConstants.CONFIG_EXECUTOR)) { createShellExecutor(value); activeExecutorClassName = value;