You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2020/05/26 06:30:49 UTC
[flink] 04/04: [hotfix] Remove generic row for HiveTableFactory
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 <lz...@aliyun.com>
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);