小编Ali*_*ore的帖子

当我运行jboss-cli.sh时,我收到此消息.

[root bin]# sh jboss-cli.sh 
You are disconnected at the moment. Type 'connect' to connect to the server or 'help' for the list of supported commands.
[disconnected /] connect localhost
The controller is not available at localhost:9999
[disconnected /] connect
The controller is not available at localhost:9999
[disconnected /] connect localhost:9999  
The controller is not available at localhost:9999
[disconnected /] 

我还有另一个jboss5 GA的安装.我希望这不会干扰.虽然现在完全关闭了.

本机管理界面是:standalone.sh中的9999

请注意这个问题.

                                     EDITED 

当我停止使用"service jboss stop"服务时,我收到此消息

[root@ bin]# *** JBossAS process (7302) received KILL signal *** …

我有一个类,它是传入消息的监听器,应该永远存活(以便它可以监听传入的消息),直到我明确断开它的连接.我已将该线程声明为setDaemon(false),但它终止于调用方法终止.

请告诉我如何使该线程保持活跃,并请详细说明如何实现Spring TaskExecutor来实现相同的目标.

提前致谢.它是一个监听器,当有人发送消息时它会收到通知...所以我如何让它保持运行？

听众类

public class MyListnerImpl implements Listener {
    private final connectionImpl con;   

    public MyListnerImpl(ConnectionImpl con) {
    if (con.isAuthenticated() && con.isConnected()) {
        if (logger.isInfoEnabled()) {
            logger.info("Initializing XmppListner:");
        }
        this.itsCon = con;
        Thread t1 = new Thread(this);
        t1.setDaemon(false);
        t1.start();
    }
    }

    public final void listnerInterfaceMethod(final Chat chat, final Message message) {
        System.out.println("Message" + message);
    }

    public final void run() {
    itsCon.getChatManager().addChatListener(new ChatManagerListener() {
        public void chatCreated(final Chat chat, final boolean createdLocally) {
            if (!createdLocally) {
                chat.addMessageListener(itsFbml);
            }
        }
    }); …

我的spark-streaming代码在eclipse IDE上无缝运行.但是当我在本地spark集群上运行它时,它会给出org.apache.spark.util.TaskCompletionListenerException.

同样在spark-submit"客户端模式"代码运行正常,直到我启动我的kafka生产者,但是当我启动生产者时,它给出了以下错误.

我使用命令sh SPARK_HOME/sbin/start-all.sh启动本地群集

并使用此脚本调用spark-submit .

#!/bin/sh

SP_SUBMIT=/home/user/spark/bin/spark-submit
DEP_MODE=client


$SP_SUBMIT \
--deploy-mode $DEP_MODE \
--class com.alind.sparkStream.Test \
--master spark://clstr:7077 \
--name alind\
/home/user/jar/com.alind-0.0.1-SNAPSHOT.jar \

当火花流开始接收消息时,我收到此错误.

2015-06-29 16:13:56 ERROR JobScheduler:96 - Error running job streaming job 1435574590600 ms.3
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 306.0 failed 1 times, most recent failure: Lost task 0.0 in stage 306.0 (TID 164, localhost): org.apache.spark.util.TaskCompletionListenerException
    at org.apache.spark.TaskContextImpl.markTaskCompleted(TaskContextImpl.scala:76)
    at org.apache.spark.scheduler.Task.run(Task.scala:58)
    at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:200)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) …

我们如何将数据添加到Apcache Solr上运行的特定核心.目前我有这段代码,它在单个核心上添加数据,如果我们有多个核心运行具有相同的字段名称,太阳能如何决定写入哪个核心,因为这段代码是模糊的!

我们无处可定义,核心/集合/索引!!!

import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.common.SolrInputDocument;

import java.io.IOException;

public class SolrjPopulator {
  public static void main(String[] args) throws IOException, SolrServerException {
    HttpSolrServer server = new HttpSolrServer("http://localhost:8983/solr");
    for(int i=0;i<1000;++i) {
      SolrInputDocument doc = new SolrInputDocument();
      doc.addField("cat", "book");
      doc.addField("id", "book-" + i);
      doc.addField("name", "The Legend of the Hobbit part " + i);
      server.add(doc);
      if(i%100==0) server.commit();  // periodically flush
    }
    server.commit();
  }
}