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%)
