[flink] branch master updated (6fa1ea1 -> 5420f29)

[ch...@apache.org]

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

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


    from 6fa1ea1  [FLINK-14163][runtime] Enforce synchronous registration of produced partitions
     add 5420f29  [FLINK-14703][e2e] Port the Kafka SQL related tests.

No new revisions were added by this update.

Summary of changes:
 .../flink-end-to-end-tests-common-kafka/pom.xml    |  94 ++++++++
 .../tests/util/kafka/SQLClientKafkaITCase.java     | 253 +++++++++++++++++++++
 .../test/resources/kafka_json_source_schema.yaml   | 141 ++++++++++++
 .../apache/flink/tests/util/FlinkDistribution.java |  23 ++
 .../flink/tests/util/flink/ClusterController.java  |   8 +
 .../util/flink/LocalStandaloneFlinkResource.java   |   5 +
 .../flink/tests/util/flink/SQLJobSubmission.java   |  97 ++++++++
 flink-end-to-end-tests/run-nightly-tests.sh        |   3 -
 .../test-scripts/test_sql_client_kafka.sh          |  22 --
 .../test-scripts/test_sql_client_kafka010.sh       |  22 --
 .../test-scripts/test_sql_client_kafka011.sh       |  22 --
 .../test-scripts/test_sql_client_kafka_common.sh   | 224 ------------------
 tools/travis/splits/split_misc.sh                  |   5 -
 13 files changed, 621 insertions(+), 298 deletions(-)
 create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/SQLClientKafkaITCase.java
 create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/resources/kafka_json_source_schema.yaml
 create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/SQLJobSubmission.java
 delete mode 100755 flink-end-to-end-tests/test-scripts/test_sql_client_kafka.sh
 delete mode 100755 flink-end-to-end-tests/test-scripts/test_sql_client_kafka010.sh
 delete mode 100755 flink-end-to-end-tests/test-scripts/test_sql_client_kafka011.sh
 delete mode 100755 flink-end-to-end-tests/test-scripts/test_sql_client_kafka_common.sh