flink写入es版本控制问题

写入es有两种，一种是create请求，覆盖操作。一种update局部更新操作。本次讨论各种情况es写入的版本控制问题，以及flink1.6.x与es6.x的小插曲 1：测试不控制版本号的create覆盖操作 Requests.indexRequest() .index("test") .type("_doc") .id(inputjson.getS

>>阅读原文<<