[hotfix][elasticsearch] Make TestEmitter#createIndexRequest private

Treydone · Mar 21, 2022 · dda63cf · dda63cf
1 parent 010f622
commit dda63cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...csearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestEmitter.java b/...csearch-base/src/test/java/org/apache/flink/connector/elasticsearch/sink/TestEmitter.java
@@ -58,7 +58,7 @@ public void emit(
         indexer.add(createIndexRequest(element));
     }
 
-    public IndexRequest createIndexRequest(Tuple2<Integer, String> element) {
+    private IndexRequest createIndexRequest(Tuple2<Integer, String> element) {
         Map<String, Object> document = new HashMap<>();
         document.put(dataFieldName, element.f1);
         try {