[
https://issues.apache.org/jira/browse/SOLR-1395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=12928160#action_12928160
]
JohnWu commented on SOLR-1395:
------------------------------
TomLiu:
I correct the code ater patched:
correct the codeļ¼
1)package org.apache.solr.client.solrj.request-> QueryRequest ->query (filed):
protected SolrParams query;
2)package org.apache.solr.handler.component->SearchHandler->Submit (method):
void submit(final ShardRequest sreq, final String shard, final
ModifiableSolrParams params) {
Callable<ShardResponse> task = new Callable<ShardResponse>() {
public ShardResponse call() throws Exception {
ShardResponse srsp = new ShardResponse();
srsp.setShardRequest(sreq);
srsp.setShard(shard);
SimpleSolrResponse ssr = new SimpleSolrResponse();
srsp.setSolrResponse(ssr);
long startTime = System.currentTimeMillis();
try {
// String url = "http://"; + shard + "/select";
String url = SearchHandler.scheme + shard;
params.remove(CommonParams.WT); // use default (currently
javabin)
params.remove(CommonParams.VERSION);
SolrServer server = new CommonsHttpSolrServer(url, client);
// SolrRequest req = new
QueryRequest(SolrRequest.METHOD.POST, "/select");
// use generic request to avoid extra processing of queries
QueryRequest req = new QueryRequest(params);
req.setMethod(SolrRequest.METHOD.POST);
// no need to set the response parser as binary is the
default
// req.setResponseParser(new BinaryResponseParser());
// srsp.rsp = server.request(req);
// srsp.rsp = server.query(sreq.params);
ssr.nl = server.request(req);
} catch (Throwable th) {
srsp.setException(th);
if (th instanceof SolrException) {
srsp.setResponseCode(((SolrException)th).code());
} else {
srsp.setResponseCode(-1);
}
}
ssr.elapsedTime = System.currentTimeMillis() - startTime;
return srsp;
}
};
pending.add( completionService.submit(task) );
}
After
ant compile
in Solr/dist:
apache-solr-4.0-SNAPSHOT.war
apache-solr-dataimporthandler-4.0-SNAPSHOT.jar
apache-solr-analysis-extras-4.0-SNAPSHOT.jar
apache-solr-dataimporthandler-extras-4.0-SNAPSHOT.jar
apache-solr-cell-4.0-SNAPSHOT.jar apache-solr-solrj-4.0-SNAPSHOT.jar
apache-solr-clustering-4.0-SNAPSHOT.jar solrj-lib
apache-solr-core-4.0-SNAPSHOT.jar
now I forget the which patch crate a katta and katta proxy folder in example:
drwxrwxr-x 3 hadoop hadoop 4096 Nov 3 22:53 kattaproxy
drwxrwxr-x 3 hadoop hadoop 4096 Nov 3 22:53 katta
drwxrwxr-x 3 hadoop hadoop 4096 Oct 16 03:28 exampledocs
drwxrwxr-x 5 hadoop hadoop 4096 Oct 16 03:31 example-DIH
which folder for katta ? how to set the SolrKattaServer in core container?
There are some test program, which can to refer?
Thanks for your help!
> Integrate Katta
> ---------------
>
> Key: SOLR-1395
> URL: https://issues.apache.org/jira/browse/SOLR-1395
> Project: Solr
> Issue Type: New Feature
> Affects Versions: 1.4
> Reporter: Jason Rutherglen
> Priority: Minor
> Fix For: Next
>
> Attachments: back-end.log, front-end.log, hadoop-core-0.19.0.jar,
> katta-core-0.6-dev.jar, katta.node.properties, katta.zk.properties,
> log4j-1.2.13.jar, solr-1395-1431-3.patch, solr-1395-1431-4.patch,
> solr-1395-1431-katta0.6.patch, solr-1395-1431-katta0.6.patch,
> solr-1395-1431.patch, solr-1395-katta-0.6.2-1.patch,
> solr-1395-katta-0.6.2-2.patch, solr-1395-katta-0.6.2.patch, SOLR-1395.patch,
> SOLR-1395.patch, SOLR-1395.patch, test-katta-core-0.6-dev.jar,
> zkclient-0.1-dev.jar, zookeeper-3.2.1.jar
>
> Original Estimate: 336h
> Remaining Estimate: 336h
>
> We'll integrate Katta into Solr so that:
> * Distributed search uses Hadoop RPC
> * Shard/SolrCore distribution and management
> * Zookeeper based failover
> * Indexes may be built using Hadoop
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
