You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2020/03/04 07:52:50 UTC
[flink] branch master updated (b3f8e33 -> 2b13a41)

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

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


    from b3f8e33  [FLINK-16140] [docs-zh] Translate Event Processing (CEP) page into Chinese (#11168)
     add 2b13a41  [FLINK-16362][table] Remove deprecated `emitDataStream` method in StreamTableSink

No new revisions were added by this update.

Summary of changes:
 docs/dev/table/sourceSinks.md                           | 12 ++++++------
 docs/dev/table/sourceSinks.zh.md                        | 12 ++++++------
 .../connectors/cassandra/CassandraAppendTableSink.java  |  4 ----
 .../elasticsearch/ElasticsearchUpsertTableSinkBase.java |  5 -----
 .../Elasticsearch6UpsertTableSinkFactoryTest.java       |  2 +-
 .../Elasticsearch7UpsertTableSinkFactoryTest.java       |  2 +-
 .../streaming/connectors/kafka/KafkaTableSinkBase.java  |  5 -----
 .../kafka/KafkaTableSourceSinkFactoryTestBase.java      |  4 ++--
 .../apache/flink/addons/hbase/HBaseUpsertTableSink.java |  5 -----
 .../flink/api/java/io/jdbc/JDBCAppendTableSink.java     |  5 -----
 .../flink/api/java/io/jdbc/JDBCUpsertTableSink.java     |  5 -----
 .../flink/api/java/io/jdbc/JDBCAppendTableSinkTest.java |  2 +-
 .../client/gateway/local/CollectStreamTableSink.java    |  5 -----
 .../client/gateway/utils/TestTableSinkFactoryBase.java  |  5 +++--
 .../java/org/apache/flink/table/sinks/CsvTableSink.java |  5 -----
 .../apache/flink/table/sinks/OutputFormatTableSink.java |  5 -----
 .../org/apache/flink/table/sinks/StreamTableSink.java   | 17 +----------------
 .../java/org/apache/flink/table/api/TableUtils.java     |  5 -----
 .../flink/table/planner/sinks/CollectTableSink.scala    |  4 ----
 .../factories/utils/TestCollectionTableFactory.scala    |  4 ----
 .../runtime/batch/sql/PartitionableSinkITCase.scala     |  5 -----
 .../table/planner/runtime/utils/StreamTestSink.scala    | 12 ------------
 .../table/planner/utils/MemoryTableSourceSinkUtil.scala |  5 -----
 .../factories/utils/TestCollectionTableFactory.scala    |  4 ++--
 .../table/runtime/stream/table/TableSinkITCase.scala    | 15 ++++++---------
 .../flink/table/utils/MemoryTableSourceSinkUtil.scala   |  4 ++--
 .../walkthrough/common/table/SpendReportTableSink.java  |  6 ++++--
 27 files changed, 35 insertions(+), 129 deletions(-)