UBI goes distrib #11
UBI goes distrib #11
Conversation
Pardon, I barely understand what's going on there.
|
|
||
| // ------------------- | ||
|
|
||
| CollectionAdminRequest.createCollection("ubi_queries", "_default", 1, 1) |
There was a problem hiding this comment.
@epugh I noticed that UBI comp yields a kind of stream into ubi_queries. Should we create such collection before issuing queries?
|
UBIComponentDistrQueriesTest fails with and it doesn't seem specific to UBI. I'm stuck. Don't know how to get through it. okay. I've figured it out https://github.com/apache/solr/pull/2452/files#r1875035115 |
| assertTrue(qid.length()>10); | ||
| Thread.sleep(10000); // I know what you think of | ||
| // TODO check that ids were recorded | ||
| QueryResponse queryCheck = cluster.getSolrClient("ubi_queries").query(new MapSolrParams( |
There was a problem hiding this comment.
@epugh do you have an idea how to wait till update stream have landed to ubi_queries?
There was a problem hiding this comment.
hummm.... so, I think that in the UBIComponent when we call getTuples, there is a chance that it waits till we finish that step? You are using the configset that wraps the update() with an explicit commit(), which you woudn't do in a prod setup, just so we can see the new docs:
I looked at some tests like https://github.com/apache/solr/blob/main/solr/solrj-streaming/src/test/org/apache/solr/client/solrj/io/stream/StreamDecoratorTest.java#L364 and they are why I believe it is actually a synchornous process, not a back ground process...
|
Would it be useful to add you to the |
nope. I can push into apache#2452 as a maintainer. |
|
Merged! and please do continue! this is super great to have a collaborator! |
This what I understand about distributed Solr.