This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2f923867769feb2a6461191ad8656da6cb84002a Author: JingsongLi <[email protected]> AuthorDate: Mon May 25 21:42:25 2020 +0800 [hotfix] Remove generic row for HiveTableFactory This closes #12324 --- .../main/java/org/apache/flink/connectors/hive/HiveTableFactory.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java index 01b16c5..0bb78b8 100644 --- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java +++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableFactory.java @@ -27,7 +27,6 @@ import org.apache.flink.table.factories.TableSinkFactory; 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 @@ import static org.apache.flink.util.Preconditions.checkNotNull; * 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 class HiveTableFactory } @Override - public TableSink<Row> createTableSink(TableSinkFactory.Context context) { + public TableSink createTableSink(TableSinkFactory.Context context) { CatalogTable table = checkNotNull(context.getTable()); Preconditions.checkArgument(table instanceof CatalogTableImpl);
