ES查询异常

问题描述 投票:0回答:1

我使用stormcrawler 1.16和ELasticsearch-7.2.0,java版本是1.8.0_252,storm版本是1.2.3,maven版本是3.6.3。

我使用mvn原型创建了一个项目--------。

    mvn archetype:generate -DarchetypeGroupId=com.digitalpebble.stormcrawler - 
    DarchetypeArtifactId=storm-crawler-elasticsearch-archetype -DarchetypeVersion=LATEST

我做了一个seeds.txt文件,放了9个urls,只用于测试,并使用REAEDME.md文件中给出的命令在--远程模式下提交拓扑。

它运行成功,并按照意图抓取页面。

但是当我把8000个URLs放到seeds.txt文件中时,问题就出现了。

我再次运行ES_IndexInit.sh文件,并使用与之前相同的命令提交拓扑,然后我得到了这个错误--。

at java.lang.Thread.run(Thread.java:748) [?:1.8.0_252]
     2020-06-12 11:26:11.416 c.d.s.e.p.AggregationSpout pool-12-thread-1 [ERROR] [spout #1]  Exception with ES query
    java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.8.0_252]
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:714) ~[?:1.8.0_252]
at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvent(DefaultConnectingIOReactor.java:174) [stormjar.jar:?]
at org.apache.http.impl.nio.reactor.DefaultConnectingIOReactor.processEvents(DefaultConnectingIOReactor.java:148) [stormjar.jar:?]
at org.apache.http.impl.nio.reactor.AbstractMultiworkerIOReactor.execute(AbstractMultiworkerIOReactor.java:351) [stormjar.jar:?]
at org.apache.http.impl.nio.conn.PoolingNHttpClientConnectionManager.execute(PoolingNHttpClientConnectionManager.java:221) [stormjar.jar:?]
at org.apache.http.impl.nio.client.CloseableHttpAsyncClientBase$1.run(CloseableHttpAsyncClientBase.java:64) [stormjar.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_252]

然后我在worker.log文件中查找错误,我在那里发现了同样的错误,然后我检查了我的碎片的健康状况------。

      {
   "cluster_name" : "my-cluster1",
  "status" : "green",
  "timed_out" : false,
  "number_of_nodes" : 1,
   "number_of_data_nodes" : 1,
   "active_primary_shards" : 2,
    "active_shards" : 2,
   "relocating_shards" : 0,
    "initializing_shards" : 0,
    "unassigned_shards" : 0,
  "delayed_unassigned_shards" : 0,
   "number_of_pending_tasks" : 0,
   "number_of_in_flight_fetch" : 0,
    "task_max_waiting_in_queue_millis" : 0,
    "active_shards_percent_as_number" : 100.0,
   "indices" : {
     ".kibana_task_manager" : {
      "status" : "green",
      "number_of_shards" : 1,
       "number_of_replicas" : 0,
      "active_primary_shards" : 1,
       "active_shards" : 1,
      "relocating_shards" : 0,
      "initializing_shards" : 0,
      "unassigned_shards" : 0,
     "shards" : {
       "0" : {
      "status" : "green",
      "primary_active" : true,
      "active_shards" : 1,
      "relocating_shards" : 0,
      "initializing_shards" : 0,
      "unassigned_shards" : 0
       }
      }
    },
      ".kibana_1" : {
  "status" : "green",
  "number_of_shards" : 1,
  "number_of_replicas" : 0,
  "active_primary_shards" : 1,
  "active_shards" : 1,
  "relocating_shards" : 0,
  "initializing_shards" : 0,
  "unassigned_shards" : 0,
  "shards" : {
    "0" : {
      "status" : "green",
      "primary_active" : true,
      "active_shards" : 1,
      "relocating_shards" : 0,
      "initializing_shards" : 0,
      "unassigned_shards" : 0
            }
           }
         }
      }
    }

shards的健康状况是绿色的,现在如果我在不同的项目或新项目中提交爬虫拓扑,拓扑仍然是理想的,并且没有发出或传递任何元组。

我使用的版本是否相互兼容? 我应该使用java 11来做elasticsearch,还是可以的?

关于实例的细节 -我使用 ec2 medium intance ubuntu 18.04,内存 4 GB。

谁能解释一下这个问题是什么?

elasticsearch web-crawler apache-storm stormcrawler
1个回答
0
投票

你应该不需要再次运行ESInitScript,除非你想删除状态索引中的URLs。如果你运行了不止一次,状态中就会什么都没有,这可能是拓扑空闲的原因。

种子文件中的URL越多越好,没有任何理由会造成问题,我们经常有> 1M的URL的种子文件,这不是问题。

© www.soinside.com 2019 - 2024. All rights reserved.