๐๐ฎ๐๐ฎ, ๐๐ป๐ฎ๐น๐๐๐ถ๐ฐ๐ & ๐๐. Modern alternative to Snowflake. Cost-effective and simple for massive-scale analytics. https://databend.com
Replaces tokio::sync::Notify with WatchNotify which is safe to nofity_one before Notified future has been polled, otherwise, we risk not being able to release the lock in time.
Tests
[x] Unit Test
[ ] Logic Test
[ ] Benchmark Test
[ ] No Test - Explain why
Type of change
[x] Bug Fix (non-breaking change which fixes an issue)
[ ] New Feature (non-breaking change which adds functionality)
[ ] Breaking Change (fix or feature that could cause existing functionality not to work as expected)
The system has been made more efficient by setting a limit to the number of concurrent queries through a max_running_queries parameter.
The logging level has been changed to INFO for databend-query-node-1, reducing the amount of log data produced during normal operations.
Enhancement in Notification Methods:
A new method named notify_one() has been introduced that enhances the system's capability to send notifications.
Addition of Test for New Method:
A test named test_notify_one() has been added to ensure the correct functionality of the newly introduced notification method.
Improved LockHolder Notifications:
The LockHolder structure utilization has been improved by replacing the old notification type with the new WatchNotify type, increasing efficiency and notifications abilities of the system.
I hereby agree to the terms of the CLA available at: https://docs.databend.com/dev/policies/cla/
Summary
Replaces
tokio::sync::Notify
withWatchNotify
which is safe tonofity_one
beforeNotified
future has been polled, otherwise, we risk not being able to release the lock in time.Tests
Type of change
This change isโ