[jira] Commented: (SOLR-1395) Integrate Katta

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] Commented: (SOLR-1395) Integrate Katta

Tim Allison (Jira)

    [ 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: [hidden email]
For additional commands, e-mail: [hidden email]