Was bedeutet dieser Fehler (SimpleHttpConnectionManager wird falsch verwendet)?

Ich versuche zu lesen, von Daten ElasticSearch zu funken?

conf = {"es.resource":"sflow_*/sflow","es.nodes":"ES01","es.query":'some query'} rdd = sc.newAPIHadoopRDD("org.elasticsearch.hadoop.mr.EsInputFormat", "org.apache.hadoop.io.NullWritable", "org.elasticsearch.hadoop.mr.LinkedMapWritable", conf=conf) rdd.take(2) 

Nach rdd.take (2) Der Prozess wird stecken und das Warn-Log wie unten ausgeben

 16/03/14 20:52:07 WARN httpclient.SimpleHttpConnectionManager: SimpleHttpConnectionManager being used incorrectly. Be sure that HttpMethod.releaseConnection() is always called and that only one thread and/or method is using this connection manager at a time. 

Aber rdd.first () wird immer das Ergebnis erfolgreich zurückgeben. Weißt du, warum?

  • Was sind die Spark-Transformationen, die einen Shuffle verursachen?
  • Bewegen von Spark DataFrame von Python zu Scala mit Zeppelin
  • Was ist der bevorzugte Weg, um 'Ertrag' in Scala zu implementieren?
  • Welche Programmiersprachen kann ich auf Android Dalvik verwenden?
  • Mehrfach-Funken-Bewerbungsunterlagen im Standalone-Modus
  • Python-Äquivalent von Scala's existiert () Funktion?
  • Wie benutzt man die JDBC-Quelle zum Schreiben und Lesen von Daten in (Py) Spark?
  • Scala: Merkmal für ein Funktionsobjekt mit variablen Längenargumenten?
  • Wie benutzt man Scala und Python in einem selben Spark-Projekt?
  • Python: Umleitung des Teilprozesses Popen stdout zur Protokolldatei
  • Was ist das Äquivalent zu scala.util.Try in pyspark?
  • Python ist die beste Programmiersprache der Welt.