Skip to content

Commit c3dfa05

Browse files
committed
Fix import in HadoopFormatIO
1 parent 23e762c commit c3dfa05

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format

sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,6 @@
8585
import org.apache.hadoop.io.ObjectWritable;
8686
import org.apache.hadoop.io.Writable;
8787
import org.apache.hadoop.mapred.FileAlreadyExistsException;
88-
import org.apache.hadoop.mapred.FileSplit;
8988
import org.apache.hadoop.mapreduce.InputFormat;
9089
import org.apache.hadoop.mapreduce.InputSplit;
9190
import org.apache.hadoop.mapreduce.Job;
@@ -100,6 +99,7 @@
10099
import org.apache.hadoop.mapreduce.TaskAttemptID;
101100
import org.apache.hadoop.mapreduce.TaskID;
102101
import org.apache.hadoop.mapreduce.lib.db.DBConfiguration;
102+
import org.apache.hadoop.mapreduce.lib.input.FileSplit;
103103
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
104104
import org.apache.hadoop.mapreduce.task.JobContextImpl;
105105
import org.apache.hadoop.mapreduce.task.TaskAttemptContextImpl;

0 commit comments

Comments
 (0)