You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ja...@apache.org on 2020/05/28 02:34:18 UTC

[flink] branch master updated (5365e40 -> 3a322e0)

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

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 5365e40  [hotfix] Adjust License Headers for FLIP-27 sources to be same as the remaining code base
     add 3a322e0  [FLINK-16021][table-common] Fix DescriptorProperties.putTableSchema does not include PRIMARY KEY

No new revisions were added by this update.

Summary of changes:
 .../ElasticsearchUpsertTableSinkFactoryBase.java   |  8 ++-
 .../flink/connector/hbase/HBaseTableFactory.java   |  8 ++-
 .../table/catalog/hive/HiveCatalogITCase.java      | 46 ++++++++++++++++
 .../jdbc/table/JdbcTableSourceSinkFactory.java     |  8 ++-
 .../kafka/KafkaTableSourceSinkFactoryBase.java     |  8 ++-
 .../gateway/utils/TestTableSinkFactoryBase.java    |  8 ++-
 .../gateway/utils/TestTableSourceFactoryBase.java  |  8 ++-
 .../org/apache/flink/table/descriptors/OldCsv.java |  4 +-
 .../flink/table/descriptors/SchemaValidator.java   | 10 +++-
 .../flink/table/sinks/CsvTableSinkFactoryBase.java | 14 ++---
 .../table/sources/CsvTableSourceFactoryBase.java   | 18 +++---
 .../flink/table/utils/TableSourceFactoryMock.java  | 10 +++-
 .../table/descriptors/DescriptorProperties.java    | 64 ++++++++++++++--------
 .../table/factories/TableFormatFactoryBase.java    |  7 ++-
 .../descriptors/DescriptorPropertiesTest.java      | 15 +++--
 .../planner/catalog/CatalogConstraintTest.java     |  9 +--
 .../flink/table/utils/InMemoryTableFactory.scala   |  7 ++-
 17 files changed, 177 insertions(+), 75 deletions(-)