我能够完成前两部分,并将我的聚合输出到STDOUT。但是,当我将代码添加到Elasticsearch中时,似乎没有发生任何事情(没有添加数据)。connected to [http://elasticsearch-elasticsearch-coordinating-only.default.svc.cluster.local:9200]
以下是我的代码想知道是否有人能帮我弄清楚为什么Flink作业没有向Elasticsearch添加数据:(从我的Flink集群中,我可以很好地查询Elasticsearch (手动)并将