[X] I had searched in the issues and found no similar issues.
What happened
Traceback (most recent call last):
File "listen-slice-tasks.py", line 100, in <module>
workflow.submit()
File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/core/workflow.py", line 430, in submit
self._ensure_side_model_exists()
File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/core/workflow.py", line 407, in _ensure_side_model_exists
self.user.create_if_not_exists()
File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/models/user.py", line 68, in create_if_not_exists
user = gateway.create_user(
File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/java_gateway.py", line 217, in create_user
return self.gateway.entry_point.createUser(
File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/py4j/java_gateway.py", line 1322, in call
return_value = get_return_value(
File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/py4j/protocol.py", line 326, in get_return_value
raise Py4JJavaError(
py4j.protocol.Py4JJavaError: An error occurred while calling t.createUser.
: ServiceException(code=30001)
at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl.updateUser(UsersServiceImpl.java:405)
at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl.createUserIfNotExists(UsersServiceImpl.java:1325)
at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl$$FastClassBySpringCGLIB$$ac00af33.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123)
at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388)
at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708)
at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl$$EnhancerBySpringCGLIB$$62ef78e4.createUserIfNotExists(<generated>)
at org.apache.dolphinscheduler.api.python.PythonGateway.createUser(PythonGateway.java:475)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
at py4j.Gateway.invoke(Gateway.java:282)
at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
at py4j.commands.CallCommand.execute(CallCommand.java:79)
at py4j.GatewayConnection.run(GatewayConnection.java:238)
at java.base/java.lang.Thread.run(Thread.java:829)
Search before asking
What happened
Traceback (most recent call last): File "listen-slice-tasks.py", line 100, in <module> workflow.submit() File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/core/workflow.py", line 430, in submit self._ensure_side_model_exists() File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/core/workflow.py", line 407, in _ensure_side_model_exists self.user.create_if_not_exists() File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/models/user.py", line 68, in create_if_not_exists user = gateway.create_user( File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/pydolphinscheduler/java_gateway.py", line 217, in create_user return self.gateway.entry_point.createUser( File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/py4j/java_gateway.py", line 1322, in call return_value = get_return_value( File "/home/sumfen/anaconda3/envs/traning/lib/python3.8/site-packages/py4j/protocol.py", line 326, in get_return_value raise Py4JJavaError( py4j.protocol.Py4JJavaError: An error occurred while calling t.createUser. : ServiceException(code=30001) at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl.updateUser(UsersServiceImpl.java:405) at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl.createUserIfNotExists(UsersServiceImpl.java:1325) at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl$$FastClassBySpringCGLIB$$ac00af33.invoke(<generated>) at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:123) at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:388) at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:119) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) at org.apache.dolphinscheduler.api.service.impl.UsersServiceImpl$$EnhancerBySpringCGLIB$$62ef78e4.createUserIfNotExists(<generated>) at org.apache.dolphinscheduler.api.python.PythonGateway.createUser(PythonGateway.java:475) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244) at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357) at py4j.Gateway.invoke(Gateway.java:282) at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132) at py4j.commands.CallCommand.execute(CallCommand.java:79) at py4j.GatewayConnection.run(GatewayConnection.java:238) at java.base/java.lang.Thread.run(Thread.java:829)
What you expected to happen
self.user.create_if_not_exists()
How to reproduce
self.user.create_if_not_exists()
Anything else
No response
Version
dev
Are you willing to submit PR?
Code of Conduct