@Test
    public void processAndcreateIndexRequestTest() {
        customerSinkFunc.process(tuple2, ctx, indexer);
        tuple2.setField(false, 0);
        customerSinkFunc.process(tuple2, ctx, indexer);
    }
Company: www.dtstack.com

@author zhufeng
@date 2020-06-23
elasticsearch6/elasticsearch6-sink/src/test/java/com/dtstack/flink/sql/sink/elasticsearch/CustomerSinkFuncTest.java