lucene-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "JohnWu (JIRA)" <j...@apache.org>
Subject [jira] Commented: (SOLR-1395) Integrate Katta
Date Thu, 04 Nov 2010 08:31:44 GMT

    [ 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: dev-unsubscribe@lucene.apache.org
For additional commands, e-mail: dev-help@lucene.apache.org


Mime
View raw message