-
Notifications
You must be signed in to change notification settings - Fork 3.7k
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
Fix loading lookup extension #17212
Fix loading lookup extension #17212
Conversation
2ecfa47
to
d9e4cd9
Compare
@cryptoe @LakshSingla @kfaraz Can you guys take a quick look at this? |
d9e4cd9
to
4339c87
Compare
@abhishekrb19 can you please re-run the pipeline one more time? |
...s-core/lookups-cached-single/src/main/java/org/apache/druid/server/lookup/LoadingLookup.java
Outdated
Show resolved
Hide resolved
...s-core/lookups-cached-single/src/main/java/org/apache/druid/server/lookup/LoadingLookup.java
Outdated
Show resolved
Hide resolved
...s-core/lookups-cached-single/src/main/java/org/apache/druid/server/lookup/LoadingLookup.java
Show resolved
Hide resolved
4339c87
to
c8772ae
Compare
@Akshat-Jain thanks for the review! PR updated, can you give it one more round? |
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.
Some minor comments
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Show resolved
Hide resolved
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Outdated
Show resolved
Hide resolved
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Show resolved
Hide resolved
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Outdated
Show resolved
Hide resolved
...s-core/lookups-cached-single/src/main/java/org/apache/druid/server/lookup/LoadingLookup.java
Outdated
Show resolved
Hide resolved
Signed-off-by: TessaIO <[email protected]>
c8772ae
to
9e1c412
Compare
@Akshat-Jain @abhishekrb19 Thanks for the review. One more round please. |
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.
@TessaIO a final set of comments. Looks good otherwise, thanks!
Also, we don't typically force push changes to make reviewing easier. The commits will be squashed and merged as one when committing to master.
...s-core/lookups-cached-single/src/main/java/org/apache/druid/server/lookup/LoadingLookup.java
Outdated
Show resolved
Hide resolved
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Outdated
Show resolved
Hide resolved
...s-core/lookups-cached-single/src/main/java/org/apache/druid/server/lookup/LoadingLookup.java
Outdated
Show resolved
Hide resolved
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Outdated
Show resolved
Hide resolved
...re/lookups-cached-single/src/test/java/org/apache/druid/server/lookup/LoadingLookupTest.java
Outdated
Show resolved
Hide resolved
Signed-off-by: TessaIO <[email protected]>
@abhishekrb19 PR updated! |
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.
Thanks for the PR and for addressing all the review comments!
Looks good to me! :)
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.
Thanks for your first contribution @TessaIO, and thanks to @Akshat-Jain for the in-depth review!
@TessaIO, do you mind merging the latest master into this branch to get a clean CI run? I can commit this change after that.
…ading-lookup-extension
@abhishekrb19 done |
Resolves #17337.
Description
This PR aims to change the behavior of the druid lookups-cached-single extension. In fact, we aim to introduce the option to iterate over fetched data from the dataFetcher. We need this in the case of loadingLookups, that's why these changes don't impact the pollingLookup feature.
I also added the handling of a use case where the data exists in Druid but not in the actual data fetcher, which is in our use-case JDBC Data fetcher.
Release note
Key changed/added classes in this PR
Support iterating over fetched data for the loadinglookups for the druid lookups-cached-single extension
This PR has: