diff --git a/package/scripts/impala-state-store.py b/package/scripts/impala-state-store.py
index c3f3760..44e57ac 100644
--- a/package/scripts/impala-state-store.py
+++ b/package/scripts/impala-state-store.py
@@ -35,7 +35,7 @@ def start(self, env):
         import params
         self.configure(env)
 
-        self.create_hdfs_user(params.flink_user)
+        self.create_hdfs_user(params.impala_user)
         cmd = 'service impala-state-store start'
         Execute('echo "Running cmd: ' + cmd + '"')
         Execute(cmd)
@@ -58,4 +58,4 @@ def create_hdfs_user(self, user):
         Execute('hadoop fs -chgrp ' + user + ' /user/'+user, user='hdfs')
 
 if __name__ == "__main__":
-    StateStore().execute()
\ No newline at end of file
+    StateStore().execute()