resolve conflict

apache · Oct 19, 2022 · 6ad6dfe · 6ad6dfe
1 parent 9e2600a
commit 6ad6dfe
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java b/...c/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java
@@ -64,7 +64,6 @@ public class KafkaSourceReader implements SourceReader<SeaTunnelRow, KafkaSource
 
     private volatile boolean running = false;
 
-    KafkaSourceReader(ConsumerMetadata metadata, SeaTunnelRowType typeInfo,
     KafkaSourceReader(ConsumerMetadata metadata,
                       DeserializationSchema<SeaTunnelRow> deserializationSchema,
                       SourceReader.Context context) {