We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 500958a commit 6988dfcCopy full SHA for 6988dfc
1 file changed
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
@@ -101,7 +101,6 @@
101
import org.apache.hudi.utilities.sources.InputBatch;
102
import org.apache.hudi.utilities.sources.helpers.KafkaOffsetGen;
103
import org.apache.hudi.utilities.transform.Transformer;
104
-import org.apache.kafka.common.utils.CloseableIterator;
105
import org.apache.log4j.LogManager;
106
import org.apache.log4j.Logger;
107
import org.apache.spark.api.java.JavaRDD;
0 commit comments