[hotfix] [jdbc] Add generic parameter to ResultTypeQueryable
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b3ac6932 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b3ac6932 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b3ac6932 Branch: refs/heads/table-retraction Commit: b3ac693200aacd6f8a581e25056067fabe0ef356 Parents: 8890a8d Author: zentol <ches...@apache.org> Authored: Thu Apr 6 13:11:35 2017 +0200 Committer: zentol <ches...@apache.org> Committed: Thu Apr 6 19:35:50 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b3ac6932/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java b/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java index 3153f96..e714867 100644 --- a/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java +++ b/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java @@ -95,7 +95,7 @@ import org.slf4j.LoggerFactory; * @see PreparedStatement * @see DriverManager */ -public class JDBCInputFormat extends RichInputFormat<Row, InputSplit> implements ResultTypeQueryable { +public class JDBCInputFormat extends RichInputFormat<Row, InputSplit> implements ResultTypeQueryable<Row> { private static final long serialVersionUID = 1L; private static final Logger LOG = LoggerFactory.getLogger(JDBCInputFormat.class);
