Skip to content

Commit bac4629

Browse files
修竹修竹
authored andcommitted
完善es结果表文档
1 parent 9e7c131 commit bac4629

File tree

1 file changed

+0
-2
lines changed
  • elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch

1 file changed

+0
-2
lines changed

elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,9 @@
2727
import org.apache.flink.api.java.tuple.Tuple2;
2828
import org.apache.flink.api.java.typeutils.RowTypeInfo;
2929
import org.apache.flink.api.java.typeutils.TupleTypeInfo;
30-
import org.apache.flink.metrics.Counter;
3130
import org.apache.flink.streaming.api.datastream.DataStream;
3231
import org.apache.flink.streaming.api.datastream.DataStreamSink;
3332
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
34-
import org.apache.flink.table.sinks.AppendStreamTableSink;
3533
import org.apache.flink.table.sinks.RetractStreamTableSink;
3634
import org.apache.flink.table.sinks.TableSink;
3735
import org.apache.flink.types.Row;

0 commit comments

Comments
 (0)