[hotfix] Remove generic row for HiveTableFactory

This closes apache#12324
spotify · May 26, 2020 · 808c87d · 808c87d
1 parent dc32661
commit 808c87d
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java b/...flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java
@@ -27,7 +27,6 @@
 import org.apache.flink.table.factories.TableSourceFactory;
 import org.apache.flink.table.sinks.TableSink;
 import org.apache.flink.table.sources.TableSource;
-import org.apache.flink.types.Row;
 import org.apache.flink.util.Preconditions;
 
 import org.apache.hadoop.hive.conf.HiveConf;
@@ -42,7 +41,7 @@
  * A table factory implementation for Hive catalog.
  */
 public class HiveTableFactory
- implements TableSourceFactory<RowData>, TableSinkFactory<Row> {
+ implements TableSourceFactory<RowData>, TableSinkFactory {
 
  private final HiveConf hiveConf;
 
@@ -79,7 +78,7 @@ public TableSource<RowData> createTableSource(TableSourceFactory.Context context
  }
 
  @Override
- public TableSink<Row> createTableSink(TableSinkFactory.Context context) {
+ public TableSink createTableSink(TableSinkFactory.Context context) {
  CatalogTable table = checkNotNull(context.getTable());
  Preconditions.checkArgument(table instanceof CatalogTableImpl);