然而,当我看到Kibana中的数据时,数据显示为损坏的记录,而不是它自己的字段。 下面是处理数据并将其发送到elasticsearch的代码。正如你所看到的,它显示为一个损坏的记录,而不是我的意图,那就是让它成为一个文本,情感和候选字段。我很感谢我能得到的任何帮助,谢谢。 output in kibana
ElasticSearch使用的CPU太多了。今天我发现了这些原木。有人能帮我吗?(LocalIndexShardGateway.java:290) at org.elasticsearch.index.VersionType.fromValue(VersionType.java:307)
at org.ela
我使用Python3在PySpark中使用elasticsearch-py客户端,并且在使用ES和RDD时遇到了一个问题。特别是,我的RDD中的每条记录都是一串文本,我正试图分析它以获取令牌信息,但是当我试图在Spark中的map函数中使用它时,我会遇到一个错误。例如,它非常好地工作:es = Elasticsearch()
t = 'the quick brown fox