We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
Now, we don't have the resource manager on queue level. like yarn queue. when submit job we will send job to all worker if avaliable.
queue
I check the code, find we can add some tag to hazelcast node, then when we assign task, we can use this tag to choose node.
tag
Here are some code need to update: 1.SeaTunnelServer then create node, add tag
SeaTunnelServer
DefaultSlotService when create slot profile, read tag.
DefaultSlotService
AbstractResourceManager when assign task to worker, use tag to choose
AbstractResourceManager
No response
The text was updated successfully, but these errors were encountered:
great!!!
Sorry, something went wrong.
liunaijie
Successfully merging a pull request may close this issue.
Search before asking
Description
Now, we don't have the resource manager on queue level. like yarn
queue
. when submit job we will send job to all worker if avaliable.I check the code, find we can add some
tag
to hazelcast node, then when we assign task, we can use this tag to choose node.Here are some code need to update:
![image](https://private-user-images.githubusercontent.com/28497357/341608151-3acb1621-c8e1-42e6-b59c-0d36ae502dba.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3MTk2MDE4OTIsIm5iZiI6MTcxOTYwMTU5MiwicGF0aCI6Ii8yODQ5NzM1Ny8zNDE2MDgxNTEtM2FjYjE2MjEtYzhlMS00MmU2LWI1OWMtMGQzNmFlNTAyZGJhLnBuZz9YLUFtei1BbGdvcml0aG09QVdTNC1ITUFDLVNIQTI1NiZYLUFtei1DcmVkZW50aWFsPUFLSUFWQ09EWUxTQTUzUFFLNFpBJTJGMjAyNDA2MjglMkZ1cy1lYXN0LTElMkZzMyUyRmF3czRfcmVxdWVzdCZYLUFtei1EYXRlPTIwMjQwNjI4VDE5MDYzMlomWC1BbXotRXhwaXJlcz0zMDAmWC1BbXotU2lnbmF0dXJlPTc5ZWVlZmM1NzY5M2UyZWIzZTg3NGYwNTc3MGJkMGNkNzQ2ZDJiNGE4Yzk5Y2Y1Nzg5ZDFhOWZjZTIyNDdjZmUmWC1BbXotU2lnbmVkSGVhZGVycz1ob3N0JmFjdG9yX2lkPTAma2V5X2lkPTAmcmVwb19pZD0wIn0.vKveDb3X0CyLozQvEthxZVsDnpcUUoAHaKiZIlRwW10)
1.
SeaTunnelServer
then create node, add tagDefaultSlotService
when create slot profile, read tag.AbstractResourceManager
when assign task to worker, use tag to chooseUsage Scenario
No response
Related issues
No response
Are you willing to submit a PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: