[flink] branch master updated (ae96b37 -> 165b1d1)

[tw...@apache.org]

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

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


    from ae96b37  [FLINK-9992][tests] Fix FsStorageLocationReferenceTest#testEncodeAndDecode by adding retries to generate a valid path
     add 165b1d1  [FLINK-19187][examples-table] Add a new basic Table API example

No new revisions were added by this update.

Summary of changes:
 flink-examples/flink-examples-table/pom.xml        |  33 ++++-
 .../java/basics/GettingStartedExample.java         | 147 +++++++++++++++++++++
 .../scala/basics/GettingStartedExample.scala       | 145 ++++++++++++++++++++
 .../scala/{ => basics}/StreamSQLExample.scala      |   2 +-
 .../scala/{ => basics}/StreamTableExample.scala    |   2 +-
 .../scala/{ => basics}/TPCHQuery3Table.scala       |   2 +-
 .../examples/scala/{ => basics}/WordCountSQL.scala |   2 +-
 .../scala/{ => basics}/WordCountTable.scala        |   2 +-
 .../java/basics/GettingStartedExampleITCase.java   |  23 ++--
 .../scala/basics/GettingStartedExampleITCase.java  |  23 ++--
 .../examples/utils/ExampleOutputTestBase.java      |  48 ++++---
 11 files changed, 376 insertions(+), 53 deletions(-)
 create mode 100644 flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/GettingStartedExample.java
 create mode 100644 flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/basics/GettingStartedExample.scala
 rename flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/{ => basics}/StreamSQLExample.scala (98%)
 rename flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/{ => basics}/StreamTableExample.scala (97%)
 rename flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/{ => basics}/TPCHQuery3Table.scala (99%)
 rename flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/{ => basics}/WordCountSQL.scala (97%)
 rename flink-examples/flink-examples-table/src/main/scala/org/apache/flink/table/examples/scala/{ => basics}/WordCountTable.scala (97%)
 copy flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarDeleteHeadersTest.java => flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/java/basics/GettingStartedExampleITCase.java (60%)
 copy flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarDeleteHeadersTest.java => flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/scala/basics/GettingStartedExampleITCase.java (60%)
 copy flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/utils/BatchAbstractTestBase.java => flink-examples/flink-examples-table/src/test/java/org/apache/flink/table/examples/utils/ExampleOutputTestBase.java (54%)