This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 4e3fb3c78e76cd13dadda58c36ff18fb037b5269
Author: Dawid Wysakowicz <[email protected]>
AuthorDate: Fri Dec 13 09:50:06 2019 +0100

    [hotfix][table-common] Deprecate TableSource#getSchema.
---
 .../src/main/java/org/apache/flink/table/sources/TableSource.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
index 386240b..1567be1 100644
--- 
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
+++ 
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/TableSource.java
@@ -73,7 +73,10 @@ public interface TableSource<T> {
         * Returns the schema of the produced table.
         *
         * @return The {@link TableSchema} of the produced table.
+        * @deprecated Table schema is a logical description of a table and 
should not be part of the physical TableSource.
+        *             Define schema when registering a Table either in DDL or 
in {@code TableEnvironment#connect(...)}.
         */
+       @Deprecated
        TableSchema getTableSchema();
 
        /**

Reply via email to