[flink] branch master updated (c0165a8a7e3 -> 469049a4359)

[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 c0165a8a7e3 [FLINK-29101] ignore non canBePipelined consumedPartitionGroup in getAllSchedulableRegions.
     add 469049a4359 [FLINK-29285][tests] Move TestUtils#getResource

No new revisions were added by this update.

Summary of changes:
 .../table/test/KinesisFirehoseTableITTest.java     |  4 +-
 .../table/test/KinesisStreamsTableApiIT.java       |  5 +-
 .../flink/tests/util/kafka/KafkaSinkE2ECase.java   |  8 +--
 .../flink/tests/util/kafka/KafkaSourceE2ECase.java | 10 +--
 .../tests/util/kafka/SQLClientKafkaITCase.java     |  8 +--
 .../util/kafka/SQLClientSchemaRegistryITCase.java  | 11 ++--
 .../flink/tests/util/kafka/SmokeKafkaITCase.java   |  4 +-
 .../org/apache/flink/tests/util/TestUtils.java     | 56 -----------------
 .../streaming/tests/Elasticsearch6SinkE2ECase.java | 10 +--
 .../streaming/tests/Elasticsearch7SinkE2ECase.java | 10 +--
 .../tests/util/hbase/SQLClientHBaseITCase.java     |  9 +--
 .../FlinkContainerWithPulsarEnvironment.java       |  4 +-
 .../apache/flink/tests/scala/ScalaFreeITCase.java  |  7 ++-
 .../flink/table/sql/codegen/SqlITCaseBase.java     |  5 +-
 .../table/sql/codegen/UsingRemoteJarITCase.java    |  5 +-
 .../flink/table/gateway/SqlGatewayE2ECase.java     |  7 ++-
 .../kinesis/test/KinesisTableApiITCase.java        |  4 +-
 .../flink/test/resources/ResourceTestUtils.java    | 73 +---------------------
 18 files changed, 64 insertions(+), 176 deletions(-)
 copy flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/TestUtils.java => flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/resources/ResourceTestUtils.java (57%)