Skip to content
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

Orkes queues not perfoming well #4

Open
sks1995 opened this issue Oct 20, 2022 · 3 comments
Open

Orkes queues not perfoming well #4

sks1995 opened this issue Oct 20, 2022 · 3 comments

Comments

@sks1995
Copy link

sks1995 commented Oct 20, 2022

Describe the bug
We are trying to use orkes queues in netflix conductor
As suggested in doc, changed conductor.queue.type=redis_standalone

On comparing it with dyno queues, orkes queues seemed to be under performing.
I am trying to execute 3 tasks sequentially.
Overall time taken by orkes queues is around 3s mostly, while for dyno queues, it is around 1.2s
There is huge delay b/w task being scheduled v/s task moved to in progress.
The worker in running at same frequency in both the cases.

Am I missing any configuration ?
Can both dyno queues and orkes queues dependencies be included together in classpath ?

Expected behavior
Expected orkes queues to be equally/more performant.

Device/browser

  • Redis 7

Additional context
Add any other context about the problem here.

@sks1995
Copy link
Author

sks1995 commented Oct 21, 2022

@v1r3n Can you please assist ? We are in middle of load testing.

@v1r3n
Copy link
Contributor

v1r3n commented Oct 21, 2022

Hi @sks1995 dyno-queues and orkes-queues can be in the same path - should be fine.

I would like to know more about your setup. Can we connect and go over the setup?

@pmchung
Copy link

pmchung commented Oct 30, 2022

I think there are artificial delays added such as, most notably the second snippet:

public final List<String> pop(String queueName, int count, int timeout) {
// Keep the timeout to a minimum of 100ms
if (timeout < 100) {
timeout = 100;
}

private long getQueuedMessagesLen() {
long now = clock.millis();
if (now > nextUpdate) {
size = queueSize();
nextUpdate = now + 1000; // Cache for 1000 ms
}
return size;
}

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants