-
Notifications
You must be signed in to change notification settings - Fork 5k
[1.3.9-prepare]Add standalone server module to make it easier to develop and run #6022 #6480
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
| if(StringUtils.isNotBlank(System.getProperty("zookeeper.quorum"))){ | ||
| return System.getProperty("zookeeper.quorum"); | ||
| } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Avoid modifying too much, do this temporarily and the dev version is OK.
|
@kezhenxu94 hi, can you help me review?thx |
Sure. Will take a look soon. |
|
@CalvinKirs can we just cherry pick the related commits into the target branch? |
|
Standalone server is mostly for convenient development, so I don't know how much it will benefit to cherry pick this to the 1.3.9 release, I think developers often develop on |
It’s very difficult, our branches are quite different 😭 |
I totally agree with you. but the main purpose of doing this is to allow some new users to start easily and quickly. @dailidong |
Now there are many deployment steps for DolphinScheduler, especially for new users, what they want to feel most is to quickly experience whether this can meet his needs and how to quickly experience the functions of DolphinScheduler. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM in terms of standalone server functionalities, I can see this error logs when running a simple shell task, might not be related to this but might be worthy to take a look.
2021-10-12 20:04:02.210 ERROR 76462 --- [ool-13-thread-2] o.a.d.remote.handler.NettyServerHandler : process msg Command [type=TASK_EXECUTE_REQUEST, opaque=3, bodyLen=1510] error
java.lang.NullPointerException: null
at org.apache.dolphinscheduler.server.worker.processor.TaskExecuteProcessor.getTaskLogPath(TaskExecuteProcessor.java:175) ~[classes/:na]
at org.apache.dolphinscheduler.server.worker.processor.TaskExecuteProcessor.process(TaskExecuteProcessor.java:133) ~[classes/:na]
at org.apache.dolphinscheduler.remote.handler.NettyServerHandler$1.run(NettyServerHandler.java:134) ~[classes/:na]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_292]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [na:1.8.0_292]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [na:1.8.0_292]
at java.lang.Thread.run(Thread.java:748) [na:1.8.0_292]
| private int maxWaitTime; | ||
|
|
||
| public String getServerList() { | ||
| if(StringUtils.isNotBlank(System.getProperty("zookeeper.quorum"))){ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Seems it's not formatted
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thx your remind, done
| private static void startAlertServer() { | ||
| AlertServer.getInstance().start(); | ||
| } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you cherry-pick this part from the latest dev branch and uncomment line 61 to enable alert server?
| private static void startAlertServer() { | |
| AlertServer.getInstance().start(); | |
| } | |
| private static void startAlertServer() { | |
| final Path alertPluginPath = Paths.get( | |
| StandaloneServer.class.getProtectionDomain().getCodeSource().getLocation().getPath(), | |
| "../../../dolphinscheduler-alert-plugin/dolphinscheduler-alert-email/pom.xml" | |
| ).toAbsolutePath(); | |
| if (Files.exists(alertPluginPath)) { | |
| System.setProperty("alert.plugin.binding", alertPluginPath.toString()); | |
| System.setProperty("alert.plugin.dir", ""); | |
| } | |
| AlertServer.getInstance().start(); | |
| } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Well, the settings are totally different between this branch and dev branch?
I can see
alert.type=EMAIL
plugin.dir=/Users/xx/your/path/to/plugin/dirvs
alert.plugin.binding=
alert.plugin.dir=There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yup, an Email Alert is that must be loaded. An email will be loaded automatically when AlertServer is started
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
So we don’t need to set up email
|
SonarCloud Quality Gate failed. |
kezhenxu94
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
lenboo
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
+1








No description provided.